broker

package
v0.35.1 Latest Latest
Warning

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

Go to latest
Published: Nov 10, 2022 License: Apache-2.0 Imports: 7 Imported by: 24

Documentation

Index

Constants

View Source
const (
	// EventArrivalTime is used to access the metadata stored on a
	// CloudEvent to measure the time difference between when an event is
	// received on a broker and before it is dispatched to the trigger function.
	// The format is an RFC3339 time in string format. For example: 2019-08-26T23:38:17.834384404Z.
	EventArrivalTime = "knativearrivaltime"

	// LabelUniqueName is the label for the unique name per stats_reporter instance.
	LabelUniqueName = "unique_name"

	// LabelContainerName is the label for the immutable name of the container.
	LabelContainerName = metrics.LabelContainerName
)
View Source
const (
	// TTLAttribute is the name of the CloudEvents extension attribute used to store the
	// Broker's TTL (number of times a single event can reply through a Broker continuously). All
	// interactions with the attribute should be done through the GetTTL and SetTTL functions.
	TTLAttribute = "knativebrokerttl"
)

Variables

View Source
var (
	ContainerTagKey = tag.MustNewKey(LabelContainerName)
	UniqueTagKey    = tag.MustNewKey(LabelUniqueName)
)

Functions

func DeleteTTL added in v0.10.2

func DeleteTTL(ctx cloudevents.EventContext) error

DeleteTTL removes the TTL CE extension attribute

func GetTTL added in v0.6.1

func GetTTL(ctx cloudevents.EventContext) (int32, error)

GetTTL finds the TTL in the EventContext using a case insensitive comparison for the key. The second return param, is the case preserved key that matched. Depending on the encoding/transport, the extension case could be changed.

func SetTTL

func SetTTL(ctx cloudevents.EventContext, ttl int32) error

SetTTL sets the TTL into the EventContext. ttl should be a positive integer.

func TTLDefaulter added in v0.12.0

func TTLDefaulter(logger *zap.Logger, defaultTTL int32) client.EventDefaulter

TTLDefaulter returns a cloudevents event defaulter that will manage the TTL for events with the following rules:

If TTL is not found, it will set it to the default passed in.
If TTL is <= 0, it will remain 0.
If TTL is > 1, it will be reduced by one.

Types

This section is empty.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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