encoding

Documentation

Index

• Variables
• func CtxIsSnappy(ctx context.Context) bool
• func CtxWithSnappy(ctx context.Context) context.Context
• func WrapHandler(h drpc.Handler) drpc.Handler
• type ConnUnblocked
  • func WrapConnEncoding(conn ConnUnblocked, useSnappy bool) ConnUnblocked
• type ProtoMessageGettable
• type ProtoMessageSettable

Variables

var ErrNotAProtoMessage = errors.New("encoding: not a proto message")

Functions

func CtxIsSnappy

func CtxIsSnappy(ctx context.Context) bool

func CtxWithSnappy

func CtxWithSnappy(ctx context.Context) context.Context

func WrapHandler

func WrapHandler(h drpc.Handler) drpc.Handler

Types

type ConnUnblocked

type ConnUnblocked interface {
	drpc.Conn
	Unblocked() <-chan struct{}
}

func WrapConnEncoding

func WrapConnEncoding(conn ConnUnblocked, useSnappy bool) ConnUnblocked

WrapConnEncoding wraps the drpc connection and replaces an encoding

type ProtoMessageGettable

type ProtoMessageGettable interface {
	ProtoMessage() (protobuf.Message, error)
}

type ProtoMessageSettable

type ProtoMessageSettable interface {
	ProtoMessageGettable
	SetProtoMessage(protobuf.Message) error
}