Versions in this module Expand all Collapse all v2 v2.6.0 Apr 26, 2021 Changes in this version + var ErrCannotConvertToEvent = errors.New("cannot convert message to event") + var ErrNotBinary = errors.New("message is not in binary mode") + var ErrNotStructured = errors.New("message is not in structured mode") + var ErrUnknownEncoding = errors.New("unknown Message encoding") + func GetOrDefaultFromCtx(ctx context.Context, key interface{}, def interface{}) interface + func ToEvent(ctx context.Context, message MessageReader, transformers ...Transformer) (*event.Event, error) + func UseFormatForEvent(ctx context.Context, f format.Format) context.Context + func WithForceBinary(ctx context.Context) context.Context + func WithForceStructured(ctx context.Context) context.Context + func WithPreferredEventEncoding(ctx context.Context, enc Encoding) context.Context + func WithSkipDirectBinaryEncoding(ctx context.Context, skip bool) context.Context + func WithSkipDirectStructuredEncoding(ctx context.Context, skip bool) context.Context + type BinaryWriter interface + End func(ctx context.Context) error + SetData func(data io.Reader) error + Start func(ctx context.Context) error + type Encoding int + const EncodingBinary + const EncodingEvent + const EncodingStructured + const EncodingUnknown + func DirectWrite(ctx context.Context, message MessageReader, structuredWriter StructuredWriter, ...) (Encoding, error) + func Write(ctx context.Context, message MessageReader, structuredWriter StructuredWriter, ...) (Encoding, error) + func (e Encoding) String() string + type EventMessage event.Event + func (*EventMessage) Finish(error) error + func (m *EventMessage) GetAttribute(k spec.Kind) (spec.Attribute, interface{}) + func (m *EventMessage) GetExtension(name string) interface{} + func (m *EventMessage) ReadBinary(ctx context.Context, b BinaryWriter) (err error) + func (m *EventMessage) ReadEncoding() Encoding + func (m *EventMessage) ReadStructured(ctx context.Context, builder StructuredWriter) error + type ExactlyOnceMessage interface + Received func(settle func(error)) + type Message interface + Finish func(error) error + func ToMessage(e *event.Event) Message + func UnwrapMessage(message Message) Message + func WithFinish(m Message, finish func(error)) Message + type MessageContext interface + Context func() context.Context + type MessageMetadataReader interface + GetAttribute func(attributeKind spec.Kind) (spec.Attribute, interface{}) + GetExtension func(name string) interface{} + type MessageMetadataWriter interface + SetAttribute func(attribute spec.Attribute, value interface{}) error + SetExtension func(name string, value interface{}) error + type MessageReader interface + ReadBinary func(context.Context, BinaryWriter) error + ReadEncoding func() Encoding + ReadStructured func(context.Context, StructuredWriter) error + type MessageWrapper interface + GetWrappedMessage func() Message + type StructuredWriter interface + SetStructuredEvent func(ctx context.Context, format format.Format, event io.Reader) error + type Transformer interface + Transform func(MessageMetadataReader, MessageMetadataWriter) error + type TransformerFunc func(MessageMetadataReader, MessageMetadataWriter) error + func (t TransformerFunc) Transform(r MessageMetadataReader, w MessageMetadataWriter) error + type Transformers []Transformer + func (t Transformers) Transform(r MessageMetadataReader, w MessageMetadataWriter) error
Go to main page