clientutil

Documentation

Index

• func FillBatch(ids map[int]int, msgs []*codec.Message, b []*codec.BatchElem)
• func GetMessage() *codec.Message
• func PutMessage(x *codec.Message)
• type IdReply
  • func NewIdReply() *IdReply
  • func (i *IdReply) Ask(ctx context.Context, id []byte) (json.RawMessage, error)
  • func (i *IdReply) NextId() *codec.ID
  • func (i *IdReply) Resolve(id []byte, msg json.RawMessage, err error)

Functions

func FillBatch

func FillBatch(ids map[int]int, msgs []*codec.Message, b []*codec.BatchElem)

func GetMessage

func GetMessage() *codec.Message

func PutMessage

func PutMessage(x *codec.Message)

Types

type IdReply

type IdReply struct {
	// contains filtered or unexported fields
}

func NewIdReply

func NewIdReply() *IdReply

func (*IdReply) Ask

func (i *IdReply) Ask(ctx context.Context, id []byte) (json.RawMessage, error)

func (*IdReply) NextId

func (i *IdReply) NextId() *codec.ID

func (*IdReply) Resolve

func (i *IdReply) Resolve(id []byte, msg json.RawMessage, err error)