datacodec

Documentation

Overview

Package datacodec holds the data codec registry and adds known encoders and decoders supporting media types such as `application/json` and `application/xml`.

Index

• Variables
• func AddDecoder(contentType string, fn Decoder)
• func AddEncoder(contentType string, fn Encoder)
• func Decode(ctx context.Context, contentType string, in, out interface{}) error
• func DecodeObserved(ctx context.Context, contentType string, in, out interface{}) error
• func Encode(ctx context.Context, contentType string, in interface{}) ([]byte, error)
• func EncodeObserved(ctx context.Context, contentType string, in interface{}) ([]byte, error)
• func SetObservedCodecs()
• type Decoder
• type Encoder

Variables

var (
	// LatencyMs measures the latency in milliseconds for the CloudEvents generic
	// codec data methods.
	LatencyMs = stats.Float64("cloudevents.io/sdk-go/datacodec/latency", "The latency in milliseconds for the CloudEvents generic data codec methods.", "ms")
)

var (
	// LatencyView is an OpenCensus view that shows data codec method latency.
	LatencyView = &view.View{
		Name:        "datacodec/latency",
		Measure:     LatencyMs,
		Description: "The distribution of latency inside of the generic data codec for CloudEvents.",
		Aggregation: view.Distribution(0, .01, .1, 1, 10, 100, 1000, 10000),
		TagKeys:     observability.LatencyTags(),
	}
)

Functions

func AddDecoder

func AddDecoder(contentType string, fn Decoder)

AddDecoder registers a decoder for a given content type. The codecs will use these to decode the data payload from a cloudevent.Event object.

func AddEncoder

func AddEncoder(contentType string, fn Encoder)

AddEncoder registers an encoder for a given content type. The codecs will use these to encode the data payload for a cloudevent.Event object.

func Decode

func Decode(ctx context.Context, contentType string, in, out interface{}) error

Decode looks up and invokes the decoder registered for the given content type. An error is returned if no decoder is registered for the given content type.

func DecodeObserved

func DecodeObserved(ctx context.Context, contentType string, in, out interface{}) error

DecodeObserved calls Decode and records the result.

func Encode

func Encode(ctx context.Context, contentType string, in interface{}) ([]byte, error)

Encode looks up and invokes the encoder registered for the given content type. An error is returned if no encoder is registered for the given content type.

func EncodeObserved

func EncodeObserved(ctx context.Context, contentType string, in interface{}) ([]byte, error)

EncodeObserved calls Encode and records the result.

func SetObservedCodecs

func SetObservedCodecs()

Types

type Decoder

type Decoder func(ctx context.Context, in, out interface{}) error

Decoder is the expected function signature for decoding `in` to `out`. What `in` is could be decoder dependent. For example, `in` could be bytes, or a base64 string.

type Encoder

type Encoder func(ctx context.Context, in interface{}) ([]byte, error)

Encoder is the expected function signature for encoding `in` to bytes. Returns an error if the encoder has an issue encoding `in`.