streams

Jul 6, 2020

Changes in this version

+ type HandlerFunc func(ctx context.Context, msg Message) error

+ func (fn HandlerFunc) Handle(ctx context.Context, msg Message) error

type Message

+ CorrelationId string

+ GlobalNumber int64

May 16, 2020

Changes in this version

+ type Handler interface

+ Handle func(ctx context.Context, msg Message) error

+ type Id struct

+ Entity string

+ Group string

+ func ParseId(format string, args ...interface{}) Id

+ func (id Id) HasEntity() bool

+ func (id Id) String() string

+ func (id Id) Value() (driver.Value, error)

+ func (id Id) WithEntity(format string, args ...interface{}) Id

+ type Message struct

+ Data interface{}

+ GroupNumber int64

+ Number int64

+ Stream Id

+ Time time.Time

+ Type string

+ type NamedSnapshot interface

+ SnapshotName func() string