command

Oct 18, 2023

Changes in this version

type Bus

+ func (bus *Bus) HandleClosure(cmd ClosureCommand) *Async

+ type ClosureCommand func() (data any, err error)

Oct 13, 2023

Changes in this version

+ const HandlerNotFoundError

+ const OneHandlerPerCommandError

+ type Async struct

+ func (res *Async) Await() error

+ func (res *Async) Get() (any, error)

type Bus

+ func (bus *Bus) SetErrorHandlers(hdls ...ErrorHandler)

+ func (bus *Bus) SetInwardMiddlewares(mdls ...InwardMiddleware)

+ func (bus *Bus) SetOutwardMiddlewares(mdls ...OutwardMiddleware)

+ func (bus *Bus) SetQueueBuffer(queueBuffer int)

+ func (bus *Bus) SetWorkerPoolSize(workerPoolSize int)

+ type BusError string

+ func (e BusError) Error() string

type Command

+ Identifier func() Identifier

type Handler

+ Handles func() Identifier

+ type Identifier int64

+ type InwardMiddleware interface

+ HandleInward func(cmd Command) error

+ type OutwardMiddleware interface

+ HandleOutward func(cmd Command, data any, err error) error

Sep 28, 2020

Changes in this version

type Bus

+ func (bus *Bus) RemoveScheduled(keys ...uuid.UUID)

+ func (bus *Bus) Schedule(cmd Command, sch *schedule.Schedule) (*uuid.UUID, error)

May 1, 2020

Changes in this version

+ const BusIsShuttingDownError

+ const BusNotInitializedError

+ const InvalidCommandError

+ type Bus struct

+ func NewBus() *Bus

+ func (bus *Bus) ErrorHandlers(hdls ...ErrorHandler)

+ func (bus *Bus) Handle(cmd Command) error

+ func (bus *Bus) HandleAsync(cmd Command) error

+ func (bus *Bus) Initialize(hdls ...Handler)

+ func (bus *Bus) QueueBuffer(queueBuffer int)

+ func (bus *Bus) Shutdown()

+ func (bus *Bus) WorkerPoolSize(workerPoolSize int)

+ type Command interface

+ ID func() []byte

+ type ErrorBusIsShuttingDown string

+ func (e ErrorBusIsShuttingDown) Error() string

+ type ErrorBusNotInitialized string

+ func (e ErrorBusNotInitialized) Error() string

+ type ErrorHandler interface

+ Handle func(cmd Command, err error)

+ type ErrorInvalidCommand string

+ func (e ErrorInvalidCommand) Error() string

+ type Handler interface

+ Handle func(cmd Command) error