marshaler

Documentation

Index

• Constants
• func NewCloudEvent(ev Event) (cloudevents.Event, error)
• type Event
  • func WithSource(source string, ev Event) Event
• type Marshaler
  • func New(transform TransformFunc) Marshaler
• type TransformFunc

Constants

const (
	CloudEventsHeaderType    = "ce_type"
	CloudEventsHeaderTime    = "ce_time"
	CloudEventsHeaderSource  = "ce_source"
	CloudEventsHeaderSubject = "ce_subject"
)

const (
	UnknownEventName = "io.openmeter.unknown"
)

Functions

func NewCloudEvent

func NewCloudEvent(ev Event) (cloudevents.Event, error)

Types

type Event

type Event interface {
	EventName() string
	EventMetadata() metadata.EventMetadata
	Validate() error
}

func WithSource

func WithSource(source string, ev Event) Event

WithSource can be used to add the CloudEvents source field to an event.

type Marshaler

type Marshaler = cqrs.CommandEventMarshaler

func New

func New(transform TransformFunc) Marshaler

type TransformFunc

type TransformFunc func(watermillIn *message.Message, cloudEvent cloudevents.Event) (*message.Message, error)