event

Nov 20, 2022

Changes in this version

+ func Error(ctx context.Context, err error) Event

+ func Infof(ctx context.Context, key any, format string, a ...any) Event

+ func New(ctx context.Context, key, value any) Event

+ type Receiver struct

+ func (r *Receiver) Rcv(ctx context.Context, fn func(Event) error, src ...EventSource) error

+ func (s *Receiver) String() string

+ type Source struct

+ Cap int

+ func (s *Source) Close() error

+ func (s *Source) Emit(e Event) bool

+ func (s *Source) Len() int

+ func (s *Source) String() string

+ func (s *Source) Sub() <-chan Event

+ func (s *Source) Unsub(ch <-chan Event)