event

Documentation

Overview

Package event defines version 1 implementation of event

Index

• func CloudNativeData() event.Data
• func CloudNativeDataValues() event.DataValue
• func CloudNativeEvent() event.Event
• func CreateCloudEvents(e event.Event, ps pubsub.PubSub) (*cloudevents.Event, error)
• func GetCloudNativeEvents(ce cloudevents.Event) (e event.Event, err error)
• func PublishCloudEventToLog(e cloudevents.Event)
• func SendCloudEventsToDataChannel(inChan chan<- *channel.DataChan, status channel.Status, address string, ...)
• func SendEventToLog(e event.Event)
• func SendNewEventToDataChannel(inChan chan<- *channel.DataChan, address string, e *cloudevents.Event)
• func SendStatusToDataChannel(inChan chan<- *channel.DataChan, status channel.Status, address string)

Functions

func CloudNativeData

func CloudNativeData() event.Data

CloudNativeData gets Cloud Native Event object

func CloudNativeDataValues

func CloudNativeDataValues() event.DataValue

CloudNativeDataValues gets CNE data values object

func CloudNativeEvent

func CloudNativeEvent() event.Event

CloudNativeEvent gets Cloud Native Event object

func CreateCloudEvents

func CreateCloudEvents(e event.Event, ps pubsub.PubSub) (*cloudevents.Event, error)

CreateCloudEvents create new cloud event from cloud native events and pubsub

func GetCloudNativeEvents

func GetCloudNativeEvents(ce cloudevents.Event) (e event.Event, err error)

GetCloudNativeEvents get event data from cloud events object if its valid else return error

func PublishCloudEventToLog

func PublishCloudEventToLog(e cloudevents.Event)

PublishCloudEventToLog ... publish event data to a log

func SendCloudEventsToDataChannel

func SendCloudEventsToDataChannel(inChan chan<- *channel.DataChan, status channel.Status, address string, e cloudevents.Event)

SendCloudEventsToDataChannel sends data event in cloudevents format to data channel

func SendEventToLog

func SendEventToLog(e event.Event)

SendEventToLog ...

func SendNewEventToDataChannel

func SendNewEventToDataChannel(inChan chan<- *channel.DataChan, address string, e *cloudevents.Event)

SendNewEventToDataChannel send created publisher information for QDR to process

func SendStatusToDataChannel

func SendStatusToDataChannel(inChan chan<- *channel.DataChan, status channel.Status, address string)

SendStatusToDataChannel send created publisher information for QDR to process