coder

Documentation

Index

• Constants
• type Appender
  • func NewAppender(appenderName string, flagBitIndex int, ...) *Appender
  • func (ap *Appender) Decode(client *arpc.Client, msg *arpc.Message) *arpc.Message
  • func (ap *Appender) Encode(client *arpc.Client, msg *arpc.Message) *arpc.Message

Constants

const (
	// FlagBitOpenTracing .
	FlagBitOpenTracing = 0
	// FlagBitGZip .
	FlagBitGZip = 7
)

Types

type Appender

type Appender struct {
	AppenderName string
	FlagBitIndex int
	// contains filtered or unexported fields
}

Appender .

func NewAppender

func NewAppender(appenderName string,
	flagBitIndex int,
	valueToBytes func(interface{}) ([]byte, error),
	bytesToValue func([]byte) (interface{}, error)) *Appender

NewAppender returns the trace coding middleware.

func (*Appender) Decode

func (ap *Appender) Decode(client *arpc.Client, msg *arpc.Message) *arpc.Message

Decode implements arpc MessageCoder.

func (*Appender) Encode

func (ap *Appender) Encode(client *arpc.Client, msg *arpc.Message) *arpc.Message

Encode implements arpc MessageCoder.