event

Feb 18, 2021

Changes in this version

type Event

+ AppliesAt time.Time

+ ID string

+ Sender Sender

+ Timestamp time.Time

+ func New(msg proto.Message) Event

+ type Sender struct

+ Application string

+ Metadata map[string]string

Oct 19, 2020

Changes in this version

+ type Event struct

+ Payload []byte

+ Topic string

+ type Handler func(ctx context.Context, evt Event) error

+ type MultiReader struct

+ func NewMultiReader(ctx context.Context, urls []string) (*MultiReader, error)

+ func (mr *MultiReader) Close() error

+ func (mr *MultiReader) Read(ctx context.Context, fn Handler) error

+ type Reader struct

+ func NewReader(ctx context.Context, urlStr string) (*Reader, error)

+ func (r *Reader) Close() error

+ func (r *Reader) Read(ctx context.Context, fn Handler) error

+ type Writer struct

+ func NewWriter(ctx context.Context, urlStr string) (*Writer, error)

+ func (w *Writer) Close() error

+ func (w *Writer) Write(ctx context.Context, evt Event) error