spokes

type AppBuilder func() IApp

type AppFtor func() IApp

type CmdSpoke struct {
	*Spoke
	// contains filtered or unexported fields
}

type CmdSpokeBuilder func() ICommandSpoke

type CmdSpokeFtor func() ICommandSpoke

type GenCmdSpoke struct {
	*Spoke
	// contains filtered or unexported fields
}

type GenCmdSpokeBuilder[T behavior.ICmd] func() IGenCmdSpoke[T]

type GenCmdSpokeFtor[T behavior.ICmd] func() IGenCmdSpoke[T]

type IApp interface {
	comps.IComponent
	comps.IShutdown
	Run() error
	Inject(spokes ...ISpoke) IApp
}

type ICommandSpoke interface {
	IMediatorSpoke
}

type IGenCmdSpoke[T behavior.ICmd] interface {
	ICommandSpoke
}

type IMediatorSpoke interface {
	ISpoke
}

type IProjectionSpoke interface {
	ISpoke
}

type IPulsarSpoke interface {
	ISpoke
}

type IQuerySpoke interface {
	ISpoke
}

type ISpoke interface {
	comps.IComponent
	comps.IShutdown
	Run(ctx context.Context) func() error
	Inject(reactions ...comps.ISpokePlugin) ISpoke
}

type ProjectionSpoke struct {
	*Spoke
	// contains filtered or unexported fields
}

type ProjectionSpokeBuilder func() IProjectionSpoke

type ProjectionSpokeFtor func() IProjectionSpoke

type PulsarSpoke struct {
	*Spoke
	// contains filtered or unexported fields
}

type QrySpoke struct {
	*Spoke
	// contains filtered or unexported fields
}

type Spoke struct {
	*comps.Component
	// contains filtered or unexported fields
}

type SpokeBuilder func() ISpoke

type SpokeFtor func() ISpoke