codec

Documentation

Overview

Package codec is an interface for encoding messages

Index

• Variables
• func NewContext(ctx context.Context, c Codec) context.Context
• type Codec
  • func FromContext(ctx context.Context) (Codec, bool)
  • func NewCodec(opts ...Option) Codec
• type CodecV2
• type Frame
  • func NewFrame(data []byte) *Frame
  • func (m *Frame) Marshal() ([]byte, error)
  • func (m *Frame) MarshalJSON() ([]byte, error)
  • func (m *Frame) ProtoMessage()
  • func (m *Frame) Reset()
  • func (m *Frame) String() string
  • func (m *Frame) Unmarshal(data []byte) error
  • func (m *Frame) UnmarshalJSON(data []byte) error
• type Option
  • func Flatten(b bool) Option
  • func Logger(l logger.Logger) Option
  • func Meter(m meter.Meter) Option
  • func SetOption(k, v interface{}) Option
  • func TagName(n string) Option
  • func Tracer(t tracer.Tracer) Option
• type Options
  • func NewOptions(opts ...Option) Options
• type RawMessage
  • func (m *RawMessage) MarshalJSON() ([]byte, error)
  • func (m *RawMessage) UnmarshalJSON(data []byte) error

Variables

var (
	// ErrInvalidMessage returned when invalid messge passed to codec
	ErrInvalidMessage = errors.New("invalid message")
	// ErrUnknownContentType returned when content-type is unknown
	ErrUnknownContentType = errors.New("unknown content-type")
)

var (
	// DefaultCodec is the global default codec
	DefaultCodec = NewCodec()
	// DefaultTagName specifies struct tag name to control codec Marshal/Unmarshal
	DefaultTagName = "codec"
)

Functions

func NewContext

func NewContext(ctx context.Context, c Codec) context.Context

NewContext put codec in context

Types

type Codec

type Codec interface {
	Marshal(v interface{}, opts ...Option) ([]byte, error)
	Unmarshal(b []byte, v interface{}, opts ...Option) error
	String() string
}

Codec encodes/decodes various types of messages.

func FromContext

func FromContext(ctx context.Context) (Codec, bool)

FromContext returns codec from context

func NewCodec

func NewCodec(opts ...Option) Codec

NewCodec returns new noop codec

type CodecV2

type CodecV2 interface {
	Marshal(buf []byte, v interface{}, opts ...Option) ([]byte, error)
	Unmarshal(buf []byte, v interface{}, opts ...Option) error
	String() string
}

type Frame

type Frame struct {
	Data []byte
}

Frame gives us the ability to define raw data to send over the pipes

func NewFrame

func NewFrame(data []byte) *Frame

NewFrame returns new frame with data

func (*Frame) Marshal

func (m *Frame) Marshal() ([]byte, error)

Marshal returns frame data

func (*Frame) MarshalJSON

func (m *Frame) MarshalJSON() ([]byte, error)

MarshalJSON returns frame data

func (*Frame) ProtoMessage

func (m *Frame) ProtoMessage()

ProtoMessage noop func

func (*Frame) Reset

func (m *Frame) Reset()

Reset resets frame

func (*Frame) String

func (m *Frame) String() string

String returns frame as string

func (*Frame) Unmarshal

func (m *Frame) Unmarshal(data []byte) error

Unmarshal set frame data

func (*Frame) UnmarshalJSON

func (m *Frame) UnmarshalJSON(data []byte) error

UnmarshalJSON set frame data

type Option

type Option func(*Options)

Option func

func Flatten

func Flatten(b bool) Option

Flatten enables checking for flatten tag name

func Logger

func Logger(l logger.Logger) Option

Logger sets the logger

func Meter

func Meter(m meter.Meter) Option

Meter sets the meter

func SetOption

func SetOption(k, v interface{}) Option

SetOption returns a function to setup a context with given value

func TagName

func TagName(n string) Option

TagName sets the codec tag name in struct

func Tracer

func Tracer(t tracer.Tracer) Option

Tracer to be used for tracing

type Options

type Options struct {
	// Meter used for metrics
	Meter meter.Meter
	// Logger used for logging
	Logger logger.Logger
	// Tracer used for tracing
	Tracer tracer.Tracer
	// Context stores additional codec options
	Context context.Context
	// TagName specifies tag name in struct to control codec
	TagName string
	// Flatten specifies that struct must be analyzed for flatten tag
	Flatten bool
}

Options contains codec options

func NewOptions

func NewOptions(opts ...Option) Options

NewOptions returns new options

type RawMessage

type RawMessage []byte

RawMessage is a raw encoded JSON value. It implements Marshaler and Unmarshaler and can be used to delay decoding or precompute a encoding.

func (*RawMessage) MarshalJSON

func (m *RawMessage) MarshalJSON() ([]byte, error)

MarshalJSON returns m as the JSON encoding of m.

func (*RawMessage) UnmarshalJSON

func (m *RawMessage) UnmarshalJSON(data []byte) error

UnmarshalJSON sets *m to a copy of data.