sender

Documentation

Index

• Variables
• func NewCloudEvent(data interface{}, typ string) cloudevents.Event
• func NewEventID() string
• func RegisterEventSender(es EventSender)
• func ResetEventSenders()
• func SendEvent(ce cloudevents.Event, endpoint interface{}) error
• type EventSender
• type Sender
  • func New() Sender

Variables

var (
	// ErrEndpointTypeNotSupported is raised if configured endpoint isn't
	// supported by any of the event senders that are registered.
	ErrEndpointTypeNotSupported = errors.New("given endpoint isn't " +
		"supported by any registered event sender")
)

Functions

func NewCloudEvent

func NewCloudEvent(data interface{}, typ string) cloudevents.Event

NewCloudEvent creates a new cloud event

func NewEventID

func NewEventID() string

NewEventID creates new event ID

func RegisterEventSender

func RegisterEventSender(es EventSender)

RegisterEventSender will register a EventSender to be used.

func ResetEventSenders

func ResetEventSenders()

ResetEventSenders will reset configured event senders to defaults.

func SendEvent

func SendEvent(ce cloudevents.Event, endpoint interface{}) error

SendEvent will send cloud event to given url

Types

type EventSender

type EventSender interface {
	// Supports will check given endpoint definition and decide if it's valid for
	// this sender.
	Supports(endpoint interface{}) bool
	// SendEvent will send event to given endpoint.
	SendEvent(ce cloudevents.Event, endpoint interface{}) error
}

EventSender will be used to send events to configured endpoint.

type Sender

type Sender interface {
	SendContinually()
}

Sender will send messages continuously until process receives a SIGINT

func New

func New() Sender

New creates new Sender