golang

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
  • func MetaFromContext(ctx context.Context) (Meta, error)

Variables

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

func ContextWithMeta(ctx context.Context, m Meta) context.Context

func HandleCrash

func HandleCrash()

func MetaExtract

func MetaExtract(ctx context.Context, h http.Header) context.Context

func MetaInject

func MetaInject(ctx context.Context, h http.Header) error

func Start

func Start(handler func(ctx context.Context, msg []byte) ([]byte, error))

func StartWithContext

func StartWithContext(ctx context.Context, handler func(ctx context.Context, msg []byte) ([]byte, error)) error

Types

type Meta

type Meta struct {
	Source string `json:"source" protobuf:"bytes,1,opt,name=source"`
	ID     string `json:"id" protobuf:"bytes,2,opt,name=id"`
	// UnixTime
	Time int64 `json:"time,omitempty" protobuf:"varint,3,opt,name=time"`
}

func MetaFromContext

func MetaFromContext(ctx context.Context) (Meta, error)