rpc

Documentation

Index

• Variables
• type Ack
  • func (*Ack) Descriptor() ([]byte, []int)
  • func (x *Ack) GetOk() bool
  • func (*Ack) ProtoMessage()
  • func (x *Ack) ProtoReflect() protoreflect.Message
  • func (x *Ack) Reset()
  • func (x *Ack) String() string
• type CompleteRpcMessage
  • func (*CompleteRpcMessage) Descriptor() ([]byte, []int)
  • func (x *CompleteRpcMessage) GetHeader() *RpcHeader
  • func (x *CompleteRpcMessage) GetProtobufBody() []byte
  • func (x *CompleteRpcMessage) GetRawBody() []byte
  • func (*CompleteRpcMessage) ProtoMessage()
  • func (x *CompleteRpcMessage) ProtoReflect() protoreflect.Message
  • func (x *CompleteRpcMessage) Reset()
  • func (x *CompleteRpcMessage) String() string
• type RpcHeader
  • func (*RpcHeader) Descriptor() ([]byte, []int)
  • func (x *RpcHeader) GetCoordinationId() int32
  • func (x *RpcHeader) GetMode() RpcMode
  • func (x *RpcHeader) GetRpcType() int32
  • func (*RpcHeader) ProtoMessage()
  • func (x *RpcHeader) ProtoReflect() protoreflect.Message
  • func (x *RpcHeader) Reset()
  • func (x *RpcHeader) String() string
• type RpcMode
  • func (RpcMode) Descriptor() protoreflect.EnumDescriptor
  • func (x RpcMode) Enum() *RpcMode
  • func (RpcMode) EnumDescriptor() ([]byte, []int)
  • func (x RpcMode) Number() protoreflect.EnumNumber
  • func (x RpcMode) String() string
  • func (RpcMode) Type() protoreflect.EnumType
  • func (x *RpcMode) UnmarshalJSON(b []byte) error

Variables

var (
	RpcMode_name = map[int32]string{
		0: "REQUEST",
		1: "RESPONSE",
		2: "RESPONSE_FAILURE",
		3: "PING",
		4: "PONG",
	}
	RpcMode_value = map[string]int32{
		"REQUEST":          0,
		"RESPONSE":         1,
		"RESPONSE_FAILURE": 2,
		"PING":             3,
		"PONG":             4,
	}
)

Enum value maps for RpcMode.

var File_GeneralRPC_proto protoreflect.FileDescriptor

Types

type Ack

type Ack struct {
	Ok *bool `protobuf:"varint,1,opt,name=ok" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*Ack) Descriptor

func (*Ack) Descriptor() ([]byte, []int)

Deprecated: Use Ack.ProtoReflect.Descriptor instead.

func (*Ack) GetOk

func (x *Ack) GetOk() bool

func (*Ack) ProtoMessage

func (*Ack) ProtoMessage()

func (*Ack) ProtoReflect

func (x *Ack) ProtoReflect() protoreflect.Message

func (*Ack) Reset

func (x *Ack) Reset()

func (*Ack) String

func (x *Ack) String() string

type CompleteRpcMessage

type CompleteRpcMessage struct {
	Header       *RpcHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`                                 // required
	ProtobufBody []byte     `protobuf:"bytes,2,opt,name=protobuf_body,json=protobufBody" json:"protobuf_body,omitempty"` // required
	RawBody      []byte     `protobuf:"bytes,3,opt,name=raw_body,json=rawBody" json:"raw_body,omitempty"`                // optional
	// contains filtered or unexported fields
}

func (*CompleteRpcMessage) Descriptor

func (*CompleteRpcMessage) Descriptor() ([]byte, []int)

Deprecated: Use CompleteRpcMessage.ProtoReflect.Descriptor instead.

func (*CompleteRpcMessage) GetHeader

func (x *CompleteRpcMessage) GetHeader() *RpcHeader

func (*CompleteRpcMessage) GetProtobufBody

func (x *CompleteRpcMessage) GetProtobufBody() []byte

func (*CompleteRpcMessage) GetRawBody

func (x *CompleteRpcMessage) GetRawBody() []byte

func (*CompleteRpcMessage) ProtoMessage

func (*CompleteRpcMessage) ProtoMessage()

func (*CompleteRpcMessage) ProtoReflect

func (x *CompleteRpcMessage) ProtoReflect() protoreflect.Message

func (*CompleteRpcMessage) Reset

func (x *CompleteRpcMessage) Reset()

func (*CompleteRpcMessage) String

func (x *CompleteRpcMessage) String() string

type RpcHeader

type RpcHeader struct {
	Mode           *RpcMode `protobuf:"varint,1,opt,name=mode,enum=exec.rpc.RpcMode" json:"mode,omitempty"`
	CoordinationId *int32   `protobuf:"varint,2,opt,name=coordination_id,json=coordinationId" json:"coordination_id,omitempty"` // reusable coordination identifier.  Sender defines.  Server returns on return.  Irrelevant for purely single direction rpc.
	RpcType        *int32   `protobuf:"varint,3,opt,name=rpc_type,json=rpcType" json:"rpc_type,omitempty"`                      // a rpc mode specific rpc type.
	// contains filtered or unexported fields
}

func (*RpcHeader) Descriptor

func (*RpcHeader) Descriptor() ([]byte, []int)

Deprecated: Use RpcHeader.ProtoReflect.Descriptor instead.

func (*RpcHeader) GetCoordinationId

func (x *RpcHeader) GetCoordinationId() int32

func (*RpcHeader) GetMode

func (x *RpcHeader) GetMode() RpcMode

func (*RpcHeader) GetRpcType

func (x *RpcHeader) GetRpcType() int32

func (*RpcHeader) ProtoMessage

func (*RpcHeader) ProtoMessage()

func (*RpcHeader) ProtoReflect

func (x *RpcHeader) ProtoReflect() protoreflect.Message

func (*RpcHeader) Reset

func (x *RpcHeader) Reset()

func (*RpcHeader) String

func (x *RpcHeader) String() string

type RpcMode

type RpcMode int32

const (
	RpcMode_REQUEST          RpcMode = 0
	RpcMode_RESPONSE         RpcMode = 1
	RpcMode_RESPONSE_FAILURE RpcMode = 2
	RpcMode_PING             RpcMode = 3
	RpcMode_PONG             RpcMode = 4
)

func (RpcMode) Descriptor

func (RpcMode) Descriptor() protoreflect.EnumDescriptor

func (RpcMode) Enum

func (x RpcMode) Enum() *RpcMode

func (RpcMode) EnumDescriptor

func (RpcMode) EnumDescriptor() ([]byte, []int)

Deprecated: Use RpcMode.Descriptor instead.

func (RpcMode) Number

func (x RpcMode) Number() protoreflect.EnumNumber

func (RpcMode) String

func (x RpcMode) String() string

func (RpcMode) Type

func (RpcMode) Type() protoreflect.EnumType

func (*RpcMode) UnmarshalJSON

func (x *RpcMode) UnmarshalJSON(b []byte) error

Deprecated: Do not use.