cloudevent

Documentation

Index

• func ToCloudEvent(event events.Event) (cev2.Event, error)
• type Sender
  • func NewSender(conf config.Config, ackC, nackC, undeliveredC chan<- events.Event) *Sender
  • func (s *Sender) Format() events.EventFormat
  • func (s *Sender) SendEvent(event events.Event)

Functions

func ToCloudEvent

func ToCloudEvent(event events.Event) (cev2.Event, error)

Types

type Sender

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

Sender sends cloud events.

func NewSender

func NewSender(conf config.Config, ackC, nackC, undeliveredC chan<- events.Event) *Sender

func (*Sender) Format

func (s *Sender) Format() events.EventFormat

func (*Sender) SendEvent

func (s *Sender) SendEvent(event events.Event)