v2

package module
v2.0.0-prevew7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 23, 2020 License: Apache-2.0 Imports: 8 Imported by: 1,298

Documentation

Index

Constants

View Source
const (
	ApplicationXML                  = event.ApplicationXML
	ApplicationJSON                 = event.ApplicationJSON
	TextPlain                       = event.TextPlain
	ApplicationCloudEventsJSON      = event.ApplicationCloudEventsJSON
	ApplicationCloudEventsBatchJSON = event.ApplicationCloudEventsBatchJSON
	Base64                          = event.Base64

	VersionV1  = event.CloudEventsVersionV1
	VersionV03 = event.CloudEventsVersionV03

	EncodingBinary     = binding.EncodingBinary
	EncodingStructured = binding.EncodingStructured
)

Variables

View Source
var (
	StringOfApplicationJSON                 = event.StringOfApplicationJSON
	StringOfApplicationXML                  = event.StringOfApplicationXML
	StringOfTextPlain                       = event.StringOfTextPlain
	StringOfApplicationCloudEventsJSON      = event.StringOfApplicationCloudEventsJSON
	StringOfApplicationCloudEventsBatchJSON = event.StringOfApplicationCloudEventsBatchJSON
	StringOfBase64                          = event.StringOfBase64

	NewClient             = client.New
	NewClientObserved     = client.NewObserved
	NewDefaultClient      = client.NewDefault
	NewHTTPReceiveHandler = client.NewHTTPReceiveHandler

	WithEventDefaulter   = client.WithEventDefaulter
	WithUUIDs            = client.WithUUIDs
	WithTimeNow          = client.WithTimeNow
	WithTracePropagation = client.WithTracePropagation()

	NewEvent  = event.New
	NewResult = protocol.NewResult

	NewHTTPResult = http.NewResult

	ToMessage = binding.ToMessage

	WriteHTTPRequest = http.WriteRequest

	EnableTracing = observability.EnableTracing

	ContextWithTarget      = context.WithTarget
	TargetFromContext      = context.TargetFrom
	WithEncodingBinary     = binding.WithForceBinary
	WithEncodingStructured = binding.WithForceStructured

	ParseTimestamp = types.ParseTimestamp
	ParseURIRef    = types.ParseURIRef
	ParseURI       = types.ParseURI

	NewHTTP = http.New

	WithTarget          = http.WithTarget
	WithHeader          = http.WithHeader
	WithShutdownTimeout = http.WithShutdownTimeout
	//WithEncoding           = http.WithEncoding
	//WithStructuredEncoding = http.WithStructuredEncoding // TODO: expose new way
	WithPort         = http.WithPort
	WithPath         = http.WithPath
	WithMiddleware   = http.WithMiddleware
	WithListener     = http.WithListener
	WithRoundTripper = http.WithRoundTripper
)

Functions

This section is empty.

Types

type Client

type Client = client.Client

type ClientOption

type ClientOption client.Option

type Encoding

type Encoding = binding.Encoding

type Event

type Event = event.Event

type EventContext

type EventContext = event.EventContext

type EventContextV03

type EventContextV03 = event.EventContextV03

type EventContextV1

type EventContextV1 = event.EventContextV1

type HTTPOption

type HTTPOption http.Option

type HTTPProtocol

type HTTPProtocol = http.Protocol

type Message

type Message = binding.Message

type Timestamp

type Timestamp = types.Timestamp

type URIRef

type URIRef = types.URIRef

Directories

Path Synopsis
test
Package test contains test data and generic tests for testing bindings.
Package test contains test data and generic tests for testing bindings.
Package client holds the recommended entry points for interacting with the CloudEvents Golang SDK.
Package client holds the recommended entry points for interacting with the CloudEvents Golang SDK.
cmd
Package context holds the last resort overrides and fyi objects that can be passed to clients and transports added to context.Context objects.
Package context holds the last resort overrides and fyi objects that can be passed to clients and transports added to context.Context objects.
Package cloudevents provides primitives to work with CloudEvents specification: https://github.com/cloudevents/spec.
Package cloudevents provides primitives to work with CloudEvents specification: https://github.com/cloudevents/spec.
datacodec
Package datacodec holds the data codec registry and adds known encoders and decoders supporting media types such as `application/json` and `application/xml`.
Package datacodec holds the data codec registry and adds known encoders and decoders supporting media types such as `application/json` and `application/xml`.
datacodec/json
Package json holds the encoder/decoder implementation for `application/json`.
Package json holds the encoder/decoder implementation for `application/json`.
datacodec/text
Text codec converts []byte or string to string and vice-versa.
Text codec converts []byte or string to string and vice-versa.
datacodec/xml
Package xml holds the encoder/decoder implementation for `application/xml`.
Package xml holds the encoder/decoder implementation for `application/xml`.
Package observability holds metrics and tracing recording implementations.
Package observability holds metrics and tracing recording implementations.
amqp
Module amqp implements an AMQP binding using pack.ag/amqp module
Module amqp implements an AMQP binding using pack.ag/amqp module
gochan
Package channel implements the CloudEvent transport implementation using go chan.
Package channel implements the CloudEvent transport implementation using go chan.
nats
Package nats implements the CloudEvent transport implementation using NATS.
Package nats implements the CloudEvent transport implementation using NATS.
stan
Package stan implements the CloudEvent transport implementation using NATS Streaming.
Package stan implements the CloudEvent transport implementation using NATS Streaming.
test
Package test provides re-usable functions for binding tests.
Package test provides re-usable functions for binding tests.
samples module
Package test holds integration and benchmark tests.
Package test holds integration and benchmark tests.
tools module
Package types implements the CloudEvents type system.
Package types implements the CloudEvents type system.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL