Documentation ¶
Overview ¶
Code generated by gen.sh. DO NOT EDIT.
Index ¶
- Variables
- func ContextWithMeta(ctx context.Context, m Meta) context.Context
- func HandleCrash()
- func MetaExtract(ctx context.Context, h http.Header) context.Context
- func MetaInject(ctx context.Context, h http.Header) error
- func Start(handler func(ctx context.Context, msg []byte) ([]byte, error))
- func StartWithContext(ctx context.Context, ...) error
- type Meta
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // MetaID is a unique ID for the message. // Required. // https://github.com/cloudevents/spec/blob/master/spec.md#id MetaID = "dataflow-id" // MetaSource is the source of the messages as a Unique Resource Identifier (URI). // Required. // https://github.com/cloudevents/spec/blob/master/spec.md#source-1 MetaSource = "dataflow-source" // MetaTime is the time of the message. As meta-data, this might be different to the event-time (which might be within the message). // For example, it might be the last-modified time of a file, but the file itself was created at another time. // Optional. // https://github.com/cloudevents/spec/blob/master/spec.md#time MetaTime = "dataflow-time" )
Functions ¶
func ContextWithMeta ¶ added in v0.0.105
func HandleCrash ¶ added in v0.0.105
func HandleCrash()
func MetaExtract ¶ added in v0.0.105
Types ¶
Click to show internal directories.
Click to hide internal directories.