rpcpb

Documentation

Index

• Variables
• type RPCInfo
  • func (*RPCInfo) Descriptor() ([]byte, []int)
  • func (x *RPCInfo) GetArgs() [][]byte
  • func (x *RPCInfo) GetArgsType() []string
  • func (x *RPCInfo) GetCaller() string
  • func (x *RPCInfo) GetCid() string
  • func (x *RPCInfo) GetExpired() int64
  • func (x *RPCInfo) GetFn() string
  • func (x *RPCInfo) GetHostname() string
  • func (x *RPCInfo) GetReply() bool
  • func (x *RPCInfo) GetReplyTo() string
  • func (x *RPCInfo) GetTrack() string
  • func (*RPCInfo) ProtoMessage()
  • func (x *RPCInfo) ProtoReflect() protoreflect.Message
  • func (x *RPCInfo) Reset()
  • func (x *RPCInfo) String() string
• type ResultInfo
  • func NewResultInfo(Cid string, Error string, ArgsType string, result []byte) *ResultInfo
  • func (*ResultInfo) Descriptor() ([]byte, []int)
  • func (x *ResultInfo) GetCid() string
  • func (x *ResultInfo) GetError() string
  • func (x *ResultInfo) GetResult() []byte
  • func (x *ResultInfo) GetResultType() string
  • func (*ResultInfo) ProtoMessage()
  • func (x *ResultInfo) ProtoReflect() protoreflect.Message
  • func (x *ResultInfo) Reset()
  • func (x *ResultInfo) String() string

Variables

var File_mqant_rpc_proto protoreflect.FileDescriptor

Types

type RPCInfo

type RPCInfo struct {
	Cid      string   `protobuf:"bytes,1,opt,name=Cid,proto3" json:"Cid,omitempty"`
	Fn       string   `protobuf:"bytes,2,opt,name=Fn,proto3" json:"Fn,omitempty"`
	ReplyTo  string   `protobuf:"bytes,3,opt,name=ReplyTo,proto3" json:"ReplyTo,omitempty"`
	Track    string   `protobuf:"bytes,4,opt,name=track,proto3" json:"track,omitempty"`
	Expired  int64    `protobuf:"varint,5,opt,name=Expired,proto3" json:"Expired,omitempty"`
	Reply    bool     `protobuf:"varint,6,opt,name=Reply,proto3" json:"Reply,omitempty"`
	ArgsType []string `protobuf:"bytes,7,rep,name=ArgsType,proto3" json:"ArgsType,omitempty"`
	Args     [][]byte `protobuf:"bytes,8,rep,name=Args,proto3" json:"Args,omitempty"`
	Caller   string   `protobuf:"bytes,9,opt,name=caller,proto3" json:"caller,omitempty"`
	Hostname string   `protobuf:"bytes,10,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// contains filtered or unexported fields
}

func (*RPCInfo) Descriptor

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

Deprecated: Use RPCInfo.ProtoReflect.Descriptor instead.

func (*RPCInfo) GetArgs

func (x *RPCInfo) GetArgs() [][]byte

func (*RPCInfo) GetArgsType

func (x *RPCInfo) GetArgsType() []string

func (*RPCInfo) GetCaller

func (x *RPCInfo) GetCaller() string

func (*RPCInfo) GetCid

func (x *RPCInfo) GetCid() string

func (*RPCInfo) GetExpired

func (x *RPCInfo) GetExpired() int64

func (*RPCInfo) GetFn

func (x *RPCInfo) GetFn() string

func (*RPCInfo) GetHostname

func (x *RPCInfo) GetHostname() string

func (*RPCInfo) GetReply

func (x *RPCInfo) GetReply() bool

func (*RPCInfo) GetReplyTo

func (x *RPCInfo) GetReplyTo() string

func (*RPCInfo) GetTrack

func (x *RPCInfo) GetTrack() string

func (*RPCInfo) ProtoMessage

func (*RPCInfo) ProtoMessage()

func (*RPCInfo) ProtoReflect

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

func (*RPCInfo) Reset

func (x *RPCInfo) Reset()

func (*RPCInfo) String

func (x *RPCInfo) String() string

type ResultInfo

type ResultInfo struct {
	Cid        string `protobuf:"bytes,1,opt,name=Cid,proto3" json:"Cid,omitempty"`
	Error      string `protobuf:"bytes,2,opt,name=Error,proto3" json:"Error,omitempty"`
	ResultType string `protobuf:"bytes,4,opt,name=ResultType,proto3" json:"ResultType,omitempty"`
	Result     []byte `protobuf:"bytes,5,opt,name=Result,proto3" json:"Result,omitempty"`
	// contains filtered or unexported fields
}

func NewResultInfo

func NewResultInfo(Cid string, Error string, ArgsType string, result []byte) *ResultInfo

func (*ResultInfo) Descriptor

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

Deprecated: Use ResultInfo.ProtoReflect.Descriptor instead.

func (*ResultInfo) GetCid

func (x *ResultInfo) GetCid() string

func (*ResultInfo) GetError

func (x *ResultInfo) GetError() string

func (*ResultInfo) GetResult

func (x *ResultInfo) GetResult() []byte

func (*ResultInfo) GetResultType

func (x *ResultInfo) GetResultType() string

func (*ResultInfo) ProtoMessage

func (*ResultInfo) ProtoMessage()

func (*ResultInfo) ProtoReflect

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

func (*ResultInfo) Reset

func (x *ResultInfo) Reset()

func (*ResultInfo) String

func (x *ResultInfo) String() string