broker

Jan 25, 2023

Changes in this version

+ type ErrExtensionInfo struct

+ ErrDestination *url.URL

+ ErrResponseBody []byte

Mar 3, 2020

Changes in this version

+ const LabelUniqueName

+ var UniqueTagKey = tag.MustNewKey(LabelUniqueName)

Jan 21, 2020

Changes in this version

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

Dec 3, 2019

Changes in this version

+ const TTLAttribute

+ func DeleteTTL(ctx cloudevents.EventContext) error

Nov 13, 2019

Changes in this version

+ const LabelContainerName

+ const LabelPodName

+ var ContainerTagKey = tag.MustNewKey(LabelContainerName)

+ var PodTagKey = tag.MustNewKey(LabelPodName)

Sep 17, 2019

Changes in this version

+ const EventArrivalTime

+ const TraceParent

+ const V03TTLAttribute

+ func ExtractPassThroughHeaders(tctx cloudevents.HTTPTransportContext) http.Header

Aug 6, 2019

Changes in this version

+ const TimeInFlightMetadataName

+ var MeasureDeliveryTime = stats.Int64("knative.dev/eventing/trigger/measures/delivery_time", ...)

Jun 25, 2019

Changes in this version

+ var MeasureTriggerDispatchTime = stats.Int64("knative.dev/eventing/trigger/measures/dispatch_time", ...)

+ var MeasureTriggerEventsTotal = stats.Int64("knative.dev/eventing/trigger/measures/events_total", ...)

+ var MeasureTriggerFilterTime = stats.Int64("knative.dev/eventing/trigger/measures/filter_time", ...)

+ var TagBroker = mustNewTagKey("broker")

+ var TagFilterResult = mustNewTagKey("filter_result")

+ var TagResult = mustNewTagKey("result")

+ var TagTrigger = mustNewTagKey("trigger")

+ func Buckets125(low, high float64) []float64

Jun 26, 2019

Changes in this version

+ func GetTTL(ctx cloudevents.EventContext) (interface{}, string)

Apr 2, 2019

Changes in this version

+ const V02TTLAttribute

+ func SendingContext(ctx context.Context, tctx cehttp.TransportContext, targetURI *url.URL) context.Context

+ func SetTTL(ctx cloudevents.EventContext, ttl interface{}) cloudevents.EventContext

+ type Receiver struct

+ func New(logger *zap.Logger, client client.Client) (*Receiver, error)

+ func (r *Receiver) Start(stopCh <-chan struct{}) error