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() map[string]string
  • func (*SinkMessage) ProtoMessage()
  • func (x *SinkMessage) ProtoReflect() protoreflect.Message
  • func (x *SinkMessage) Reset()
  • func (x *SinkMessage) String() string

Variables

var File_sink_message_proto protoreflect.FileDescriptor

Types

type SinkMessage

type SinkMessage struct {
	MessageId          string            `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	Content            []byte            `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	CurrentChunkNumber int32             `protobuf:"varint,3,opt,name=current_chunk_number,json=currentChunkNumber,proto3" json:"current_chunk_number,omitempty"`
	TotalChunks        int32             `protobuf:"varint,4,opt,name=total_chunks,json=totalChunks,proto3" json:"total_chunks,omitempty"`
	TracingInfo        map[string]string `` /* 182-byte string literal not displayed */
	// 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() map[string]string

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