rita

type Command struct {
	// ID is a unique identifier for the command.
	ID string

	// Time is the time of when the command was received.
	Time time.Time

	// Type is a unique name for the command. This can be omitted
	// if a type registry is being used, otherwise it must be set explicitly
	// to identity the encoded data.
	Type string

	// Data is the command data. This must be a byte slice (pre-encoded) or a value
	// of a type registered in the type registry.
	Data any

	// Meta is application-defined metadata about the command.
	Meta map[string]string
}

type Decider interface {
	Decide(*Command) ([]*Event, error)
}

type DeciderEvolver interface {
	Decider
	Evolver
}

type Event struct {
	// ID of the event. This will be used as the NATS msg ID
	// for de-duplication.
	ID string

	// Identifier for specific entities. Can be used to determine if
	// an event is related to a specific entity/node/endpoint/agent/etc.
	// The format must be two tokens, e.g. "node.1234".
	Entity string

	// Time is the time of when the event occurred which may be different
	// from the time the event is appended to the store. If no time is provided,
	// the current local time will be used.
	Time time.Time

	// Type is a unique name for the event itself. This can be omitted
	// if a type registry is being used, otherwise it must be set explicitly
	// to identity the encoded data.
	Type string

	// Data is the event data. This must be a byte slice (pre-encoded) or a value
	// of a type registered in the type registry.
	Data any

	// Metadata is application-defined metadata about the event.
	Meta map[string]string

	// Expect can be set to specify optimistic concurrency control
	// expectations for an append operation.
	Expect *Expect
	// contains filtered or unexported fields
}

type EventStore struct {
	// contains filtered or unexported fields
}

type EventStoreConfig struct {
	Name        string
	Description string
	Metadata    map[string]string
	Replicas    int
	Storage     jetstream.StorageType
	Placement   *jetstream.Placement
	RePublish   *jetstream.RePublish
	MaxMsgs     int64
	MaxAge      time.Duration
	MaxBytes    int64
}

type EvolveOption interface {
	// contains filtered or unexported methods
}

type Evolver interface {
	Evolve(*Event) error
}

type Expect struct {
	Sequence uint64
	Pattern  string
}

type Manager struct {
	// contains filtered or unexported fields
}

type ManagerOption interface {
	// contains filtered or unexported methods
}

type Model[T any] struct {
	// contains filtered or unexported fields
}

type Viewer[T any] interface {
	View(func(T) error) error
}

type WatchOption interface {
	// contains filtered or unexported methods
}

type Watcher interface {
	Stop()
}