comps

type BehaviorStoreFtor func() IBehaviorStore

type BusFtor func() (IBus, error)

type CmdHandlerFtor func() ICmdHandler

type CommandHandler interface {
	Handle(ctx context.Context, cmd behavior.ICmd) contract.IFbk
}

type Component struct {
	Name schema.Name
	// contains filtered or unexported fields
}

type EventReaction struct {
	*Component
	// contains filtered or unexported fields
}

type EventStoreFtor func() IEventStore

type EvtReactionFtor func() IEvtReaction

type GenBusFtor[TConn interface{}, TMsg interface{}] func() (IGenBus[TConn, TMsg], error)

type GenCommandHandler[T behavior.ICmd] interface {
	Handle(ctx context.Context, cmd T) contract.IFbk
}

type GenEvtReactionFtor[TEvt behavior.IEvt] func() IGenEvtReaction[TEvt]

type GenEvtReactor[TEvt behavior.IEvt] struct {
	*Component
	// contains filtered or unexported fields
}

type GenMediatorLoggerFtor[TEvt behavior.IEvt] func() IGenMediatorLogger[TEvt]

type GenMsgReactionFtor[TMsg schema.IMsg] func() IGenMsgReaction[TMsg]

type GenProjFtor[TEvt behavior.IEvt, TState schema.ISchema] func() IGenProjection[TEvt, TState]

type GenProjection[TEvt behavior.IEvt, TState schema.ISchema] struct {
	*EventReaction
	// contains filtered or unexported fields
}

type GenProjectionFtor[TEvt behavior.IEvt, TState schema.ISchema] func() IGenProjection[TEvt, TState]

type GenReactFunc[TEvt behavior.IEvt] func(ctx context.Context, evt TEvt) error

type GenRequesterFtor[THope contract.IHope] func() (IGenRequester[THope], error)

type GenResponderFtor[THope contract.IHope] func() IGenResponder[THope]

type IActivate interface {
	Activate(ctx context.Context) error
}

type IBehaviorStore interface {
	IClose
	Load(ctx context.Context, behavior behavior.IBehavior) error
	Save(ctx context.Context, behavior behavior.IBehavior) error
	Exists(ctx context.Context, streamID string) error
}

type IBus interface {
	Close()
	Publish(ctx context.Context, topic string, data []byte) error
	Request(ctx context.Context, topic string, data []byte, timeout time.Duration) ([]byte, error)
	RequestAsync(ctx context.Context, topic string, data []byte, timeout time.Duration, responses chan []byte) func() error
	Listen(ctx context.Context, topic string, facts chan []byte)
	ListenAsync(ctx context.Context, topic string, facts chan []byte) func() error
	Wait() error
}

type IClose interface {
	Close() error
}

type ICmdHandler interface {
	IComponent
	CommandHandler
}

type IComponent interface {
	GetMediator() mediator.IMediator
	GetName() schema.Name
	GetLogger() logger.IAppLogger
	GetConfig() config.IAppConfig
}

type IConnection[TConn interface{}] interface {
	Connection() TConn
}

type IDeactivate interface {
	Deactivate(ctx context.Context) error
}

type IEmitter interface {
	ISpokePlugin
	IMediatorReaction
	IAmEmitter()
}

type IEventStore interface {
	IBehaviorStore
	ISnapshotStore
	SaveEvents(ctx context.Context, streamID string, events []behavior.IEvt) error
	LoadEvents(ctx context.Context, streamID string) ([]behavior.IEvt, error)
}

type IEvtReaction interface {
	IMediatorReaction
}

type IGenBus[TConn interface{}, TMsg interface{}] interface {
	IBus
	IConnection[TConn]
	Respond(ctx context.Context, topic string, hopes chan TMsg)
	RespondAsync(ctx context.Context, topic string, hopes chan TMsg) func() error
}

type IGenCmdHandler[T behavior.ICmd] interface {
	GenCommandHandler[T]
	GetTopic() behavior.Topic
	GetBehaviorStore() IBehaviorStore
	GetBehavior(ID schema.IIdentity) behavior.IBehavior
	SetTopic(topic behavior.Topic)
}

type IGenEvtReaction[TEvt behavior.IEvt] interface {
	IGenMediatorReaction[TEvt]
}

type IGenListener[TMsg interface{}, TFact contract.IFact] interface {
	IListener
}

type IGenMediatorLogger[TEvt behavior.IEvt] interface {
	IGenEvtReaction[TEvt]
}

type IGenMediatorReaction[TEvt behavior.IEvt] interface {
	ISpokePlugin
	behavior.IGetEvtType
	behavior.IGenReacter[TEvt]
}

type IGenMsgReaction[TMsg schema.IMsg] interface {
	IMsgReaction
	GenWhen(ctx context.Context, msg TMsg)
}

type IGenProjection[TEvt behavior.IEvt, TState schema.ISchema] interface {
	IProjection
}

type IGenRequester[THope contract.IHope] interface {
	IRequester
	GenRequest(ctx context.Context, hope THope, timeout time.Duration) contract.IFbk
	GenRequestAsync(ctx context.Context, hope THope, timeout time.Duration) contract.IFbk
}

type IGenResponder[THope contract.IHope] interface {
	IResponder
}

type IListener interface {
	ISpokePlugin
	IAmFactListener()
}

type IMediatorLogger interface {
	IEvtReaction
}

type IMediatorReaction interface {
	ISpokePlugin
	behavior.IGetEvtType
	behavior.Reacter
}

type IMsgReaction interface {
	ISpokePlugin
}

type IPolicy interface {
	IMediatorReaction
	IAmPolicy()
}

type IProjection interface {
	IMediatorReaction
	IAmProjection()
}

type IProjector interface {
	ISpokePlugin
	behavior.Reacter
	Project(ctx context.Context, prefixes []string, poolSize int) error
	Inject(handlers ...IProjection)
}

type IQueryProvider interface {
	ISpokePlugin
	IAmQueryProvider()
	RunQuery(ctx context.Context, qry contract.IReq) contract.IRsp
}

type IRequester interface {
	IComponent
	IAmRequester()
	GetHopeType() contract.HopeType
	Request(ctx context.Context, hope contract.IHope, timeout time.Duration) contract.IFbk
	RequestAsync(ctx context.Context, hope contract.IHope, timeout time.Duration) contract.IFbk
}

type IResponder interface {
	ISpokePlugin
	IAmResponder()
	GetHopeType() contract.HopeType
}

type IShutdown interface {
	Shutdown(ctx context.Context)
}

type ISnapshotStore interface {
	SaveSnapshot(ctx context.Context, aggregate behavior.IBehavior) error
	GetSnapshot(ctx context.Context, id string) (*behavior.Snapshot, error)
}

type ISpokePlugin interface {
	IComponent
	IActivate
	IDeactivate
}

type IStore interface {
	Load(id string) interface{}
	Save(id string, model interface{})
}

type MediatorLoggerFtor func() IMediatorLogger

type MsgReaction struct {
	*Component
	// contains filtered or unexported fields
}

type MsgReactionFtor func() IMsgReaction

type OnEvtFunc func(ctx context.Context, evt behavior.IEvt) error

type OnMsgFunc func(ctx context.Context, msg schema.IMsg) error

type Policy struct {
	*EventReaction
	NewCH CmdHandlerFtor
}

type ProjFtor[TEvt behavior.IEvt, TState schema.ISchema] func() IProjection

type ProjectorBuilder func(newProj ProjectorFtor) IProjector

type ProjectorFtor func() IProjector

type QryProvider[TReadModel schema.ISchema] struct {
	*Component
	// contains filtered or unexported fields
}

type QryWorker[TReadModel schema.ISchema] func(ctx context.Context, store behavior.IModelStore[TReadModel], qry contract.IReq) contract.IRsp

type RequesterFtor func() (IRequester, error)