internal

Documentation

Overview

Package internal is a generated protocol buffer package.

It is generated from these files:

internal/data.proto

It has these top-level messages:

WriteShardRequest
WriteShardResponse
MapShardRequest
MapShardResponse

Index

• type MapShardRequest
  • func (m *MapShardRequest) GetChunkSize() int32
  • func (m *MapShardRequest) GetQuery() string
  • func (m *MapShardRequest) GetShardID() uint64
  • func (*MapShardRequest) ProtoMessage()
  • func (m *MapShardRequest) Reset()
  • func (m *MapShardRequest) String() string
• type MapShardResponse
  • func (m *MapShardResponse) GetCode() int32
  • func (m *MapShardResponse) GetData() []byte
  • func (m *MapShardResponse) GetFields() []string
  • func (m *MapShardResponse) GetMessage() string
  • func (m *MapShardResponse) GetTagSets() []string
  • func (*MapShardResponse) ProtoMessage()
  • func (m *MapShardResponse) Reset()
  • func (m *MapShardResponse) String() string
• type WriteShardRequest
  • func (m *WriteShardRequest) GetPoints() [][]byte
  • func (m *WriteShardRequest) GetShardID() uint64
  • func (*WriteShardRequest) ProtoMessage()
  • func (m *WriteShardRequest) Reset()
  • func (m *WriteShardRequest) String() string
• type WriteShardResponse
  • func (m *WriteShardResponse) GetCode() int32
  • func (m *WriteShardResponse) GetMessage() string
  • func (*WriteShardResponse) ProtoMessage()
  • func (m *WriteShardResponse) Reset()
  • func (m *WriteShardResponse) String() string

Types

type MapShardRequest

type MapShardRequest struct {
	ShardID          *uint64 `protobuf:"varint,1,req,name=ShardID" json:"ShardID,omitempty"`
	Query            *string `protobuf:"bytes,2,req,name=Query" json:"Query,omitempty"`
	ChunkSize        *int32  `protobuf:"varint,3,req,name=ChunkSize" json:"ChunkSize,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*MapShardRequest) GetChunkSize

func (m *MapShardRequest) GetChunkSize() int32

func (*MapShardRequest) GetQuery

func (m *MapShardRequest) GetQuery() string

func (*MapShardRequest) GetShardID

func (m *MapShardRequest) GetShardID() uint64

func (*MapShardRequest) ProtoMessage

func (*MapShardRequest) ProtoMessage()

func (*MapShardRequest) Reset

func (m *MapShardRequest) Reset()

func (*MapShardRequest) String

func (m *MapShardRequest) String() string

type MapShardResponse

type MapShardResponse struct {
	Code             *int32   `protobuf:"varint,1,req,name=Code" json:"Code,omitempty"`
	Message          *string  `protobuf:"bytes,2,opt,name=Message" json:"Message,omitempty"`
	Data             []byte   `protobuf:"bytes,3,opt,name=Data" json:"Data,omitempty"`
	TagSets          []string `protobuf:"bytes,4,rep,name=TagSets" json:"TagSets,omitempty"`
	Fields           []string `protobuf:"bytes,5,rep,name=Fields" json:"Fields,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*MapShardResponse) GetCode

func (m *MapShardResponse) GetCode() int32

func (*MapShardResponse) GetData

func (m *MapShardResponse) GetData() []byte

func (*MapShardResponse) GetFields

func (m *MapShardResponse) GetFields() []string

func (*MapShardResponse) GetMessage

func (m *MapShardResponse) GetMessage() string

func (*MapShardResponse) GetTagSets

func (m *MapShardResponse) GetTagSets() []string

func (*MapShardResponse) ProtoMessage

func (*MapShardResponse) ProtoMessage()

func (*MapShardResponse) Reset

func (m *MapShardResponse) Reset()

func (*MapShardResponse) String

func (m *MapShardResponse) String() string

type WriteShardRequest

type WriteShardRequest struct {
	ShardID          *uint64  `protobuf:"varint,1,req,name=ShardID" json:"ShardID,omitempty"`
	Points           [][]byte `protobuf:"bytes,2,rep,name=Points" json:"Points,omitempty"`
	XXX_unrecognized []byte   `json:"-"`
}

func (*WriteShardRequest) GetPoints

func (m *WriteShardRequest) GetPoints() [][]byte

func (*WriteShardRequest) GetShardID

func (m *WriteShardRequest) GetShardID() uint64

func (*WriteShardRequest) ProtoMessage

func (*WriteShardRequest) ProtoMessage()

func (*WriteShardRequest) Reset

func (m *WriteShardRequest) Reset()

func (*WriteShardRequest) String

func (m *WriteShardRequest) String() string

type WriteShardResponse

type WriteShardResponse struct {
	Code             *int32  `protobuf:"varint,1,req,name=Code" json:"Code,omitempty"`
	Message          *string `protobuf:"bytes,2,opt,name=Message" json:"Message,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*WriteShardResponse) GetCode

func (m *WriteShardResponse) GetCode() int32

func (*WriteShardResponse) GetMessage

func (m *WriteShardResponse) GetMessage() string

func (*WriteShardResponse) ProtoMessage

func (*WriteShardResponse) ProtoMessage()

func (*WriteShardResponse) Reset

func (m *WriteShardResponse) Reset()

func (*WriteShardResponse) String

func (m *WriteShardResponse) String() string