queue_service_protos

Documentation

Index

• Variables
• type AttributesProto
  • func (*AttributesProto) Descriptor() ([]byte, []int)
  • func (x *AttributesProto) GetAttributes() map[string]string
  • func (*AttributesProto) ProtoMessage()
  • func (x *AttributesProto) ProtoReflect() protoreflect.Message
  • func (x *AttributesProto) Reset()
  • func (x *AttributesProto) String() string
• type DataFrameListProto
  • func (*DataFrameListProto) Descriptor() ([]byte, []int)
  • func (x *DataFrameListProto) GetIndex() []*DataFrameProto
  • func (*DataFrameListProto) ProtoMessage()
  • func (x *DataFrameListProto) ProtoReflect() protoreflect.Message
  • func (x *DataFrameListProto) Reset()
  • func (x *DataFrameListProto) String() string
• type DataFrameProto
  • func (*DataFrameProto) Descriptor() ([]byte, []int)
  • func (x *DataFrameProto) GetData() []byte
  • func (x *DataFrameProto) GetIndex() uint64
  • func (x *DataFrameProto) GetMessage() string
  • func (x *DataFrameProto) GetTags() map[string]string
  • func (*DataFrameProto) ProtoMessage()
  • func (x *DataFrameProto) ProtoReflect() protoreflect.Message
  • func (x *DataFrameProto) Reset()
  • func (x *DataFrameProto) String() string

Variables

var File_pkg_streaming_types_queueservice_proto protoreflect.FileDescriptor

Types

type AttributesProto

type AttributesProto struct {
	Attributes map[string]string `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*AttributesProto) Descriptor

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

Deprecated: Use AttributesProto.ProtoReflect.Descriptor instead.

func (*AttributesProto) GetAttributes

func (x *AttributesProto) GetAttributes() map[string]string

func (*AttributesProto) ProtoMessage

func (*AttributesProto) ProtoMessage()

func (*AttributesProto) ProtoReflect

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

func (*AttributesProto) Reset

func (x *AttributesProto) Reset()

func (*AttributesProto) String

func (x *AttributesProto) String() string

type DataFrameListProto

type DataFrameListProto struct {
	Index []*DataFrameProto `protobuf:"bytes,1,rep,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

func (*DataFrameListProto) Descriptor

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

Deprecated: Use DataFrameListProto.ProtoReflect.Descriptor instead.

func (*DataFrameListProto) GetIndex

func (x *DataFrameListProto) GetIndex() []*DataFrameProto

func (*DataFrameListProto) ProtoMessage

func (*DataFrameListProto) ProtoMessage()

func (*DataFrameListProto) ProtoReflect

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

func (*DataFrameListProto) Reset

func (x *DataFrameListProto) Reset()

func (*DataFrameListProto) String

func (x *DataFrameListProto) String() string

type DataFrameProto

type DataFrameProto struct {
	Index   uint64            `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Tags    map[string]string `` /* 149-byte string literal not displayed */
	Data    []byte            `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Message string            `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*DataFrameProto) Descriptor

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

Deprecated: Use DataFrameProto.ProtoReflect.Descriptor instead.

func (*DataFrameProto) GetData

func (x *DataFrameProto) GetData() []byte

func (*DataFrameProto) GetIndex

func (x *DataFrameProto) GetIndex() uint64

func (*DataFrameProto) GetMessage

func (x *DataFrameProto) GetMessage() string

func (*DataFrameProto) GetTags

func (x *DataFrameProto) GetTags() map[string]string

func (*DataFrameProto) ProtoMessage

func (*DataFrameProto) ProtoMessage()

func (*DataFrameProto) ProtoReflect

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

func (*DataFrameProto) Reset

func (x *DataFrameProto) Reset()

func (*DataFrameProto) String

func (x *DataFrameProto) String() string