extensions

Documentation

Overview

Package extensions provides implementations of common event extensions.

Index

• Constants
• func AddDataRefExtension(e *event.Event, dataRef string) error
• type DataRefExtension
  • func GetDataRefExtension(e event.Event) (DataRefExtension, bool)
• type DistributedTracingExtension
  • func GetDistributedTracingExtension(event event.Event) (DistributedTracingExtension, bool)
  • func (d DistributedTracingExtension) AddTracingAttributes(e event.EventWriter)
  • func (d *DistributedTracingExtension) ReadTransformer() binding.TransformerFunc
  • func (d *DistributedTracingExtension) WriteTransformer() binding.TransformerFunc

Constants

const (
	TraceParentExtension = "traceparent"
	TraceStateExtension  = "tracestate"
)

const DataRefExtensionKey = "dataref"

Functions

func AddDataRefExtension

func AddDataRefExtension(e *event.Event, dataRef string) error

AddDataRefExtension adds the dataref attribute to the cloudevents context

Types

type DataRefExtension

type DataRefExtension struct {
	DataRef string `json:"dataref"`
}

DataRefExtension represents the CloudEvents Dataref (claim check pattern) extension for cloudevents contexts, See https://github.com/cloudevents/spec/blob/main/cloudevents/extensions/dataref.md for more info

func GetDataRefExtension

func GetDataRefExtension(e event.Event) (DataRefExtension, bool)

GetDataRefExtension returns any dataref attribute present in the cloudevent event/context and a bool to indicate if it was found. If not found, the DataRefExtension.DataRef value will be ""

type DistributedTracingExtension

type DistributedTracingExtension struct {
	TraceParent string `json:"traceparent"`
	TraceState  string `json:"tracestate"`
}

DistributedTracingExtension represents the extension for cloudevents context

func GetDistributedTracingExtension

func GetDistributedTracingExtension(event event.Event) (DistributedTracingExtension, bool)

func (DistributedTracingExtension) AddTracingAttributes

func (d DistributedTracingExtension) AddTracingAttributes(e event.EventWriter)

AddTracingAttributes adds the tracing attributes traceparent and tracestate to the cloudevents context

func (*DistributedTracingExtension) ReadTransformer

func (d *DistributedTracingExtension) ReadTransformer() binding.TransformerFunc

func (*DistributedTracingExtension) WriteTransformer

func (d *DistributedTracingExtension) WriteTransformer() binding.TransformerFunc