bee

Jul 6, 2025

Changes in this version

+ func Event(ctx context.Context, fn ManagerEventApplier, opts ...eo.Options) error

+ type ManagerEventApplier interface

+ Handle func(event *gen.EventEnvelope) ([]*gen.CommandEnvelope, error)

Jun 19, 2025

Changes in this version

+ var CommandsPrefix = "cmds"

+ var EventsPrefix = "events"

+ var QueryPrefix = "query"

Jun 19, 2025

Changes in this version

+ func MustUnmarshal[T any](data []byte) T

Jun 18, 2025

Changes in this version

+ const DeliverAll

+ func Command(ctx context.Context, handler CommandHandler, opts ...co.Options)

+ func GetCommand(aggreate, command string) any

+ func GetEvent(aggreate, event string) any

+ func JetStream(ctx context.Context) (nats.JetStreamContext, bool)

+ func Nats(ctx context.Context) (*nats.Conn, bool)

+ func Project(ctx context.Context, fn EventApplier, opts ...po.Options) error

+ func PublishCommand(ctx context.Context, cmd *gen.CommandEnvelope, payload any) error

+ func Query(ctx context.Context, fn Querier, opts ...qo.Options) error

+ func RegisterCommand[T any](aggreate, command string)

+ func RegisterEvent[T any](aggreate, event string)

+ func Replay(ctx context.Context, fn ReplayHandler, opts ...ro.Options)

+ func ReplayAndSubscribe[T EventApplier](ctx context.Context, agg T, opts ...ro.Options) <-chan T

+ func UnmarshalCommand(c *gen.CommandEnvelope) (any, error)

+ func UnmarshalEvent(e *gen.EventEnvelope) (any, error)

+ func Unmarshal[T any](data []byte) (T, error)

+ func WithJetStream(ctx context.Context, js nats.JetStreamContext) context.Context

+ func WithNats(ctx context.Context, nc *nats.Conn) context.Context

+ type CommandHandler interface

+ Handle func(ctx context.Context, m *gen.CommandEnvelope) ([]*gen.EventEnvelope, error)

+ type CommandProcessor struct

+ type EventApplier interface

+ ApplyEvent func(event *gen.EventEnvelope) error

+ type Projector interface

+ type Querier interface

+ Query func(query *gen.QueryEnvelope) (interface{}, error)

+ type ReplayHandler interface

+ ApplyEvent func(m *gen.EventEnvelope) error