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 ClientOption ¶
type EventContext ¶
type EventContext = event.EventContext
type EventContextV03 ¶
type EventContextV03 = event.EventContextV03
type EventContextV1 ¶
type EventContextV1 = event.EventContextV1
type HTTPOption ¶
type HTTPProtocol ¶
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. |
Click to show internal directories.
Click to hide internal directories.