Versions in this module Expand all Collapse all v0 v0.22.1 Jul 14, 2023 Changes in this version + var ErrSpecifyThriftFile = errors.New("specify a Thrift file using --thrift") + type Encoding string + const JSON + const Protobuf + const Raw + const Thrift + const UnspecifiedEncoding + func (e *Encoding) UnmarshalFlag(s string) error + func (e *Encoding) UnmarshalText(text []byte) error + func (e Encoding) GetHealth(serviceName string) (Serializer, error) + func (e Encoding) String() string + type MethodType int + const BidirectionalStream + const ClientStream + const ServerStream + const Unary + type ProtoErrorDeserializer interface + ErrorDetails func(err error) ([]interface{}, error) + type Serializer interface + CheckSuccess func(body *transport.Response) error + Encoding func() Encoding + MethodType func() MethodType + Request func(body []byte) (*transport.Request, error) + Response func(body *transport.Response) (response interface{}, err error) + func NewJSON(methodName string) Serializer + func NewProtobuf(fullMethodName string, source protobuf.DescriptorProvider) (Serializer, error) + func NewRaw(methodName string) Serializer + func NewThrift(p ThriftParams) (Serializer, error) + type StreamRequestReader interface + NextBody func() ([]byte, error) + type StreamSerializer interface + StreamRequest func(body io.Reader) (*transport.StreamRequest, StreamRequestReader, error) + type ThriftParams struct + Envelope bool + File string + Method string + Multiplexed bool