stream

type CommandController interface {
	CommandSink(context.Context, *Stream, *command.Command) (*command.Reply, error)
}

type CommandControllerOption func(*commandController)

type CommandSinker interface {
	CommandSink(ctx context.Context, cmd *command.Command) (*command.Reply, error)
}

type CommandSinkerInterceptor func(CommandSinker) CommandSinker

type ConnectorPublisher struct {
}

type ControllerFunc func(context.Context, *Stream, *command.Command) (*command.Reply, error)

type EventController interface {
	PickStream(*event.Event) Picker
	EventSink(context.Context, *Stream, *event.Event) error
}

type EventControllerOption func(*eventController)

type EventErrorHandler interface {
	HandleError(ctx context.Context, e *event.Event, err error)
}

type EventHandler interface {
	Match(eventName string) bool
	Handle(context.Context, *event.Event) error
	Rollback(context.Context, *event.Event) error
}

type EventHandlerFunc func(ctx context.Context, e *event.Event) error

type EventHandlerInterceptor func(handler EventHandler) EventHandler

type EventSinker interface {
	EventSink(ctx context.Context, e *event.Event) error
}

type EventSinkerInterceptor func(EventSinker) EventSinker

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

type MutatorOption func(*Mutator)

type Picker struct {
	StreamID  uuid.UUID
	StreamIDs []uuid.UUID
}

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

type Publisher interface {
	Publish(event []*event.Event) error
}

type State interface {
	Mutate(*event.Event)
	encoding.BinaryUnmarshaler
	encoding.BinaryMarshaler
}

type Storage interface {
	StreamName() string
	NewStream() *Stream
	Persist(ctx context.Context, s *Stream) error
	Load(ctx context.Context, streamID uuid.UUID) (*Stream, error)
	Drop(ctx context.Context, streamID uuid.UUID) error
}

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

type Subscriber interface {
	Subscribe(streamName string, h ...EventHandler)
}