Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
var ThriftModule = &thriftreflect.ThriftModule{
Name: "internal",
Package: "go.uber.org/yarpc/serialize/internal",
FilePath: "internal.thrift",
SHA1: "c60c5759efeaa1545aebd396d371509bc561b153",
Raw: rawIDL,
}
ThriftModule represents the IDL file used to generate this package.
Functions ¶
This section is empty.
Types ¶
type RPC ¶
type RPC struct {
SpanContext []byte `json:"spanContext,required"`
CallerName string `json:"callerName,required"`
ServiceName string `json:"serviceName,required"`
Encoding string `json:"encoding,required"`
Procedure string `json:"procedure,required"`
Headers map[string]string `json:"headers,omitempty"`
ShardKey *string `json:"shardKey,omitempty"`
RoutingKey *string `json:"routingKey,omitempty"`
RoutingDelegate *string `json:"routingDelegate,omitempty"`
Body []byte `json:"body,omitempty"`
}
func (*RPC) Equals ¶ added in v1.8.0
Equals returns true if all the fields of this RPC match the provided RPC.
This function performs a deep comparison.
func (*RPC) FromWire ¶
FromWire deserializes a RPC struct from its Thrift-level representation. The Thrift-level representation may be obtained from a ThriftRW protocol implementation.
An error is returned if we were unable to build a RPC struct from the provided intermediate representation.
x, err := binaryProtocol.Decode(reader, wire.TStruct)
if err != nil {
return nil, err
}
var v RPC
if err := v.FromWire(x); err != nil {
return nil, err
}
return &v, nil
func (*RPC) GetRoutingDelegate ¶ added in v1.14.0
GetRoutingDelegate returns the value of RoutingDelegate if it is set or its zero value if it is unset.
func (*RPC) GetRoutingKey ¶ added in v1.14.0
GetRoutingKey returns the value of RoutingKey if it is set or its zero value if it is unset.
func (*RPC) GetShardKey ¶ added in v1.14.0
GetShardKey returns the value of ShardKey if it is set or its zero value if it is unset.
func (*RPC) ToWire ¶
ToWire translates a RPC struct into a Thrift-level intermediate representation. This intermediate representation may be serialized into bytes using a ThriftRW protocol implementation.
An error is returned if the struct or any of its fields failed to validate.
x, err := v.ToWire()
if err != nil {
return err
}
if err := binaryProtocol.Encode(x, writer); err != nil {
return err
}
Source Files