Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ErrFunc ¶
type ErrFunc func(err error)
ErrFunc used by handler to report error from observation
type Event ¶
type Event = interface { Version() uint64 EventType() string AggregateID() string GroupID() string IsSnapshot() bool Timestamp() time.Time }
Event interface over event created by user.
type EventUnmarshaler ¶
type EventUnmarshaler = interface { Version() uint64 EventType() string AggregateID() string GroupID() string IsSnapshot() bool Timestamp() time.Time Unmarshal(v interface{}) error }
EventUnmarshaler provides event.
type GoroutinePoolGoFunc ¶
type GoroutinePoolGoFunc func(func()) error
GoroutinePoolGoFunc processes actions via provided function
type GoroutinePoolHandler ¶
type GoroutinePoolHandler struct {
// contains filtered or unexported fields
}
GoroutinePoolHandler submit events to goroutine pool for process them.
func NewGoroutinePoolHandler ¶
func NewGoroutinePoolHandler( goroutinePoolGo GoroutinePoolGoFunc, eventsHandler Handler, errFunc ErrFunc, ) *GoroutinePoolHandler
NewGoroutinePoolHandler creates new event processor.
type Iter ¶
type Iter = interface { Next(ctx context.Context) (EventUnmarshaler, bool) Err() error }
Iter provides iterator over events from eventstore or eventbus.
Click to show internal directories.
Click to hide internal directories.