events

Nov 13, 2020

Changes in this version

+ var ErrEncodingMessage = errors.New("Error encoding message")

+ var ErrMissingTopic = errors.New("Missing topic")

+ type Event struct

+ ID string

+ Metadata map[string]string

+ Payload []byte

+ Timestamp time.Time

+ Topic string

+ func (e *Event) Unmarshal(v interface{}) error

+ type PublishOption func(o *PublishOptions)

+ func WithMetadata(md map[string]string) PublishOption

+ func WithTimestamp(t time.Time) PublishOption

+ type PublishOptions struct

+ Metadata map[string]string

+ Timestamp time.Time

+ type ReadOption func(o *ReadOptions)

+ func ReadFilter(key, value string) ReadOption

+ func ReadLimit(l int) ReadOption

+ func ReadOffset(l int) ReadOption

+ func ReadTopic(t string) ReadOption

+ type ReadOptions struct

+ Limit int

+ Offset int

+ Query map[string]string

+ Topic string

+ type Store interface

+ Read func(ctx context.Context, opts ...ReadOption) ([]*Event, error)

+ Write func(ctx context.Context, event *Event, opts ...WriteOption) error

+ type Stream interface

+ Publish func(ctx context.Context, topic string, msg interface{}, opts ...PublishOption) error

+ Subscribe func(ctx context.Context, topic string, opts ...SubscribeOption) (<-chan Event, error)

+ type SubscribeOption func(o *SubscribeOptions)

+ func WithQueue(q string) SubscribeOption

+ func WithStartAtTime(t time.Time) SubscribeOption

+ type SubscribeOptions struct

+ Queue string

+ StartAtTime time.Time

+ type WriteOption func(o *WriteOptions)

+ func WithTTL(d time.Duration) WriteOption

+ type WriteOptions struct

+ TTL time.Duration