ship

Jul 13, 2022

Changes in this version

type Publisher

+ PublishRaw func(topic string, message *RawMessage) error

May 23, 2022

Changes in this version

type RawMessageHandler

+ HandleRawMessage func(ctx context.Context, m *RawMessage) error

May 23, 2022

Changes in this version

+ type RawMessage struct

+ Attributes map[string]string

+ Data []byte

+ ID string

+ OrderingKey string

+ PublishTime time.Time

+ type RawMessageHandler interface

+ HandleMessage func(ctx context.Context, m *RawMessage) error

type Subscriber

+ SubscribeRaw func(subscription string, handler RawMessageHandler) error

Feb 9, 2022

Changes in this version

+ func RegisterEvent(e Event)

+ func UnregisterEvent(event Event)

+ type Event interface

+ EventName func() string

+ func GetEvent(name string) (Event, error)

+ type Message struct

+ AggregateID string

+ AggregateType string

+ At time.Time

+ Data Event

+ ID string

+ Metadata Metadata

+ Type string

+ Version uint64

+ type MessageHandler interface

+ HandleMessage func(ctx context.Context, m *Message) error

+ type MessageHandlerFunc func(context.Context, *Message) error

+ func (f MessageHandlerFunc) HandleMessage(ctx context.Context, m *Message) error

+ type Metadata map[string]string

+ func (m Metadata) Scan(v interface{}) error

+ func (m Metadata) Value() (driver.Value, error)

+ type PubSub interface

+ type Publisher interface

+ Publish func(topic string, messages ...*Message) error

+ type Subscriber interface

+ Subscribe func(subscription string, handler MessageHandler) error