events

package

v0.0.3 Latest Latest Go to latest Published: Jul 21, 2023 License: GPL-3.0 Imports: 6 Imported by: 1

Details

This section is empty.

This section is empty.

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

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

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

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

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

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

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

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