events

Documentation

Index

• func FilterCloudEventsWithErrors(publishEventResults []PublishEventResult, cloudEvents []*cloudevents.Event) []*cloudevents.Event
• type CloudEventError
  • func CreateCloudEventErrorList(publishEventErrorList []PublishEventResult, cloudEvents []*cloudevents.Event) []CloudEventError
• type PublishDataInput
  • func CreatePublishEventList(eventSource string, cloudEvents []*cloudevents.Event) []PublishDataInput
  • func MapCloudEventsToPublishDataInputs(cloudEvents []*cloudevents.Event) []PublishDataInput
  • func NewPublishDataInput(event *cloudevents.Event) (*PublishDataInput, error)
• type PublishEventResult

Functions

func FilterCloudEventsWithErrors

func FilterCloudEventsWithErrors(publishEventResults []PublishEventResult, cloudEvents []*cloudevents.Event) []*cloudevents.Event

Types

type CloudEventError

type CloudEventError struct {
	Event *cloudevents.Event
	Error string
}

func CreateCloudEventErrorList

func CreateCloudEventErrorList(publishEventErrorList []PublishEventResult, cloudEvents []*cloudevents.Event) []CloudEventError

type PublishDataInput

type PublishDataInput struct {
	Type       string `json:"type"`
	Compressed bool   `json:"compressed"`
	Payload    string `json:"payload"`
}

func CreatePublishEventList

func CreatePublishEventList(eventSource string, cloudEvents []*cloudevents.Event) []PublishDataInput

func MapCloudEventsToPublishDataInputs

func MapCloudEventsToPublishDataInputs(cloudEvents []*cloudevents.Event) []PublishDataInput

func NewPublishDataInput

func NewPublishDataInput(event *cloudevents.Event) (*PublishDataInput, error)

type PublishEventResult

type PublishEventResult struct {
	Success bool   `json:"success"`
	Error   string `json:"error"`
}