msgservice_data

package
v1.5.2 Latest Latest
Warning

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

 Go to latest Published: Jan 9, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_lib_msgservice_data_data_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ClearEventsRequest 

type ClearEventsRequest struct {
	NodeId   *uint64 `protobuf:"varint,1,req,name=NodeId" json:"NodeId,omitempty"`
	PtId     *uint32 `protobuf:"varint,2,req,name=PtId" json:"PtId,omitempty"`
	Database *string `protobuf:"bytes,3,req,name=Database" json:"Database,omitempty"`
	Rp       *string `protobuf:"bytes,4,req,name=rp" json:"rp,omitempty"`
	Pair     *Pair   `protobuf:"bytes,5,req,name=pair" json:"pair,omitempty"`
	// contains filtered or unexported fields
}

func (*ClearEventsRequest) Descriptor deprecated 

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

Deprecated: Use ClearEventsRequest.ProtoReflect.Descriptor instead.

func (*ClearEventsRequest) GetDatabase 

func (x *ClearEventsRequest) GetDatabase() string

func (*ClearEventsRequest) GetNodeId 

func (x *ClearEventsRequest) GetNodeId() uint64

func (*ClearEventsRequest) GetPair 

func (x *ClearEventsRequest) GetPair() *Pair

func (*ClearEventsRequest) GetPtId 

func (x *ClearEventsRequest) GetPtId() uint32

func (*ClearEventsRequest) GetRp 

func (x *ClearEventsRequest) GetRp() string

func (*ClearEventsRequest) ProtoMessage 

func (*ClearEventsRequest) ProtoMessage()

func (*ClearEventsRequest) ProtoReflect 

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

func (*ClearEventsRequest) Reset 

func (x *ClearEventsRequest) Reset()

func (*ClearEventsRequest) String 

func (x *ClearEventsRequest) String() string

type ClearEventsResponse 

type ClearEventsResponse struct {
	Err *string `protobuf:"bytes,1,opt,name=Err" json:"Err,omitempty"`
	// contains filtered or unexported fields
}

func (*ClearEventsResponse) Descriptor deprecated 

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

Deprecated: Use ClearEventsResponse.ProtoReflect.Descriptor instead.

func (*ClearEventsResponse) GetErr 

func (x *ClearEventsResponse) GetErr() string

func (*ClearEventsResponse) ProtoMessage 

func (*ClearEventsResponse) ProtoMessage()

func (*ClearEventsResponse) ProtoReflect 

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

func (*ClearEventsResponse) Reset 

func (x *ClearEventsResponse) Reset()

func (*ClearEventsResponse) String 

func (x *ClearEventsResponse) String() string

type CreateDataBaseRequest 

type CreateDataBaseRequest struct {
	Db *string `protobuf:"bytes,1,req,name=Db" json:"Db,omitempty"`
	Pt *uint32 `protobuf:"varint,2,req,name=pt" json:"pt,omitempty"`
	Rp *string `protobuf:"bytes,3,req,name=rp" json:"rp,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDataBaseRequest) Descriptor deprecated 

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

Deprecated: Use CreateDataBaseRequest.ProtoReflect.Descriptor instead.

func (*CreateDataBaseRequest) GetDb 

func (x *CreateDataBaseRequest) GetDb() string

func (*CreateDataBaseRequest) GetPt 

func (x *CreateDataBaseRequest) GetPt() uint32

func (*CreateDataBaseRequest) GetRp 

func (x *CreateDataBaseRequest) GetRp() string

func (*CreateDataBaseRequest) ProtoMessage 

func (*CreateDataBaseRequest) ProtoMessage()

func (*CreateDataBaseRequest) ProtoReflect 

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

func (*CreateDataBaseRequest) Reset 

func (x *CreateDataBaseRequest) Reset()

func (*CreateDataBaseRequest) String 

func (x *CreateDataBaseRequest) String() string

type CreateDataBaseResponse 

type CreateDataBaseResponse struct {
	Err *string `protobuf:"bytes,1,opt,name=Err" json:"Err,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDataBaseResponse) Descriptor deprecated 

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

Deprecated: Use CreateDataBaseResponse.ProtoReflect.Descriptor instead.

func (*CreateDataBaseResponse) GetErr 

func (x *CreateDataBaseResponse) GetErr() string

func (*CreateDataBaseResponse) ProtoMessage 

func (*CreateDataBaseResponse) ProtoMessage()

func (*CreateDataBaseResponse) ProtoReflect 

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

func (*CreateDataBaseResponse) Reset 

func (x *CreateDataBaseResponse) Reset()

func (*CreateDataBaseResponse) String 

func (x *CreateDataBaseResponse) String() string

type DeleteRequest 

type DeleteRequest struct {
	DB         *string  `protobuf:"bytes,1,req,name=DB" json:"DB,omitempty"`
	Rp         *string  `protobuf:"bytes,2,opt,name=Rp" json:"Rp,omitempty"`
	Mst        *string  `protobuf:"bytes,3,opt,name=Mst" json:"Mst,omitempty"`
	ShardIDs   []uint64 `protobuf:"varint,4,rep,name=ShardIDs" json:"ShardIDs,omitempty"`
	DeleteType *int32   `protobuf:"varint,5,req,name=DeleteType" json:"DeleteType,omitempty"`
	PtId       *uint32  `protobuf:"varint,6,opt,name=PtId" json:"PtId,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetDB 

func (x *DeleteRequest) GetDB() string

func (*DeleteRequest) GetDeleteType 

func (x *DeleteRequest) GetDeleteType() int32

func (*DeleteRequest) GetMst 

func (x *DeleteRequest) GetMst() string

func (*DeleteRequest) GetPtId 

func (x *DeleteRequest) GetPtId() uint32

func (*DeleteRequest) GetRp 

func (x *DeleteRequest) GetRp() string

func (*DeleteRequest) GetShardIDs 

func (x *DeleteRequest) GetShardIDs() []uint64

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect 

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

func (*DeleteRequest) Reset 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (x *DeleteRequest) String() string

type DeleteResponse 

type DeleteResponse struct {
	Err *string `protobuf:"bytes,1,opt,name=Err" json:"Err,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteResponse) Descriptor deprecated 

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

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) GetErr 

func (x *DeleteResponse) GetErr() string

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect 

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

func (*DeleteResponse) Reset 

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (x *DeleteResponse) String() string

type DropSeriesRequest 

type DropSeriesRequest struct {
	Db           *string  `protobuf:"bytes,1,req,name=Db" json:"Db,omitempty"`
	PtIDs        []uint32 `protobuf:"varint,2,rep,name=PtIDs" json:"PtIDs,omitempty"`
	Measurements []string `protobuf:"bytes,3,rep,name=Measurements" json:"Measurements,omitempty"`
	Condition    *string  `protobuf:"bytes,4,opt,name=condition" json:"condition,omitempty"`
	// contains filtered or unexported fields
}

func (*DropSeriesRequest) Descriptor deprecated 

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

Deprecated: Use DropSeriesRequest.ProtoReflect.Descriptor instead.

func (*DropSeriesRequest) GetCondition 

func (x *DropSeriesRequest) GetCondition() string

func (*DropSeriesRequest) GetDb 

func (x *DropSeriesRequest) GetDb() string

func (*DropSeriesRequest) GetMeasurements 

func (x *DropSeriesRequest) GetMeasurements() []string

func (*DropSeriesRequest) GetPtIDs 

func (x *DropSeriesRequest) GetPtIDs() []uint32

func (*DropSeriesRequest) ProtoMessage 

func (*DropSeriesRequest) ProtoMessage()

func (*DropSeriesRequest) ProtoReflect 

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

func (*DropSeriesRequest) Reset 

func (x *DropSeriesRequest) Reset()

func (*DropSeriesRequest) String 

func (x *DropSeriesRequest) String() string

type DropSeriesResponse 

type DropSeriesResponse struct {
	Err *string `protobuf:"bytes,1,opt,name=Err" json:"Err,omitempty"`
	// contains filtered or unexported fields
}

func (*DropSeriesResponse) Descriptor deprecated 

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

Deprecated: Use DropSeriesResponse.ProtoReflect.Descriptor instead.

func (*DropSeriesResponse) GetErr 

func (x *DropSeriesResponse) GetErr() string

func (*DropSeriesResponse) ProtoMessage 

func (*DropSeriesResponse) ProtoMessage()

func (*DropSeriesResponse) ProtoReflect 

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

func (*DropSeriesResponse) Reset 

func (x *DropSeriesResponse) Reset()

func (*DropSeriesResponse) String 

func (x *DropSeriesResponse) String() string

type ExactCardinalityResponse 

type ExactCardinalityResponse struct {
	Cardinality map[string]uint64 `` /* 143-byte string literal not displayed */
	Err         *string           `protobuf:"bytes,2,opt,name=Err" json:"Err,omitempty"`
	// contains filtered or unexported fields
}

func (*ExactCardinalityResponse) Descriptor deprecated 

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

Deprecated: Use ExactCardinalityResponse.ProtoReflect.Descriptor instead.

func (*ExactCardinalityResponse) GetCardinality 

func (x *ExactCardinalityResponse) GetCardinality() map[string]uint64

func (*ExactCardinalityResponse) GetErr 

func (x *ExactCardinalityResponse) GetErr() string

func (*ExactCardinalityResponse) ProtoMessage 

func (*ExactCardinalityResponse) ProtoMessage()

func (*ExactCardinalityResponse) ProtoReflect 

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

func (*ExactCardinalityResponse) Reset 

func (x *ExactCardinalityResponse) Reset()

func (*ExactCardinalityResponse) String 

func (x *ExactCardinalityResponse) String() string

type GetShardSplitPointsRequest 

type GetShardSplitPointsRequest struct {
	DB      *string `protobuf:"bytes,1,req,name=DB" json:"DB,omitempty"`
	PtID    *uint32 `protobuf:"varint,2,req,name=PtID" json:"PtID,omitempty"`
	ShardID *uint64 `protobuf:"varint,3,req,name=ShardID" json:"ShardID,omitempty"`
	Idxes   []int64 `protobuf:"varint,4,rep,name=Idxes" json:"Idxes,omitempty"`
	// contains filtered or unexported fields
}

func (*GetShardSplitPointsRequest) Descriptor deprecated 

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

Deprecated: Use GetShardSplitPointsRequest.ProtoReflect.Descriptor instead.

func (*GetShardSplitPointsRequest) GetDB 

func (x *GetShardSplitPointsRequest) GetDB() string

func (*GetShardSplitPointsRequest) GetIdxes 

func (x *GetShardSplitPointsRequest) GetIdxes() []int64

func (*GetShardSplitPointsRequest) GetPtID 

func (x *GetShardSplitPointsRequest) GetPtID() uint32

func (*GetShardSplitPointsRequest) GetShardID 

func (x *GetShardSplitPointsRequest) GetShardID() uint64

func (*GetShardSplitPointsRequest) ProtoMessage 

func (*GetShardSplitPointsRequest) ProtoMessage()

func (*GetShardSplitPointsRequest) ProtoReflect 

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

func (*GetShardSplitPointsRequest) Reset 

func (x *GetShardSplitPointsRequest) Reset()

func (*GetShardSplitPointsRequest) String 

func (x *GetShardSplitPointsRequest) String() string

type GetShardSplitPointsResponse 

type GetShardSplitPointsResponse struct {
	SplitPoints []string `protobuf:"bytes,1,rep,name=SplitPoints" json:"SplitPoints,omitempty"`
	Err         *string  `protobuf:"bytes,2,opt,name=Err" json:"Err,omitempty"`
	// contains filtered or unexported fields
}

func (*GetShardSplitPointsResponse) Descriptor deprecated 

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

Deprecated: Use GetShardSplitPointsResponse.ProtoReflect.Descriptor instead.

func (*GetShardSplitPointsResponse) GetErr 

func (x *GetShardSplitPointsResponse) GetErr() string

func (*GetShardSplitPointsResponse) GetSplitPoints 

func (x *GetShardSplitPointsResponse) GetSplitPoints() []string

func (*GetShardSplitPointsResponse) ProtoMessage 

func (*GetShardSplitPointsResponse) ProtoMessage()

func (*GetShardSplitPointsResponse) ProtoReflect 

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

func (*GetShardSplitPointsResponse) Reset 

func (x *GetShardSplitPointsResponse) Reset()

func (*GetShardSplitPointsResponse) String 

func (x *GetShardSplitPointsResponse) String() string

type IndexPair 

type IndexPair struct {
	NoClearIndex *uint64 `protobuf:"varint,1,req,name=NoClearIndex" json:"NoClearIndex,omitempty"`
	ToClearIndex *uint64 `protobuf:"varint,2,req,name=ToClearIndex" json:"ToClearIndex,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexPair) Descriptor deprecated 

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

Deprecated: Use IndexPair.ProtoReflect.Descriptor instead.

func (*IndexPair) GetNoClearIndex 

func (x *IndexPair) GetNoClearIndex() uint64

func (*IndexPair) GetToClearIndex 

func (x *IndexPair) GetToClearIndex() uint64

func (*IndexPair) ProtoMessage 

func (*IndexPair) ProtoMessage()

func (*IndexPair) ProtoReflect 

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

func (*IndexPair) Reset 

func (x *IndexPair) Reset()

func (*IndexPair) String 

func (x *IndexPair) String() string

type KillQueryRequest 

type KillQueryRequest struct {
	QueryID *uint64 `protobuf:"varint,1,req,name=QueryID" json:"QueryID,omitempty"`
	// contains filtered or unexported fields
}

func (*KillQueryRequest) Descriptor deprecated 

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

Deprecated: Use KillQueryRequest.ProtoReflect.Descriptor instead.

func (*KillQueryRequest) GetQueryID 

func (x *KillQueryRequest) GetQueryID() uint64

func (*KillQueryRequest) ProtoMessage 

func (*KillQueryRequest) ProtoMessage()

func (*KillQueryRequest) ProtoReflect 

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

func (*KillQueryRequest) Reset 

func (x *KillQueryRequest) Reset()

func (*KillQueryRequest) String 

func (x *KillQueryRequest) String() string

type KillQueryResponse 

type KillQueryResponse struct {
	ErrCode *uint32 `protobuf:"varint,1,opt,name=ErrCode" json:"ErrCode,omitempty"`
	ErrMsg  *string `protobuf:"bytes,2,opt,name=ErrMsg" json:"ErrMsg,omitempty"`
	// contains filtered or unexported fields
}

func (*KillQueryResponse) Descriptor deprecated 

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

Deprecated: Use KillQueryResponse.ProtoReflect.Descriptor instead.

func (*KillQueryResponse) GetErrCode 

func (x *KillQueryResponse) GetErrCode() uint32

func (*KillQueryResponse) GetErrMsg 

func (x *KillQueryResponse) GetErrMsg() string

func (*KillQueryResponse) ProtoMessage 

func (*KillQueryResponse) ProtoMessage()

func (*KillQueryResponse) ProtoReflect 

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

func (*KillQueryResponse) Reset 

func (x *KillQueryResponse) Reset()

func (*KillQueryResponse) String 

func (x *KillQueryResponse) String() string

type MapTagKeys 

type MapTagKeys struct {
	Measurement *string  `protobuf:"bytes,1,req,name=Measurement" json:"Measurement,omitempty"`
	Keys        []string `protobuf:"bytes,2,rep,name=Keys" json:"Keys,omitempty"`
	// contains filtered or unexported fields
}

func (*MapTagKeys) Descriptor deprecated 

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

Deprecated: Use MapTagKeys.ProtoReflect.Descriptor instead.

func (*MapTagKeys) GetKeys 

func (x *MapTagKeys) GetKeys() []string

func (*MapTagKeys) GetMeasurement 

func (x *MapTagKeys) GetMeasurement() string

func (*MapTagKeys) ProtoMessage 

func (*MapTagKeys) ProtoMessage()

func (*MapTagKeys) ProtoReflect 

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

func (*MapTagKeys) Reset 

func (x *MapTagKeys) Reset()

func (*MapTagKeys) String 

func (x *MapTagKeys) String() string

type Pair 

type Pair struct {
	IndexInfo *IndexPair   `protobuf:"bytes,1,req,name=indexInfo" json:"indexInfo,omitempty"`
	ShardInfo []*ShardPair `protobuf:"bytes,2,rep,name=shardInfo" json:"shardInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*Pair) Descriptor deprecated 

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

Deprecated: Use Pair.ProtoReflect.Descriptor instead.

func (*Pair) GetIndexInfo 

func (x *Pair) GetIndexInfo() *IndexPair

func (*Pair) GetShardInfo 

func (x *Pair) GetShardInfo() []*ShardPair

func (*Pair) ProtoMessage 

func (*Pair) ProtoMessage()

func (*Pair) ProtoReflect 

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

func (*Pair) Reset 

func (x *Pair) Reset()

func (*Pair) String 

func (x *Pair) String() string

type PtRequest 

type PtRequest struct {
	Pt          *proto.DbPt `protobuf:"bytes,1,req,name=Pt" json:"Pt,omitempty"`
	MigrateType *int32      `protobuf:"varint,2,req,name=MigrateType" json:"MigrateType,omitempty"`
	OpId        *uint64     `protobuf:"varint,3,req,name=OpId" json:"OpId,omitempty"`
	AliveConnId *uint64     `protobuf:"varint,4,opt,name=AliveConnId" json:"AliveConnId,omitempty"`
	// contains filtered or unexported fields
}

func (*PtRequest) Descriptor deprecated 

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

Deprecated: Use PtRequest.ProtoReflect.Descriptor instead.

func (*PtRequest) GetAliveConnId 

func (x *PtRequest) GetAliveConnId() uint64

func (*PtRequest) GetMigrateType 

func (x *PtRequest) GetMigrateType() int32

func (*PtRequest) GetOpId 

func (x *PtRequest) GetOpId() uint64

func (*PtRequest) GetPt 

func (x *PtRequest) GetPt() *proto.DbPt

func (*PtRequest) ProtoMessage 

func (*PtRequest) ProtoMessage()

func (*PtRequest) ProtoReflect 

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

func (*PtRequest) Reset 

func (x *PtRequest) Reset()

func (*PtRequest) String 

func (x *PtRequest) String() string

type PtResponse 

type PtResponse struct {
	Err *string `protobuf:"bytes,1,opt,name=Err" json:"Err,omitempty"`
	// contains filtered or unexported fields
}

func (*PtResponse) Descriptor deprecated 

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

Deprecated: Use PtResponse.ProtoReflect.Descriptor instead.

func (*PtResponse) GetErr 

func (x *PtResponse) GetErr() string

func (*PtResponse) ProtoMessage 

func (*PtResponse) ProtoMessage()

func (*PtResponse) ProtoReflect 

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

func (*PtResponse) Reset 

func (x *PtResponse) Reset()

func (*PtResponse) String 

func (x *PtResponse) String() string

type QueryExeInfo 

type QueryExeInfo struct {
	QueryID   *uint64 `protobuf:"varint,1,req,name=QueryID" json:"QueryID,omitempty"`
	Stmt      *string `protobuf:"bytes,2,req,name=Stmt" json:"Stmt,omitempty"`
	Database  *string `protobuf:"bytes,3,req,name=Database" json:"Database,omitempty"`
	BeginTime *int64  `protobuf:"varint,4,req,name=BeginTime" json:"BeginTime,omitempty"`
	RunState  *int32  `protobuf:"varint,5,req,name=RunState" json:"RunState,omitempty"`
	PtID      *uint32 `protobuf:"varint,6,req,name=PtID" json:"PtID,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryExeInfo) Descriptor deprecated 

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

Deprecated: Use QueryExeInfo.ProtoReflect.Descriptor instead.

func (*QueryExeInfo) GetBeginTime 

func (x *QueryExeInfo) GetBeginTime() int64

func (*QueryExeInfo) GetDatabase 

func (x *QueryExeInfo) GetDatabase() string

func (*QueryExeInfo) GetPtID 

func (x *QueryExeInfo) GetPtID() uint32

func (*QueryExeInfo) GetQueryID 

func (x *QueryExeInfo) GetQueryID() uint64

func (*QueryExeInfo) GetRunState 

func (x *QueryExeInfo) GetRunState() int32

func (*QueryExeInfo) GetStmt 

func (x *QueryExeInfo) GetStmt() string

func (*QueryExeInfo) ProtoMessage 

func (*QueryExeInfo) ProtoMessage()

func (*QueryExeInfo) ProtoReflect 

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

func (*QueryExeInfo) Reset 

func (x *QueryExeInfo) Reset()

func (*QueryExeInfo) String 

func (x *QueryExeInfo) String() string

type RaftMessagesRequest 

type RaftMessagesRequest struct {
	Database     *string `protobuf:"bytes,1,opt,name=Database" json:"Database,omitempty"`
	PtId         *uint32 `protobuf:"varint,2,opt,name=PtId" json:"PtId,omitempty"`
	RaftMessages []byte  `protobuf:"bytes,3,opt,name=RaftMessages" json:"RaftMessages,omitempty"`
	// contains filtered or unexported fields
}

func (*RaftMessagesRequest) Descriptor deprecated 

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

Deprecated: Use RaftMessagesRequest.ProtoReflect.Descriptor instead.

func (*RaftMessagesRequest) GetDatabase 

func (x *RaftMessagesRequest) GetDatabase() string

func (*RaftMessagesRequest) GetPtId 

func (x *RaftMessagesRequest) GetPtId() uint32

func (*RaftMessagesRequest) GetRaftMessages 

func (x *RaftMessagesRequest) GetRaftMessages() []byte

func (*RaftMessagesRequest) ProtoMessage 

func (*RaftMessagesRequest) ProtoMessage()

func (*RaftMessagesRequest) ProtoReflect 

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

func (*RaftMessagesRequest) Reset 

func (x *RaftMessagesRequest) Reset()

func (*RaftMessagesRequest) String 

func (x *RaftMessagesRequest) String() string

type RaftMessagesResponse 

type RaftMessagesResponse struct {
	ErrMsg *string `protobuf:"bytes,1,opt,name=ErrMsg" json:"ErrMsg,omitempty"`
	// contains filtered or unexported fields
}

func (*RaftMessagesResponse) Descriptor deprecated 

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

Deprecated: Use RaftMessagesResponse.ProtoReflect.Descriptor instead.

func (*RaftMessagesResponse) GetErrMsg 

func (x *RaftMessagesResponse) GetErrMsg() string

func (*RaftMessagesResponse) ProtoMessage 

func (*RaftMessagesResponse) ProtoMessage()

func (*RaftMessagesResponse) ProtoReflect 

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

func (*RaftMessagesResponse) Reset 

func (x *RaftMessagesResponse) Reset()

func (*RaftMessagesResponse) String 

func (x *RaftMessagesResponse) String() string

type SegregateNodeRequest 

type SegregateNodeRequest struct {
	NodeId *uint64 `protobuf:"varint,1,req,name=NodeId" json:"NodeId,omitempty"`
	// contains filtered or unexported fields
}

func (*SegregateNodeRequest) Descriptor deprecated 

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

Deprecated: Use SegregateNodeRequest.ProtoReflect.Descriptor instead.

func (*SegregateNodeRequest) GetNodeId 

func (x *SegregateNodeRequest) GetNodeId() uint64

func (*SegregateNodeRequest) ProtoMessage 

func (*SegregateNodeRequest) ProtoMessage()

func (*SegregateNodeRequest) ProtoReflect 

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

func (*SegregateNodeRequest) Reset 

func (x *SegregateNodeRequest) Reset()

func (*SegregateNodeRequest) String 

func (x *SegregateNodeRequest) String() string

type SegregateNodeResponse 

type SegregateNodeResponse struct {
	Err *string `protobuf:"bytes,1,opt,name=Err" json:"Err,omitempty"`
	// contains filtered or unexported fields
}

func (*SegregateNodeResponse) Descriptor deprecated 

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

Deprecated: Use SegregateNodeResponse.ProtoReflect.Descriptor instead.

func (*SegregateNodeResponse) GetErr 

func (x *SegregateNodeResponse) GetErr() string

func (*SegregateNodeResponse) ProtoMessage 

func (*SegregateNodeResponse) ProtoMessage()

func (*SegregateNodeResponse) ProtoReflect 

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

func (*SegregateNodeResponse) Reset 

func (x *SegregateNodeResponse) Reset()

func (*SegregateNodeResponse) String 

func (x *SegregateNodeResponse) String() string

type SeriesKeysRequest 

type SeriesKeysRequest struct {
	Db           *string  `protobuf:"bytes,1,req,name=Db" json:"Db,omitempty"`
	PtIDs        []uint32 `protobuf:"varint,2,rep,name=PtIDs" json:"PtIDs,omitempty"`
	Measurements []string `protobuf:"bytes,3,rep,name=Measurements" json:"Measurements,omitempty"`
	Condition    *string  `protobuf:"bytes,4,opt,name=condition" json:"condition,omitempty"`
	Exact        *bool    `protobuf:"varint,5,opt,name=Exact" json:"Exact,omitempty"`
	// contains filtered or unexported fields
}

func (*SeriesKeysRequest) Descriptor deprecated 

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

Deprecated: Use SeriesKeysRequest.ProtoReflect.Descriptor instead.

func (*SeriesKeysRequest) GetCondition 

func (x *SeriesKeysRequest) GetCondition() string

func (*SeriesKeysRequest) GetDb 

func (x *SeriesKeysRequest) GetDb() string

func (*SeriesKeysRequest) GetExact 

func (x *SeriesKeysRequest) GetExact() bool

func (*SeriesKeysRequest) GetMeasurements 

func (x *SeriesKeysRequest) GetMeasurements() []string

func (*SeriesKeysRequest) GetPtIDs 

func (x *SeriesKeysRequest) GetPtIDs() []uint32

func (*SeriesKeysRequest) ProtoMessage 

func (*SeriesKeysRequest) ProtoMessage()

func (*SeriesKeysRequest) ProtoReflect 

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

func (*SeriesKeysRequest) Reset 

func (x *SeriesKeysRequest) Reset()

func (*SeriesKeysRequest) String 

func (x *SeriesKeysRequest) String() string

type SeriesKeysResponse 

type SeriesKeysResponse struct {
	Series []string `protobuf:"bytes,1,rep,name=Series" json:"Series,omitempty"`
	Err    *string  `protobuf:"bytes,2,opt,name=Err" json:"Err,omitempty"`
	// contains filtered or unexported fields
}

func (*SeriesKeysResponse) Descriptor deprecated 

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

Deprecated: Use SeriesKeysResponse.ProtoReflect.Descriptor instead.

func (*SeriesKeysResponse) GetErr 

func (x *SeriesKeysResponse) GetErr() string

func (*SeriesKeysResponse) GetSeries 

func (x *SeriesKeysResponse) GetSeries() []string

func (*SeriesKeysResponse) ProtoMessage 

func (*SeriesKeysResponse) ProtoMessage()

func (*SeriesKeysResponse) ProtoReflect 

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

func (*SeriesKeysResponse) Reset 

func (x *SeriesKeysResponse) Reset()

func (*SeriesKeysResponse) String 

func (x *SeriesKeysResponse) String() string

type ShardPair 

type ShardPair struct {
	NoClearShard *uint64 `protobuf:"varint,1,req,name=NoClearShard" json:"NoClearShard,omitempty"`
	ToClearShard *uint64 `protobuf:"varint,2,req,name=ToClearShard" json:"ToClearShard,omitempty"`
	// contains filtered or unexported fields
}

func (*ShardPair) Descriptor deprecated 

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

Deprecated: Use ShardPair.ProtoReflect.Descriptor instead.

func (*ShardPair) GetNoClearShard 

func (x *ShardPair) GetNoClearShard() uint64

func (*ShardPair) GetToClearShard 

func (x *ShardPair) GetToClearShard() uint64

func (*ShardPair) ProtoMessage 

func (*ShardPair) ProtoMessage()

func (*ShardPair) ProtoReflect 

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

func (*ShardPair) Reset 

func (x *ShardPair) Reset()

func (*ShardPair) String 

func (x *ShardPair) String() string

type ShowLastIndexRequest 

type ShowLastIndexRequest struct {
	Database *string  `protobuf:"bytes,1,req,name=Database" json:"Database,omitempty"`
	PtIds    []uint32 `protobuf:"varint,2,rep,name=PtIds" json:"PtIds,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowLastIndexRequest) Descriptor deprecated 

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

Deprecated: Use ShowLastIndexRequest.ProtoReflect.Descriptor instead.

func (*ShowLastIndexRequest) GetDatabase 

func (x *ShowLastIndexRequest) GetDatabase() string

func (*ShowLastIndexRequest) GetPtIds 

func (x *ShowLastIndexRequest) GetPtIds() []uint32

func (*ShowLastIndexRequest) ProtoMessage 

func (*ShowLastIndexRequest) ProtoMessage()

func (*ShowLastIndexRequest) ProtoReflect 

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

func (*ShowLastIndexRequest) Reset 

func (x *ShowLastIndexRequest) Reset()

func (*ShowLastIndexRequest) String 

func (x *ShowLastIndexRequest) String() string

type ShowQueriesResponse 

type ShowQueriesResponse struct {
	QueryExeInfos []*QueryExeInfo `protobuf:"bytes,1,rep,name=QueryExeInfos" json:"QueryExeInfos,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowQueriesResponse) Descriptor deprecated 

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

Deprecated: Use ShowQueriesResponse.ProtoReflect.Descriptor instead.

func (*ShowQueriesResponse) GetQueryExeInfos 

func (x *ShowQueriesResponse) GetQueryExeInfos() []*QueryExeInfo

func (*ShowQueriesResponse) ProtoMessage 

func (*ShowQueriesResponse) ProtoMessage()

func (*ShowQueriesResponse) ProtoReflect 

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

func (*ShowQueriesResponse) Reset 

func (x *ShowQueriesResponse) Reset()

func (*ShowQueriesResponse) String 

func (x *ShowQueriesResponse) String() string

type ShowTagKeysRequest 

type ShowTagKeysRequest struct {
	Db           *string  `protobuf:"bytes,1,req,name=Db" json:"Db,omitempty"`
	PtIDs        []uint32 `protobuf:"varint,2,rep,name=PtIDs" json:"PtIDs,omitempty"`
	Measurements []string `protobuf:"bytes,3,rep,name=Measurements" json:"Measurements,omitempty"`
	Condition    *string  `protobuf:"bytes,4,opt,name=condition" json:"condition,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowTagKeysRequest) Descriptor deprecated 

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

Deprecated: Use ShowTagKeysRequest.ProtoReflect.Descriptor instead.

func (*ShowTagKeysRequest) GetCondition 

func (x *ShowTagKeysRequest) GetCondition() string

func (*ShowTagKeysRequest) GetDb 

func (x *ShowTagKeysRequest) GetDb() string

func (*ShowTagKeysRequest) GetMeasurements 

func (x *ShowTagKeysRequest) GetMeasurements() []string

func (*ShowTagKeysRequest) GetPtIDs 

func (x *ShowTagKeysRequest) GetPtIDs() []uint32

func (*ShowTagKeysRequest) ProtoMessage 

func (*ShowTagKeysRequest) ProtoMessage()

func (*ShowTagKeysRequest) ProtoReflect 

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

func (*ShowTagKeysRequest) Reset 

func (x *ShowTagKeysRequest) Reset()

func (*ShowTagKeysRequest) String 

func (x *ShowTagKeysRequest) String() string

type ShowTagKeysResponse 

type ShowTagKeysResponse struct {
	TagKeys []string `protobuf:"bytes,1,rep,name=TagKeys" json:"TagKeys,omitempty"`
	Err     *string  `protobuf:"bytes,2,opt,name=Err" json:"Err,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowTagKeysResponse) Descriptor deprecated 

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

Deprecated: Use ShowTagKeysResponse.ProtoReflect.Descriptor instead.

func (*ShowTagKeysResponse) GetErr 

func (x *ShowTagKeysResponse) GetErr() string

func (*ShowTagKeysResponse) GetTagKeys 

func (x *ShowTagKeysResponse) GetTagKeys() []string

func (*ShowTagKeysResponse) ProtoMessage 

func (*ShowTagKeysResponse) ProtoMessage()

func (*ShowTagKeysResponse) ProtoReflect 

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

func (*ShowTagKeysResponse) Reset 

func (x *ShowTagKeysResponse) Reset()

func (*ShowTagKeysResponse) String 

func (x *ShowTagKeysResponse) String() string

type ShowTagValuesRequest 

type ShowTagValuesRequest struct {
	Db        *string       `protobuf:"bytes,1,req,name=Db" json:"Db,omitempty"`
	PtIDs     []uint32      `protobuf:"varint,2,rep,name=PtIDs" json:"PtIDs,omitempty"`
	TagKeys   []*MapTagKeys `protobuf:"bytes,3,rep,name=TagKeys" json:"TagKeys,omitempty"`
	Condition *string       `protobuf:"bytes,4,opt,name=Condition" json:"Condition,omitempty"`
	Limit     *int32        `protobuf:"varint,5,opt,name=Limit" json:"Limit,omitempty"`
	Exact     *bool         `protobuf:"varint,6,opt,name=Exact" json:"Exact,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowTagValuesRequest) Descriptor deprecated 

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

Deprecated: Use ShowTagValuesRequest.ProtoReflect.Descriptor instead.

func (*ShowTagValuesRequest) GetCondition 

func (x *ShowTagValuesRequest) GetCondition() string

func (*ShowTagValuesRequest) GetDb 

func (x *ShowTagValuesRequest) GetDb() string

func (*ShowTagValuesRequest) GetExact 

func (x *ShowTagValuesRequest) GetExact() bool

func (*ShowTagValuesRequest) GetLimit 

func (x *ShowTagValuesRequest) GetLimit() int32

func (*ShowTagValuesRequest) GetPtIDs 

func (x *ShowTagValuesRequest) GetPtIDs() []uint32

func (*ShowTagValuesRequest) GetTagKeys 

func (x *ShowTagValuesRequest) GetTagKeys() []*MapTagKeys

func (*ShowTagValuesRequest) ProtoMessage 

func (*ShowTagValuesRequest) ProtoMessage()

func (*ShowTagValuesRequest) ProtoReflect 

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

func (*ShowTagValuesRequest) Reset 

func (x *ShowTagValuesRequest) Reset()

func (*ShowTagValuesRequest) String 

func (x *ShowTagValuesRequest) String() string

type ShowTagValuesResponse 

type ShowTagValuesResponse struct {
	Err    *string           `protobuf:"bytes,1,opt,name=Err" json:"Err,omitempty"`
	Values []*TagValuesSlice `protobuf:"bytes,2,rep,name=Values" json:"Values,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowTagValuesResponse) Descriptor deprecated 

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

Deprecated: Use ShowTagValuesResponse.ProtoReflect.Descriptor instead.

func (*ShowTagValuesResponse) GetErr 

func (x *ShowTagValuesResponse) GetErr() string

func (*ShowTagValuesResponse) GetValues 

func (x *ShowTagValuesResponse) GetValues() []*TagValuesSlice

func (*ShowTagValuesResponse) ProtoMessage 

func (*ShowTagValuesResponse) ProtoMessage()

func (*ShowTagValuesResponse) ProtoReflect 

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

func (*ShowTagValuesResponse) Reset 

func (x *ShowTagValuesResponse) Reset()

func (*ShowTagValuesResponse) String 

func (x *ShowTagValuesResponse) String() string

type SysCtrlRequest 

type SysCtrlRequest struct {
	Mod   *string           `protobuf:"bytes,1,req,name=Mod" json:"Mod,omitempty"`
	Param map[string]string `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SysCtrlRequest) Descriptor deprecated 

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

Deprecated: Use SysCtrlRequest.ProtoReflect.Descriptor instead.

func (*SysCtrlRequest) GetMod 

func (x *SysCtrlRequest) GetMod() string

func (*SysCtrlRequest) GetParam 

func (x *SysCtrlRequest) GetParam() map[string]string

func (*SysCtrlRequest) ProtoMessage 

func (*SysCtrlRequest) ProtoMessage()

func (*SysCtrlRequest) ProtoReflect 

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

func (*SysCtrlRequest) Reset 

func (x *SysCtrlRequest) Reset()

func (*SysCtrlRequest) String 

func (x *SysCtrlRequest) String() string

type SysCtrlResponse 

type SysCtrlResponse struct {
	Err    *string           `protobuf:"bytes,1,req,name=Err" json:"Err,omitempty"`
	Result map[string]string `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SysCtrlResponse) Descriptor deprecated 

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

Deprecated: Use SysCtrlResponse.ProtoReflect.Descriptor instead.

func (*SysCtrlResponse) GetErr 

func (x *SysCtrlResponse) GetErr() string

func (*SysCtrlResponse) GetResult 

func (x *SysCtrlResponse) GetResult() map[string]string

func (*SysCtrlResponse) ProtoMessage 

func (*SysCtrlResponse) ProtoMessage()

func (*SysCtrlResponse) ProtoReflect 

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

func (*SysCtrlResponse) Reset 

func (x *SysCtrlResponse) Reset()

func (*SysCtrlResponse) String 

func (x *SysCtrlResponse) String() string

type TagValuesSlice 

type TagValuesSlice struct {
	Measurement *string  `protobuf:"bytes,1,req,name=Measurement" json:"Measurement,omitempty"`
	Keys        []string `protobuf:"bytes,2,rep,name=Keys" json:"Keys,omitempty"`
	Values      []string `protobuf:"bytes,3,rep,name=Values" json:"Values,omitempty"`
	// contains filtered or unexported fields
}

func (*TagValuesSlice) Descriptor deprecated 

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

Deprecated: Use TagValuesSlice.ProtoReflect.Descriptor instead.

func (*TagValuesSlice) GetKeys 

func (x *TagValuesSlice) GetKeys() []string

func (*TagValuesSlice) GetMeasurement 

func (x *TagValuesSlice) GetMeasurement() string

func (*TagValuesSlice) GetValues 

func (x *TagValuesSlice) GetValues() []string

func (*TagValuesSlice) ProtoMessage 

func (*TagValuesSlice) ProtoMessage()

func (*TagValuesSlice) ProtoReflect 

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

func (*TagValuesSlice) Reset 

func (x *TagValuesSlice) Reset()

func (*TagValuesSlice) String 

func (x *TagValuesSlice) String() string

type TransferLeadershipRequest 

type TransferLeadershipRequest struct {
	NodeId        *uint64 `protobuf:"varint,1,req,name=NodeId" json:"NodeId,omitempty"`
	PtId          *uint32 `protobuf:"varint,2,req,name=PtId" json:"PtId,omitempty"`
	Database      *string `protobuf:"bytes,3,req,name=Database" json:"Database,omitempty"`
	NewMasterPtId *uint32 `protobuf:"varint,4,req,name=newMasterPtId" json:"newMasterPtId,omitempty"`
	// contains filtered or unexported fields
}

func (*TransferLeadershipRequest) Descriptor deprecated 

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

Deprecated: Use TransferLeadershipRequest.ProtoReflect.Descriptor instead.

func (*TransferLeadershipRequest) GetDatabase 

func (x *TransferLeadershipRequest) GetDatabase() string

func (*TransferLeadershipRequest) GetNewMasterPtId 

func (x *TransferLeadershipRequest) GetNewMasterPtId() uint32

func (*TransferLeadershipRequest) GetNodeId 

func (x *TransferLeadershipRequest) GetNodeId() uint64

func (*TransferLeadershipRequest) GetPtId 

func (x *TransferLeadershipRequest) GetPtId() uint32

func (*TransferLeadershipRequest) ProtoMessage 

func (*TransferLeadershipRequest) ProtoMessage()

func (*TransferLeadershipRequest) ProtoReflect 

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

func (*TransferLeadershipRequest) Reset 

func (x *TransferLeadershipRequest) Reset()

func (*TransferLeadershipRequest) String 

func (x *TransferLeadershipRequest) String() string

type TransferLeadershipResponse 

type TransferLeadershipResponse struct {
	Err *string `protobuf:"bytes,1,opt,name=Err" json:"Err,omitempty"`
	// contains filtered or unexported fields
}

func (*TransferLeadershipResponse) Descriptor deprecated 

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

Deprecated: Use TransferLeadershipResponse.ProtoReflect.Descriptor instead.

func (*TransferLeadershipResponse) GetErr 

func (x *TransferLeadershipResponse) GetErr() string

func (*TransferLeadershipResponse) ProtoMessage 

func (*TransferLeadershipResponse) ProtoMessage()

func (*TransferLeadershipResponse) ProtoReflect 

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

func (*TransferLeadershipResponse) Reset 

func (x *TransferLeadershipResponse) Reset()

func (*TransferLeadershipResponse) String 

func (x *TransferLeadershipResponse) 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.