server

Documentation

Index

• func Connect(backoff *wait.Backoff, conn func() error) error
• func HandleEventsFromEventSource(name string, eventStream gateways.Eventing_StartEventSourceServer, ...)
• func Recover(eventSource string)
• func StartGateway(es gateways.EventingServer)
• type Channels
  • func NewChannels() *Channels

Functions

func Connect

func Connect(backoff *wait.Backoff, conn func() error) error

General connection helper

func HandleEventsFromEventSource

func HandleEventsFromEventSource(name string, eventStream gateways.Eventing_StartEventSourceServer, channels *Channels, logger *logrus.Logger)

HandleEventsFromEventSource handles events from the event source.

func Recover

func Recover(eventSource string)

Recover recovers from panics in event sources

func StartGateway

func StartGateway(es gateways.EventingServer)

StartGateway start a gateway

Types

type Channels

type Channels struct {
	Data chan []byte
	Stop chan struct{}
	Done chan struct{}
}

Channels holds the necessary channels for gateway server to process.

func NewChannels

func NewChannels() *Channels

NewChannels returns an instance of channels.