publisher

Documentation

Index

• Constants
• type CloudEventMarshaler
  • func NewCloudEventMarshaler(transform TransformFunc) CloudEventMarshaler
• type Publisher
  • func NewPublisher(opts PublisherOptions) (Publisher, error)
• type PublisherOptions
• type TopicPublisher
  • func NewMockTopicPublisher(t *testing.T) TopicPublisher
• type TransformFunc

Constants

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

Types

type CloudEventMarshaler

type CloudEventMarshaler interface {
	MarshalEvent(event.Event) (*message.Message, error)
}

func NewCloudEventMarshaler

func NewCloudEventMarshaler(transform TransformFunc) CloudEventMarshaler

type Publisher

type Publisher interface {
	ForTopic(topic string) TopicPublisher
}

func NewPublisher

func NewPublisher(opts PublisherOptions) (Publisher, error)

type PublisherOptions

type PublisherOptions struct {
	// Publisher is the underlying watermill publisher object
	Publisher message.Publisher

	// Transform is a function that can be used to transform the message before it is published, mainly used
	// for driver specific tweaks. If more are required, we should add a chain function.
	Transform TransformFunc
}

type TopicPublisher

type TopicPublisher interface {
	Publish(event event.Event) error
}

func NewMockTopicPublisher

func NewMockTopicPublisher(t *testing.T) TopicPublisher

type TransformFunc

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