transformer

Documentation

Index

• Variables
• func AddAttribute(attributeKind spec.Kind, value interface{}) binding.TransformerFactory
• func AddExtension(name string, value interface{}) binding.TransformerFactory
• func DeleteAttribute(attributeKind spec.Kind) binding.TransformerFactory
• func DeleteExtension(name string) binding.TransformerFactory
• func SetAttribute(attribute spec.Kind, defaultValue interface{}, ...) []binding.TransformerFactory
• func SetExtension(name string, defaultValue interface{}, ...) []binding.TransformerFactory
• func UpdateAttribute(attributeKind spec.Kind, updater func(interface{}) (interface{}, error)) binding.TransformerFactory
• func UpdateExtension(name string, updater func(interface{}) (interface{}, error)) binding.TransformerFactory
• func Version(version spec.Version) binding.TransformerFactory

Variables

var (
	// Sets the cloudevents id attribute to a UUID.New()
	SetUUID binding.TransformerFactory = setUUID{}
	// Add the cloudevents time attribute, if missing, to time.Now()
	AddTimeNow binding.TransformerFactory = addTimeNow{}
)

Functions

func AddAttribute

func AddAttribute(attributeKind spec.Kind, value interface{}) binding.TransformerFactory

Add cloudevents attribute (if missing) during the encoding process

func AddExtension

func AddExtension(name string, value interface{}) binding.TransformerFactory

Add cloudevents extension (if missing) during the encoding process

func DeleteAttribute

func DeleteAttribute(attributeKind spec.Kind) binding.TransformerFactory

Delete cloudevents attribute during the encoding process

func DeleteExtension

func DeleteExtension(name string) binding.TransformerFactory

Delete cloudevents extension during the encoding process

func SetAttribute

func SetAttribute(attribute spec.Kind, defaultValue interface{}, updater func(interface{}) (interface{}, error)) []binding.TransformerFactory

Sets a cloudevents attribute (if missing) to defaultValue or update it with updater function

func SetExtension

func SetExtension(name string, defaultValue interface{}, updater func(interface{}) (interface{}, error)) []binding.TransformerFactory

Sets a cloudevents extension (if missing) to defaultValue or update it with updater function

func UpdateAttribute

func UpdateAttribute(attributeKind spec.Kind, updater func(interface{}) (interface{}, error)) binding.TransformerFactory

Update cloudevents attribute (if present) using the provided function

func UpdateExtension

func UpdateExtension(name string, updater func(interface{}) (interface{}, error)) binding.TransformerFactory

Update cloudevents extension (if present) using the provided function

func Version

func Version(version spec.Version) binding.TransformerFactory

Converts the event context version to the specified one.