internal

Documentation

Index

• Variables
• type RPC
  • func (v *RPC) Equals(rhs *RPC) bool
  • func (v *RPC) FromWire(w wire.Value) error
  • func (v *RPC) GetRoutingDelegate() (o string)
  • func (v *RPC) GetRoutingKey() (o string)
  • func (v *RPC) GetShardKey() (o string)
  • func (v *RPC) String() string
  • func (v *RPC) ToWire() (wire.Value, error)

Variables

var ThriftModule = &thriftreflect.ThriftModule{Name: "internal", Package: "go.uber.org/yarpc/serialize/internal", FilePath: "internal.thrift", SHA1: "c60c5759efeaa1545aebd396d371509bc561b153", Raw: rawIDL}

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"`
	ShardKey        *string           `json:"shardKey,omitempty"`
	RoutingKey      *string           `json:"routingKey,omitempty"`
	RoutingDelegate *string           `json:"routingDelegate,omitempty"`
	Body            []byte            `json:"body"`
}

func (*RPC) Equals

func (v *RPC) Equals(rhs *RPC) bool

func (*RPC) FromWire

func (v *RPC) FromWire(w wire.Value) error

func (*RPC) GetRoutingDelegate

func (v *RPC) GetRoutingDelegate() (o string)

func (*RPC) GetRoutingKey

func (v *RPC) GetRoutingKey() (o string)

func (*RPC) GetShardKey

func (v *RPC) GetShardKey() (o string)

func (*RPC) String

func (v *RPC) String() string

func (*RPC) ToWire

func (v *RPC) ToWire() (wire.Value, error)