sink

Documentation

Index

• Variables
• type SinkMessage
  • func (*SinkMessage) Descriptor() ([]byte, []int)
  • func (x *SinkMessage) GetContent() []byte
  • func (x *SinkMessage) GetCurrentChunkNumber() int32
  • func (x *SinkMessage) GetMessageId() string
  • func (x *SinkMessage) GetTotalChunks() int32
  • func (x *SinkMessage) GetTracingInfo() []*TracingInfo
  • func (*SinkMessage) ProtoMessage()
  • func (x *SinkMessage) ProtoReflect() protoreflect.Message
  • func (x *SinkMessage) Reset()
  • func (x *SinkMessage) String() string
• type TracingInfo
  • func (*TracingInfo) Descriptor() ([]byte, []int)
  • func (x *TracingInfo) GetKey() string
  • func (x *TracingInfo) GetValue() string
  • func (*TracingInfo) ProtoMessage()
  • func (x *TracingInfo) ProtoReflect() protoreflect.Message
  • func (x *TracingInfo) Reset()
  • func (x *TracingInfo) String() string

Variables

var File_sink_proto protoreflect.FileDescriptor

Types

type SinkMessage

type SinkMessage struct {
	MessageId          *string        `protobuf:"bytes,1,req,name=message_id,json=messageId" json:"message_id,omitempty"`
	Content            []byte         `protobuf:"bytes,2,req,name=content" json:"content,omitempty"`
	CurrentChunkNumber *int32         `protobuf:"varint,5,opt,name=current_chunk_number,json=currentChunkNumber" json:"current_chunk_number,omitempty"`
	TotalChunks        *int32         `protobuf:"varint,6,opt,name=total_chunks,json=totalChunks" json:"total_chunks,omitempty"`
	TracingInfo        []*TracingInfo `protobuf:"bytes,7,rep,name=tracing_info,json=tracingInfo" json:"tracing_info,omitempty"`
	// contains filtered or unexported fields
}

func (*SinkMessage) Descriptor

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

Deprecated: Use SinkMessage.ProtoReflect.Descriptor instead.

func (*SinkMessage) GetContent

func (x *SinkMessage) GetContent() []byte

func (*SinkMessage) GetCurrentChunkNumber

func (x *SinkMessage) GetCurrentChunkNumber() int32

func (*SinkMessage) GetMessageId

func (x *SinkMessage) GetMessageId() string

func (*SinkMessage) GetTotalChunks

func (x *SinkMessage) GetTotalChunks() int32

func (*SinkMessage) GetTracingInfo

func (x *SinkMessage) GetTracingInfo() []*TracingInfo

func (*SinkMessage) ProtoMessage

func (*SinkMessage) ProtoMessage()

func (*SinkMessage) ProtoReflect

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

func (*SinkMessage) Reset

func (x *SinkMessage) Reset()

func (*SinkMessage) String

func (x *SinkMessage) String() string

type TracingInfo

type TracingInfo struct {
	Key   *string `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Value *string `protobuf:"bytes,2,req,name=value" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*TracingInfo) Descriptor

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

Deprecated: Use TracingInfo.ProtoReflect.Descriptor instead.

func (*TracingInfo) GetKey

func (x *TracingInfo) GetKey() string

func (*TracingInfo) GetValue

func (x *TracingInfo) GetValue() string

func (*TracingInfo) ProtoMessage

func (*TracingInfo) ProtoMessage()

func (*TracingInfo) ProtoReflect

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

func (*TracingInfo) Reset

func (x *TracingInfo) Reset()

func (*TracingInfo) String

func (x *TracingInfo) String() string