metapb

package
v0.2.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 25, 2022 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	CompressType_name = map[int32]string{
		0: "COMPRESS_TYPE_NONE",
		1: "COMPRESS_TYPE_SNAPPY",
		2: "COMPRESS_TYPE_GZIP",
		3: "COMPRESS_TYPE_ZLIB",
		4: "COMPRESS_TYPE_LZ4",
	}
	CompressType_value = map[string]int32{
		"COMPRESS_TYPE_NONE":   0,
		"COMPRESS_TYPE_SNAPPY": 1,
		"COMPRESS_TYPE_GZIP":   2,
		"COMPRESS_TYPE_ZLIB":   3,
		"COMPRESS_TYPE_LZ4":    4,
	}
)

Enum value maps for CompressType.

View Source 
var (
	FrameType_name = map[int32]string{
		0: "FRAME_TYPE_UNKNOWN",
		1: "FRAME_TYPE_RST",
		2: "FRAME_TYPE_CLOSE",
		3: "FRAME_TYPE_DATA",
		4: "FRAME_TYPE_FEEDBACK",
	}
	FrameType_value = map[string]int32{
		"FRAME_TYPE_UNKNOWN":  0,
		"FRAME_TYPE_RST":      1,
		"FRAME_TYPE_CLOSE":    2,
		"FRAME_TYPE_DATA":     3,
		"FRAME_TYPE_FEEDBACK": 4,
	}
)

Enum value maps for FrameType.

View Source 
var File_flare_rpc_meta_proto protoreflect.FileDescriptor
View Source 
var File_streaming_rpc_meta_proto protoreflect.FileDescriptor

Functions

This section is empty.

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 deprecated 

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 CompressType 

type CompressType int32
const (
	CompressType_COMPRESS_TYPE_NONE   CompressType = 0
	CompressType_COMPRESS_TYPE_SNAPPY CompressType = 1
	CompressType_COMPRESS_TYPE_GZIP   CompressType = 2
	CompressType_COMPRESS_TYPE_ZLIB   CompressType = 3
	CompressType_COMPRESS_TYPE_LZ4    CompressType = 4
)

func (CompressType) Descriptor 

func (CompressType) Descriptor() protoreflect.EnumDescriptor

func (CompressType) Enum 

func (x CompressType) Enum() *CompressType

func (CompressType) EnumDescriptor deprecated 

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

Deprecated: Use CompressType.Descriptor instead.

func (CompressType) Number 

func (x CompressType) Number() protoreflect.EnumNumber

func (CompressType) String 

func (x CompressType) String() string

func (CompressType) Type 

func (CompressType) Type() protoreflect.EnumType

type Feedback 

type Feedback struct {
	ConsumedSize int64 `protobuf:"varint,1,opt,name=consumed_size,json=consumedSize,proto3" json:"consumed_size,omitempty"`
	// contains filtered or unexported fields
}

func (*Feedback) Descriptor deprecated 

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

Deprecated: Use Feedback.ProtoReflect.Descriptor instead.

func (*Feedback) GetConsumedSize 

func (x *Feedback) GetConsumedSize() int64

func (*Feedback) ProtoMessage 

func (*Feedback) ProtoMessage()

func (*Feedback) ProtoReflect 

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

func (*Feedback) Reset 

func (x *Feedback) Reset()

func (*Feedback) String 

func (x *Feedback) String() string

type FrameType 

type FrameType int32
const (
	FrameType_FRAME_TYPE_UNKNOWN  FrameType = 0
	FrameType_FRAME_TYPE_RST      FrameType = 1
	FrameType_FRAME_TYPE_CLOSE    FrameType = 2
	FrameType_FRAME_TYPE_DATA     FrameType = 3
	FrameType_FRAME_TYPE_FEEDBACK FrameType = 4
)

func (FrameType) Descriptor 

func (FrameType) Descriptor() protoreflect.EnumDescriptor

func (FrameType) Enum 

func (x FrameType) Enum() *FrameType

func (FrameType) EnumDescriptor deprecated 

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

Deprecated: Use FrameType.Descriptor instead.

func (FrameType) Number 

func (x FrameType) Number() protoreflect.EnumNumber

func (FrameType) String 

func (x FrameType) String() string

func (FrameType) Type 

func (FrameType) Type() protoreflect.EnumType

type RpcMeta 

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

func (*RpcMeta) Descriptor deprecated 

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() *RpcRequestMeta

func (*RpcMeta) GetResponse 

func (x *RpcMeta) GetResponse() *RpcResponseMeta

func (*RpcMeta) GetStreamSettings 

func (x *RpcMeta) GetStreamSettings() *StreamSettings

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

type RpcRequestMeta 

type RpcRequestMeta 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"`
	LogId        int64  `protobuf:"varint,3,opt,name=log_id,json=logId,proto3" json:"log_id,omitempty"`
	TraceId      int64  `protobuf:"varint,4,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"`
	SpanId       int64  `protobuf:"varint,5,opt,name=span_id,json=spanId,proto3" json:"span_id,omitempty"`
	ParentSpanId int64  `protobuf:"varint,6,opt,name=parent_span_id,json=parentSpanId,proto3" json:"parent_span_id,omitempty"`
	RequestId    string `protobuf:"bytes,7,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // correspond to x-request-id in http header
	// contains filtered or unexported fields
}

func (*RpcRequestMeta) Descriptor deprecated 

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

Deprecated: Use RpcRequestMeta.ProtoReflect.Descriptor instead.

func (*RpcRequestMeta) GetLogId 

func (x *RpcRequestMeta) GetLogId() int64

func (*RpcRequestMeta) GetMethodName 

func (x *RpcRequestMeta) GetMethodName() string

func (*RpcRequestMeta) GetParentSpanId 

func (x *RpcRequestMeta) GetParentSpanId() int64

func (*RpcRequestMeta) GetRequestId 

func (x *RpcRequestMeta) GetRequestId() string

func (*RpcRequestMeta) GetServiceName 

func (x *RpcRequestMeta) GetServiceName() string

func (*RpcRequestMeta) GetSpanId 

func (x *RpcRequestMeta) GetSpanId() int64

func (*RpcRequestMeta) GetTraceId 

func (x *RpcRequestMeta) GetTraceId() int64

func (*RpcRequestMeta) ProtoMessage 

func (*RpcRequestMeta) ProtoMessage()

func (*RpcRequestMeta) ProtoReflect 

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

func (*RpcRequestMeta) Reset 

func (x *RpcRequestMeta) Reset()

func (*RpcRequestMeta) String 

func (x *RpcRequestMeta) String() string

type RpcResponseMeta 

type RpcResponseMeta struct {
	ErrorCode int32  `protobuf:"varint,1,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
	ErrorText string `protobuf:"bytes,2,opt,name=error_text,json=errorText,proto3" json:"error_text,omitempty"`
	// contains filtered or unexported fields
}

func (*RpcResponseMeta) Descriptor deprecated 

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

Deprecated: Use RpcResponseMeta.ProtoReflect.Descriptor instead.

func (*RpcResponseMeta) GetErrorCode 

func (x *RpcResponseMeta) GetErrorCode() int32

func (*RpcResponseMeta) GetErrorText 

func (x *RpcResponseMeta) GetErrorText() string

func (*RpcResponseMeta) ProtoMessage 

func (*RpcResponseMeta) ProtoMessage()

func (*RpcResponseMeta) ProtoReflect 

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

func (*RpcResponseMeta) Reset 

func (x *RpcResponseMeta) Reset()

func (*RpcResponseMeta) String 

func (x *RpcResponseMeta) String() string

type StreamFrameMeta 

type StreamFrameMeta struct {
	StreamId        int64     `protobuf:"varint,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	SourceStreamId  int64     `protobuf:"varint,2,opt,name=source_stream_id,json=sourceStreamId,proto3" json:"source_stream_id,omitempty"`
	FrameType       FrameType `protobuf:"varint,3,opt,name=frame_type,json=frameType,proto3,enum=flare.FrameType" json:"frame_type,omitempty"`
	HasContinuation bool      `protobuf:"varint,4,opt,name=has_continuation,json=hasContinuation,proto3" json:"has_continuation,omitempty"`
	Feedback        *Feedback `protobuf:"bytes,5,opt,name=feedback,proto3" json:"feedback,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFrameMeta) Descriptor deprecated 

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

Deprecated: Use StreamFrameMeta.ProtoReflect.Descriptor instead.

func (*StreamFrameMeta) GetFeedback 

func (x *StreamFrameMeta) GetFeedback() *Feedback

func (*StreamFrameMeta) GetFrameType 

func (x *StreamFrameMeta) GetFrameType() FrameType

func (*StreamFrameMeta) GetHasContinuation 

func (x *StreamFrameMeta) GetHasContinuation() bool

func (*StreamFrameMeta) GetSourceStreamId 

func (x *StreamFrameMeta) GetSourceStreamId() int64

func (*StreamFrameMeta) GetStreamId 

func (x *StreamFrameMeta) GetStreamId() int64

func (*StreamFrameMeta) ProtoMessage 

func (*StreamFrameMeta) ProtoMessage()

func (*StreamFrameMeta) ProtoReflect 

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

func (*StreamFrameMeta) Reset 

func (x *StreamFrameMeta) Reset()

func (*StreamFrameMeta) String 

func (x *StreamFrameMeta) String() string

type StreamSettings 

type StreamSettings struct {
	StreamId     int64 `protobuf:"varint,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	NeedFeedback bool  `protobuf:"varint,2,opt,name=need_feedback,json=needFeedback,proto3" json:"need_feedback,omitempty"`
	Writable     bool  `protobuf:"varint,3,opt,name=writable,proto3" json:"writable,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamSettings) Descriptor deprecated 

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

Deprecated: Use StreamSettings.ProtoReflect.Descriptor instead.

func (*StreamSettings) GetNeedFeedback 

func (x *StreamSettings) GetNeedFeedback() bool

func (*StreamSettings) GetStreamId 

func (x *StreamSettings) GetStreamId() int64

func (*StreamSettings) GetWritable 

func (x *StreamSettings) GetWritable() bool

func (*StreamSettings) ProtoMessage 

func (*StreamSettings) ProtoMessage()

func (*StreamSettings) ProtoReflect 

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

func (*StreamSettings) Reset 

func (x *StreamSettings) Reset()

func (*StreamSettings) String 

func (x *StreamSettings) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.