event

Documentation

Index

• Variables
• type Codec
  • func New() *Codec
  • func (e *Codec) Decode(ctx context.Context, streamType string, eventType string, bytes []byte) (event interface{}, err error)
  • func (e *Codec) Default(enc es.EncodeFunc, dec es.DecodeFunc)
  • func (e *Codec) Encode(ctx context.Context, streamType string, eventType string, event interface{}) (bytes []byte, err error)
  • func (e *Codec) Stream(streamType string) *Event
• type Event
  • func (ec *Event) Decode(ctx context.Context, eventType string, bytes []byte) (event interface{}, err error)
  • func (ec *Event) Default(enc es.EncodeFunc, dec es.DecodeFunc)
  • func (ec *Event) Encode(ctx context.Context, eventType string, event interface{}) (bytes []byte, err error)
  • func (ec *Event) Event(eventType string, enc es.EncodeFunc, dec es.DecodeFunc) *Event

Variables

var (
	ErrEventEncoderNotFound = errors.New("event encoder not found")
	ErrEventDecoderNotFound = errors.New("event decoder not found")
	ErrNoStream             = errors.New("no stream type")
)

Types

type Codec

type Codec struct {
	// contains filtered or unexported fields
}

func New

func New() *Codec

func (*Codec) Decode

func (e *Codec) Decode(ctx context.Context, streamType string, eventType string, bytes []byte) (event interface{}, err error)

func (*Codec) Default

func (e *Codec) Default(enc es.EncodeFunc, dec es.DecodeFunc)

func (*Codec) Encode

func (e *Codec) Encode(ctx context.Context, streamType string, eventType string, event interface{}) (bytes []byte, err error)

func (*Codec) Stream

func (e *Codec) Stream(streamType string) *Event

type Event

type Event struct {
	// contains filtered or unexported fields
}

func (*Event) Decode

func (ec *Event) Decode(ctx context.Context, eventType string, bytes []byte) (event interface{}, err error)

func (*Event) Default

func (ec *Event) Default(enc es.EncodeFunc, dec es.DecodeFunc)

func (*Event) Encode

func (ec *Event) Encode(ctx context.Context, eventType string, event interface{}) (bytes []byte, err error)

func (*Event) Event

func (ec *Event) Event(eventType string, enc es.EncodeFunc, dec es.DecodeFunc) *Event