__

Documentation

Index

• Variables
• type ChunkInfo
  • func (*ChunkInfo) Descriptor() ([]byte, []int)
  • func (x *ChunkInfo) GetChunkId() int64
  • func (x *ChunkInfo) GetStreamId() int64
  • func (*ChunkInfo) ProtoMessage()
  • func (x *ChunkInfo) ProtoReflect() protoreflect.Message
  • func (x *ChunkInfo) Reset()
  • func (x *ChunkInfo) String() string
• type Request
  • func (*Request) Descriptor() ([]byte, []int)
  • func (x *Request) GetMethodName() string
  • func (x *Request) GetServiceName() string
  • func (x *Request) GetTraceId() string
  • func (*Request) ProtoMessage()
  • func (x *Request) ProtoReflect() protoreflect.Message
  • func (x *Request) Reset()
  • func (x *Request) String() string
• type Response
  • func (*Response) Descriptor() ([]byte, []int)
  • func (x *Response) GetErrorCode() int32
  • func (x *Response) GetErrorMsg() string
  • func (*Response) ProtoMessage()
  • func (x *Response) ProtoReflect() protoreflect.Message
  • func (x *Response) Reset()
  • func (x *Response) String() string
• type RpcMeta
  • func (*RpcMeta) Descriptor() ([]byte, []int)
  • func (x *RpcMeta) GetAttachmentSize() int32
  • func (x *RpcMeta) GetAuthenticationData() []byte
  • func (x *RpcMeta) GetChunkInfo() *ChunkInfo
  • func (x *RpcMeta) GetCompressType() int32
  • func (x *RpcMeta) GetCorrelationId() int64
  • func (x *RpcMeta) GetRequest() *Request
  • func (x *RpcMeta) GetResponse() *Response
  • func (*RpcMeta) ProtoMessage()
  • func (x *RpcMeta) ProtoReflect() protoreflect.Message
  • func (x *RpcMeta) Reset()
  • func (x *RpcMeta) String() string

Variables

var File_meta_proto protoreflect.FileDescriptor

Types

type ChunkInfo

type ChunkInfo struct {
	StreamId int64 `protobuf:"varint,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	ChunkId  int64 `protobuf:"varint,2,opt,name=chunk_id,json=chunkId,proto3" json:"chunk_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ChunkInfo) Descriptor

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

Deprecated: Use ChunkInfo.ProtoReflect.Descriptor instead.

func (*ChunkInfo) GetChunkId

func (x *ChunkInfo) GetChunkId() int64

func (*ChunkInfo) GetStreamId

func (x *ChunkInfo) GetStreamId() int64

func (*ChunkInfo) ProtoMessage

func (*ChunkInfo) ProtoMessage()

func (*ChunkInfo) ProtoReflect

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

func (*ChunkInfo) Reset

func (x *ChunkInfo) Reset()

func (*ChunkInfo) String

func (x *ChunkInfo) String() string

type Request

type Request struct {
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	MethodName  string `protobuf:"bytes,2,opt,name=method_name,json=methodName,proto3" json:"method_name,omitempty"`
	TraceId     string `protobuf:"bytes,3,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	// contains filtered or unexported fields
}

func (*Request) Descriptor

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

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetMethodName

func (x *Request) GetMethodName() string

func (*Request) GetServiceName

func (x *Request) GetServiceName() string

func (*Request) GetTraceId

func (x *Request) GetTraceId() string

func (*Request) ProtoMessage

func (*Request) ProtoMessage()

func (*Request) ProtoReflect

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

func (*Request) Reset

func (x *Request) Reset()

func (*Request) String

func (x *Request) String() string

type Response

type Response struct {
	ErrorCode *int32  `protobuf:"varint,1,opt,name=error_code,json=errorCode,proto3,oneof" json:"error_code,omitempty"`
	ErrorMsg  *string `protobuf:"bytes,2,opt,name=error_msg,json=errorMsg,proto3,oneof" json:"error_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*Response) Descriptor

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

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetErrorCode

func (x *Response) GetErrorCode() int32

func (*Response) GetErrorMsg

func (x *Response) GetErrorMsg() string

func (*Response) ProtoMessage

func (*Response) ProtoMessage()

func (*Response) ProtoReflect

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

func (*Response) Reset

func (x *Response) Reset()

func (*Response) String

func (x *Response) String() string

type RpcMeta

type RpcMeta struct {
	Request            *Request   `protobuf:"bytes,1,opt,name=request,proto3,oneof" json:"request,omitempty"`
	Response           *Response  `protobuf:"bytes,2,opt,name=response,proto3,oneof" json:"response,omitempty"`
	CompressType       *int32     `protobuf:"varint,3,opt,name=compress_type,json=compressType,proto3,oneof" json:"compress_type,omitempty"`
	CorrelationId      *int64     `protobuf:"varint,4,opt,name=correlation_id,json=correlationId,proto3,oneof" json:"correlation_id,omitempty"`
	AttachmentSize     *int32     `protobuf:"varint,5,opt,name=attachment_size,json=attachmentSize,proto3,oneof" json:"attachment_size,omitempty"`
	ChunkInfo          *ChunkInfo `protobuf:"bytes,6,opt,name=chunk_info,json=chunkInfo,proto3,oneof" json:"chunk_info,omitempty"`
	AuthenticationData []byte     `protobuf:"bytes,7,opt,name=authentication_data,json=authenticationData,proto3,oneof" json:"authentication_data,omitempty"`
	// contains filtered or unexported fields
}

func (*RpcMeta) Descriptor

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

Deprecated: Use RpcMeta.ProtoReflect.Descriptor instead.

func (*RpcMeta) GetAttachmentSize

func (x *RpcMeta) GetAttachmentSize() int32

func (*RpcMeta) GetAuthenticationData

func (x *RpcMeta) GetAuthenticationData() []byte

func (*RpcMeta) GetChunkInfo

func (x *RpcMeta) GetChunkInfo() *ChunkInfo

func (*RpcMeta) GetCompressType

func (x *RpcMeta) GetCompressType() int32

func (*RpcMeta) GetCorrelationId

func (x *RpcMeta) GetCorrelationId() int64

func (*RpcMeta) GetRequest

func (x *RpcMeta) GetRequest() *Request

func (*RpcMeta) GetResponse

func (x *RpcMeta) GetResponse() *Response

func (*RpcMeta) ProtoMessage

func (*RpcMeta) ProtoMessage()

func (*RpcMeta) ProtoReflect

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

func (*RpcMeta) Reset

func (x *RpcMeta) Reset()

func (*RpcMeta) String

func (x *RpcMeta) String() string