sender

Documentation

Index

• Constants
• Variables
• func FromProto(container *cloudevents.CloudEvent) (*event.Event, error)
• func ToProto(e *event.Event) (*cloudevents.CloudEvent, error)
• type CloudEventSender
  • func NewHTTPSender(target string) CloudEventSender
  • func NewVanusSender(endpoint string, eventbus string) CloudEventSender

Constants

const (
	// ContentTypeProtobuf indicates that the data attribute is a protobuf message.
	ContentTypeProtobuf = "application/protobuf"
)

Variables

var ErrNotSupportBatch = errors.New("http sender: batch sending isn't supported")

Functions

func FromProto

func FromProto(container *cloudevents.CloudEvent) (*event.Event, error)

FromProto Convert from a protobuf variant into the generic, SDK event.

func ToProto

func ToProto(e *event.Event) (*cloudevents.CloudEvent, error)

ToProto convert an SDK event to a protobuf variant of the event that can be marshaled.

Types

type CloudEventSender

type CloudEventSender interface {
	SendEvent(ctx context.Context, events ...*ce.Event) error
}

func NewHTTPSender

func NewHTTPSender(target string) CloudEventSender

func NewVanusSender

func NewVanusSender(endpoint string, eventbus string) CloudEventSender