cncf

Documentation

Index

• type CloudEvents
  • func New(mux *msgs.Mux, c client.Client) (*CloudEvents, error)
  • func NewCloudEvents(mux *msgs.Mux, port int) (*CloudEvents, error)

Types

type CloudEvents

type CloudEvents struct {
	Targets map[string]string
	// contains filtered or unexported fields
}

Adapter to CloudEvents. Will receive CloudEvents via HTTP (or other sources), and forward them using Webpush and other gateway protocols.

Will forward outgoing messages to CloudEvents.

Each CloudEvents object is associated with a transport - HTTP has one instance, because it binds to a port.

One instance can send to multiple endpoints.

func New

func New(mux *msgs.Mux, c client.Client) (*CloudEvents, error)

Adapter between the internal mux and CloudEvents.

Will receive plain text cloud events - ideally from a localhost or local client. Also receives remote events - ideally encrypted with webpush wrapping.

Messages are routed using the mux to local or remote destinations.

For local->remote, the message will be encrypted For remote->local, message will be decrypted For forwarding, it is passed trough.

func NewCloudEvents

func NewCloudEvents(mux *msgs.Mux, port int) (*CloudEvents, error)