eventing

package
v1.499.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 17, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewEventFromJSON

func NewEventFromJSON(eventType, source, jsonData, additionalJSON string) ([]byte, error)

NewEventFromJSON creates a CloudEvent v1.0 from JSON string data, optionally merging additional JSON data into the event payload. Returns the serialized CloudEvent bytes.

func Process

func Process(tokenProvider gcp.OIDCTokenProvider, generalConfig *config.GeneralConfigOptions, ctx EventContext) error

Process publishes a plain CloudEvent TaskRunFinished event via GCP Pub/Sub, using the original event format with taskName, stageName, and outcome in the data payload.

func ProcessCDE added in v1.499.0

func ProcessCDE(tokenProvider gcp.OIDCTokenProvider, generalConfig *config.GeneralConfigOptions, ctx EventContext) error

ProcessCDE publishes a CDEvents TaskRunFinished event via GCP Pub/Sub.

Types

type EventContext

type EventContext struct {
	StepName  string
	StageName string
	ErrorCode string
}

EventContext carries step-level data from the generated template into the eventing package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL