netstorage_data

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Feb 29, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateDataBaseRequest) Descriptor 

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

func (*CreateDataBaseRequest) GetDb 

func (m *CreateDataBaseRequest) GetDb() string

func (*CreateDataBaseRequest) GetPt 

func (m *CreateDataBaseRequest) GetPt() uint32

func (*CreateDataBaseRequest) GetRp 

func (m *CreateDataBaseRequest) GetRp() string

func (*CreateDataBaseRequest) ProtoMessage 

func (*CreateDataBaseRequest) ProtoMessage()

func (*CreateDataBaseRequest) Reset 

func (m *CreateDataBaseRequest) Reset()

func (*CreateDataBaseRequest) String 

func (m *CreateDataBaseRequest) String() string

func (*CreateDataBaseRequest) XXX_DiscardUnknown 

func (m *CreateDataBaseRequest) XXX_DiscardUnknown()

func (*CreateDataBaseRequest) XXX_Marshal 

func (m *CreateDataBaseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateDataBaseRequest) XXX_Merge 

func (m *CreateDataBaseRequest) XXX_Merge(src proto.Message)

func (*CreateDataBaseRequest) XXX_Size 

func (m *CreateDataBaseRequest) XXX_Size() int

func (*CreateDataBaseRequest) XXX_Unmarshal 

func (m *CreateDataBaseRequest) XXX_Unmarshal(b []byte) error

type CreateDataBaseResponse 

type CreateDataBaseResponse struct {
	Err                  *string  `protobuf:"bytes,1,opt,name=Err" json:"Err,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateDataBaseResponse) Descriptor 

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

func (*CreateDataBaseResponse) GetErr 

func (m *CreateDataBaseResponse) GetErr() string

func (*CreateDataBaseResponse) ProtoMessage 

func (*CreateDataBaseResponse) ProtoMessage()

func (*CreateDataBaseResponse) Reset 

func (m *CreateDataBaseResponse) Reset()

func (*CreateDataBaseResponse) String 

func (m *CreateDataBaseResponse) String() string

func (*CreateDataBaseResponse) XXX_DiscardUnknown 

func (m *CreateDataBaseResponse) XXX_DiscardUnknown()

func (*CreateDataBaseResponse) XXX_Marshal 

func (m *CreateDataBaseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateDataBaseResponse) XXX_Merge 

func (m *CreateDataBaseResponse) XXX_Merge(src proto.Message)

func (*CreateDataBaseResponse) XXX_Size 

func (m *CreateDataBaseResponse) XXX_Size() int

func (*CreateDataBaseResponse) XXX_Unmarshal 

func (m *CreateDataBaseResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) GetDB 

func (m *DeleteRequest) GetDB() string

func (*DeleteRequest) GetDeleteType 

func (m *DeleteRequest) GetDeleteType() int32

func (*DeleteRequest) GetMst 

func (m *DeleteRequest) GetMst() string

func (*DeleteRequest) GetPtId 

func (m *DeleteRequest) GetPtId() uint32

func (*DeleteRequest) GetRp 

func (m *DeleteRequest) GetRp() string

func (*DeleteRequest) GetShardIDs 

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

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

func (*DeleteRequest) XXX_DiscardUnknown 

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal 

func (m *DeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteRequest) XXX_Merge 

func (m *DeleteRequest) XXX_Merge(src proto.Message)

func (*DeleteRequest) XXX_Size 

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal 

func (m *DeleteRequest) XXX_Unmarshal(b []byte) error

type DeleteResponse 

type DeleteResponse struct {
	Err                  *string  `protobuf:"bytes,1,opt,name=Err" json:"Err,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteResponse) Descriptor 

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

func (*DeleteResponse) GetErr 

func (m *DeleteResponse) GetErr() string

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset 

func (m *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (m *DeleteResponse) String() string

func (*DeleteResponse) XXX_DiscardUnknown 

func (m *DeleteResponse) XXX_DiscardUnknown()

func (*DeleteResponse) XXX_Marshal 

func (m *DeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteResponse) XXX_Merge 

func (m *DeleteResponse) XXX_Merge(src proto.Message)

func (*DeleteResponse) XXX_Size 

func (m *DeleteResponse) XXX_Size() int

func (*DeleteResponse) XXX_Unmarshal 

func (m *DeleteResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ExactCardinalityResponse) Descriptor 

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

func (*ExactCardinalityResponse) GetCardinality 

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

func (*ExactCardinalityResponse) GetErr 

func (m *ExactCardinalityResponse) GetErr() string

func (*ExactCardinalityResponse) ProtoMessage 

func (*ExactCardinalityResponse) ProtoMessage()

func (*ExactCardinalityResponse) Reset 

func (m *ExactCardinalityResponse) Reset()

func (*ExactCardinalityResponse) String 

func (m *ExactCardinalityResponse) String() string

func (*ExactCardinalityResponse) XXX_DiscardUnknown 

func (m *ExactCardinalityResponse) XXX_DiscardUnknown()

func (*ExactCardinalityResponse) XXX_Marshal 

func (m *ExactCardinalityResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExactCardinalityResponse) XXX_Merge 

func (m *ExactCardinalityResponse) XXX_Merge(src proto.Message)

func (*ExactCardinalityResponse) XXX_Size 

func (m *ExactCardinalityResponse) XXX_Size() int

func (*ExactCardinalityResponse) XXX_Unmarshal 

func (m *ExactCardinalityResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetShardSplitPointsRequest) Descriptor 

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

func (*GetShardSplitPointsRequest) GetDB 

func (m *GetShardSplitPointsRequest) GetDB() string

func (*GetShardSplitPointsRequest) GetIdxes 

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

func (*GetShardSplitPointsRequest) GetPtID 

func (m *GetShardSplitPointsRequest) GetPtID() uint32

func (*GetShardSplitPointsRequest) GetShardID 

func (m *GetShardSplitPointsRequest) GetShardID() uint64

func (*GetShardSplitPointsRequest) ProtoMessage 

func (*GetShardSplitPointsRequest) ProtoMessage()

func (*GetShardSplitPointsRequest) Reset 

func (m *GetShardSplitPointsRequest) Reset()

func (*GetShardSplitPointsRequest) String 

func (m *GetShardSplitPointsRequest) String() string

func (*GetShardSplitPointsRequest) XXX_DiscardUnknown 

func (m *GetShardSplitPointsRequest) XXX_DiscardUnknown()

func (*GetShardSplitPointsRequest) XXX_Marshal 

func (m *GetShardSplitPointsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetShardSplitPointsRequest) XXX_Merge 

func (m *GetShardSplitPointsRequest) XXX_Merge(src proto.Message)

func (*GetShardSplitPointsRequest) XXX_Size 

func (m *GetShardSplitPointsRequest) XXX_Size() int

func (*GetShardSplitPointsRequest) XXX_Unmarshal 

func (m *GetShardSplitPointsRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetShardSplitPointsResponse) Descriptor 

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

func (*GetShardSplitPointsResponse) GetErr 

func (m *GetShardSplitPointsResponse) GetErr() string

func (*GetShardSplitPointsResponse) GetSplitPoints 

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

func (*GetShardSplitPointsResponse) ProtoMessage 

func (*GetShardSplitPointsResponse) ProtoMessage()

func (*GetShardSplitPointsResponse) Reset 

func (m *GetShardSplitPointsResponse) Reset()

func (*GetShardSplitPointsResponse) String 

func (m *GetShardSplitPointsResponse) String() string

func (*GetShardSplitPointsResponse) XXX_DiscardUnknown 

func (m *GetShardSplitPointsResponse) XXX_DiscardUnknown()

func (*GetShardSplitPointsResponse) XXX_Marshal 

func (m *GetShardSplitPointsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetShardSplitPointsResponse) XXX_Merge 

func (m *GetShardSplitPointsResponse) XXX_Merge(src proto.Message)

func (*GetShardSplitPointsResponse) XXX_Size 

func (m *GetShardSplitPointsResponse) XXX_Size() int

func (*GetShardSplitPointsResponse) XXX_Unmarshal 

func (m *GetShardSplitPointsResponse) XXX_Unmarshal(b []byte) error

type KillQueryRequest added in v1.1.0 

type KillQueryRequest struct {
	QueryID              *uint64  `protobuf:"varint,1,req,name=QueryID" json:"QueryID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KillQueryRequest) Descriptor added in v1.1.0 

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

func (*KillQueryRequest) GetQueryID added in v1.1.0 

func (m *KillQueryRequest) GetQueryID() uint64

func (*KillQueryRequest) ProtoMessage added in v1.1.0 

func (*KillQueryRequest) ProtoMessage()

func (*KillQueryRequest) Reset added in v1.1.0 

func (m *KillQueryRequest) Reset()

func (*KillQueryRequest) String added in v1.1.0 

func (m *KillQueryRequest) String() string

func (*KillQueryRequest) XXX_DiscardUnknown added in v1.1.0 

func (m *KillQueryRequest) XXX_DiscardUnknown()

func (*KillQueryRequest) XXX_Marshal added in v1.1.0 

func (m *KillQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KillQueryRequest) XXX_Merge added in v1.1.0 

func (m *KillQueryRequest) XXX_Merge(src proto.Message)

func (*KillQueryRequest) XXX_Size added in v1.1.0 

func (m *KillQueryRequest) XXX_Size() int

func (*KillQueryRequest) XXX_Unmarshal added in v1.1.0 

func (m *KillQueryRequest) XXX_Unmarshal(b []byte) error

type KillQueryResponse added in v1.1.0 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KillQueryResponse) Descriptor added in v1.1.0 

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

func (*KillQueryResponse) GetErrCode added in v1.1.0 

func (m *KillQueryResponse) GetErrCode() uint32

func (*KillQueryResponse) GetErrMsg added in v1.1.0 

func (m *KillQueryResponse) GetErrMsg() string

func (*KillQueryResponse) ProtoMessage added in v1.1.0 

func (*KillQueryResponse) ProtoMessage()

func (*KillQueryResponse) Reset added in v1.1.0 

func (m *KillQueryResponse) Reset()

func (*KillQueryResponse) String added in v1.1.0 

func (m *KillQueryResponse) String() string

func (*KillQueryResponse) XXX_DiscardUnknown added in v1.1.0 

func (m *KillQueryResponse) XXX_DiscardUnknown()

func (*KillQueryResponse) XXX_Marshal added in v1.1.0 

func (m *KillQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KillQueryResponse) XXX_Merge added in v1.1.0 

func (m *KillQueryResponse) XXX_Merge(src proto.Message)

func (*KillQueryResponse) XXX_Size added in v1.1.0 

func (m *KillQueryResponse) XXX_Size() int

func (*KillQueryResponse) XXX_Unmarshal added in v1.1.0 

func (m *KillQueryResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MapTagKeys) Descriptor 

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

func (*MapTagKeys) GetKeys 

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

func (*MapTagKeys) GetMeasurement 

func (m *MapTagKeys) GetMeasurement() string

func (*MapTagKeys) ProtoMessage 

func (*MapTagKeys) ProtoMessage()

func (*MapTagKeys) Reset 

func (m *MapTagKeys) Reset()

func (*MapTagKeys) String 

func (m *MapTagKeys) String() string

func (*MapTagKeys) XXX_DiscardUnknown 

func (m *MapTagKeys) XXX_DiscardUnknown()

func (*MapTagKeys) XXX_Marshal 

func (m *MapTagKeys) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MapTagKeys) XXX_Merge 

func (m *MapTagKeys) XXX_Merge(src proto.Message)

func (*MapTagKeys) XXX_Size 

func (m *MapTagKeys) XXX_Size() int

func (*MapTagKeys) XXX_Unmarshal 

func (m *MapTagKeys) XXX_Unmarshal(b []byte) error

type PtRequest added in v1.0.0 

type PtRequest struct {
	Pt                   *proto1.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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*PtRequest) Descriptor added in v1.0.0 

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

func (*PtRequest) GetAliveConnId added in v1.1.0 

func (m *PtRequest) GetAliveConnId() uint64

func (*PtRequest) GetMigrateType added in v1.0.0 

func (m *PtRequest) GetMigrateType() int32

func (*PtRequest) GetOpId added in v1.0.0 

func (m *PtRequest) GetOpId() uint64

func (*PtRequest) GetPt added in v1.0.0 

func (m *PtRequest) GetPt() *proto1.DbPt

func (*PtRequest) ProtoMessage added in v1.0.0 

func (*PtRequest) ProtoMessage()

func (*PtRequest) Reset added in v1.0.0 

func (m *PtRequest) Reset()

func (*PtRequest) String added in v1.0.0 

func (m *PtRequest) String() string

func (*PtRequest) XXX_DiscardUnknown added in v1.0.0 

func (m *PtRequest) XXX_DiscardUnknown()

func (*PtRequest) XXX_Marshal added in v1.0.0 

func (m *PtRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PtRequest) XXX_Merge added in v1.0.0 

func (m *PtRequest) XXX_Merge(src proto.Message)

func (*PtRequest) XXX_Size added in v1.0.0 

func (m *PtRequest) XXX_Size() int

func (*PtRequest) XXX_Unmarshal added in v1.0.0 

func (m *PtRequest) XXX_Unmarshal(b []byte) error

type PtResponse added in v1.0.0 

type PtResponse struct {
	Err                  *string  `protobuf:"bytes,1,opt,name=Err" json:"Err,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PtResponse) Descriptor added in v1.0.0 

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

func (*PtResponse) GetErr added in v1.0.0 

func (m *PtResponse) GetErr() string

func (*PtResponse) ProtoMessage added in v1.0.0 

func (*PtResponse) ProtoMessage()

func (*PtResponse) Reset added in v1.0.0 

func (m *PtResponse) Reset()

func (*PtResponse) String added in v1.0.0 

func (m *PtResponse) String() string

func (*PtResponse) XXX_DiscardUnknown added in v1.0.0 

func (m *PtResponse) XXX_DiscardUnknown()

func (*PtResponse) XXX_Marshal added in v1.0.0 

func (m *PtResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PtResponse) XXX_Merge added in v1.0.0 

func (m *PtResponse) XXX_Merge(src proto.Message)

func (*PtResponse) XXX_Size added in v1.0.0 

func (m *PtResponse) XXX_Size() int

func (*PtResponse) XXX_Unmarshal added in v1.0.0 

func (m *PtResponse) XXX_Unmarshal(b []byte) error

type QueryExeInfo added in v1.1.0 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueryExeInfo) Descriptor added in v1.1.0 

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

func (*QueryExeInfo) GetBeginTime added in v1.1.0 

func (m *QueryExeInfo) GetBeginTime() int64

func (*QueryExeInfo) GetDatabase added in v1.1.0 

func (m *QueryExeInfo) GetDatabase() string

func (*QueryExeInfo) GetQueryID added in v1.1.0 

func (m *QueryExeInfo) GetQueryID() uint64

func (*QueryExeInfo) GetRunState added in v1.1.0 

func (m *QueryExeInfo) GetRunState() int32

func (*QueryExeInfo) GetStmt added in v1.1.0 

func (m *QueryExeInfo) GetStmt() string

func (*QueryExeInfo) ProtoMessage added in v1.1.0 

func (*QueryExeInfo) ProtoMessage()

func (*QueryExeInfo) Reset added in v1.1.0 

func (m *QueryExeInfo) Reset()

func (*QueryExeInfo) String added in v1.1.0 

func (m *QueryExeInfo) String() string

func (*QueryExeInfo) XXX_DiscardUnknown added in v1.1.0 

func (m *QueryExeInfo) XXX_DiscardUnknown()

func (*QueryExeInfo) XXX_Marshal added in v1.1.0 

func (m *QueryExeInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryExeInfo) XXX_Merge added in v1.1.0 

func (m *QueryExeInfo) XXX_Merge(src proto.Message)

func (*QueryExeInfo) XXX_Size added in v1.1.0 

func (m *QueryExeInfo) XXX_Size() int

func (*QueryExeInfo) XXX_Unmarshal added in v1.1.0 

func (m *QueryExeInfo) XXX_Unmarshal(b []byte) error

type SegregateNodeRequest added in v1.1.1 

type SegregateNodeRequest struct {
	NodeId               *uint64  `protobuf:"varint,1,req,name=NodeId" json:"NodeId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SegregateNodeRequest) Descriptor added in v1.1.1 

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

func (*SegregateNodeRequest) GetNodeId added in v1.1.1 

func (m *SegregateNodeRequest) GetNodeId() uint64

func (*SegregateNodeRequest) ProtoMessage added in v1.1.1 

func (*SegregateNodeRequest) ProtoMessage()

func (*SegregateNodeRequest) Reset added in v1.1.1 

func (m *SegregateNodeRequest) Reset()

func (*SegregateNodeRequest) String added in v1.1.1 

func (m *SegregateNodeRequest) String() string

func (*SegregateNodeRequest) XXX_DiscardUnknown added in v1.1.1 

func (m *SegregateNodeRequest) XXX_DiscardUnknown()

func (*SegregateNodeRequest) XXX_Marshal added in v1.1.1 

func (m *SegregateNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SegregateNodeRequest) XXX_Merge added in v1.1.1 

func (m *SegregateNodeRequest) XXX_Merge(src proto.Message)

func (*SegregateNodeRequest) XXX_Size added in v1.1.1 

func (m *SegregateNodeRequest) XXX_Size() int

func (*SegregateNodeRequest) XXX_Unmarshal added in v1.1.1 

func (m *SegregateNodeRequest) XXX_Unmarshal(b []byte) error

type SegregateNodeResponse added in v1.1.1 

type SegregateNodeResponse struct {
	Err                  *string  `protobuf:"bytes,1,opt,name=Err" json:"Err,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SegregateNodeResponse) Descriptor added in v1.1.1 

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

func (*SegregateNodeResponse) GetErr added in v1.1.1 

func (m *SegregateNodeResponse) GetErr() string

func (*SegregateNodeResponse) ProtoMessage added in v1.1.1 

func (*SegregateNodeResponse) ProtoMessage()

func (*SegregateNodeResponse) Reset added in v1.1.1 

func (m *SegregateNodeResponse) Reset()

func (*SegregateNodeResponse) String added in v1.1.1 

func (m *SegregateNodeResponse) String() string

func (*SegregateNodeResponse) XXX_DiscardUnknown added in v1.1.1 

func (m *SegregateNodeResponse) XXX_DiscardUnknown()

func (*SegregateNodeResponse) XXX_Marshal added in v1.1.1 

func (m *SegregateNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SegregateNodeResponse) XXX_Merge added in v1.1.1 

func (m *SegregateNodeResponse) XXX_Merge(src proto.Message)

func (*SegregateNodeResponse) XXX_Size added in v1.1.1 

func (m *SegregateNodeResponse) XXX_Size() int

func (*SegregateNodeResponse) XXX_Unmarshal added in v1.1.1 

func (m *SegregateNodeResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SeriesKeysRequest) Descriptor 

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

func (*SeriesKeysRequest) GetCondition 

func (m *SeriesKeysRequest) GetCondition() string

func (*SeriesKeysRequest) GetDb 

func (m *SeriesKeysRequest) GetDb() string

func (*SeriesKeysRequest) GetMeasurements 

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

func (*SeriesKeysRequest) GetPtIDs 

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

func (*SeriesKeysRequest) ProtoMessage 

func (*SeriesKeysRequest) ProtoMessage()

func (*SeriesKeysRequest) Reset 

func (m *SeriesKeysRequest) Reset()

func (*SeriesKeysRequest) String 

func (m *SeriesKeysRequest) String() string

func (*SeriesKeysRequest) XXX_DiscardUnknown 

func (m *SeriesKeysRequest) XXX_DiscardUnknown()

func (*SeriesKeysRequest) XXX_Marshal 

func (m *SeriesKeysRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SeriesKeysRequest) XXX_Merge 

func (m *SeriesKeysRequest) XXX_Merge(src proto.Message)

func (*SeriesKeysRequest) XXX_Size 

func (m *SeriesKeysRequest) XXX_Size() int

func (*SeriesKeysRequest) XXX_Unmarshal 

func (m *SeriesKeysRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SeriesKeysResponse) Descriptor 

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

func (*SeriesKeysResponse) GetErr 

func (m *SeriesKeysResponse) GetErr() string

func (*SeriesKeysResponse) GetSeries 

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

func (*SeriesKeysResponse) ProtoMessage 

func (*SeriesKeysResponse) ProtoMessage()

func (*SeriesKeysResponse) Reset 

func (m *SeriesKeysResponse) Reset()

func (*SeriesKeysResponse) String 

func (m *SeriesKeysResponse) String() string

func (*SeriesKeysResponse) XXX_DiscardUnknown 

func (m *SeriesKeysResponse) XXX_DiscardUnknown()

func (*SeriesKeysResponse) XXX_Marshal 

func (m *SeriesKeysResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SeriesKeysResponse) XXX_Merge 

func (m *SeriesKeysResponse) XXX_Merge(src proto.Message)

func (*SeriesKeysResponse) XXX_Size 

func (m *SeriesKeysResponse) XXX_Size() int

func (*SeriesKeysResponse) XXX_Unmarshal 

func (m *SeriesKeysResponse) XXX_Unmarshal(b []byte) error

type ShowQueriesResponse added in v1.1.0 

type ShowQueriesResponse struct {
	QueryExeInfos        []*QueryExeInfo `protobuf:"bytes,1,rep,name=QueryExeInfos" json:"QueryExeInfos,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ShowQueriesResponse) Descriptor added in v1.1.0 

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

func (*ShowQueriesResponse) GetQueryExeInfos added in v1.1.0 

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

func (*ShowQueriesResponse) ProtoMessage added in v1.1.0 

func (*ShowQueriesResponse) ProtoMessage()

func (*ShowQueriesResponse) Reset added in v1.1.0 

func (m *ShowQueriesResponse) Reset()

func (*ShowQueriesResponse) String added in v1.1.0 

func (m *ShowQueriesResponse) String() string

func (*ShowQueriesResponse) XXX_DiscardUnknown added in v1.1.0 

func (m *ShowQueriesResponse) XXX_DiscardUnknown()

func (*ShowQueriesResponse) XXX_Marshal added in v1.1.0 

func (m *ShowQueriesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShowQueriesResponse) XXX_Merge added in v1.1.0 

func (m *ShowQueriesResponse) XXX_Merge(src proto.Message)

func (*ShowQueriesResponse) XXX_Size added in v1.1.0 

func (m *ShowQueriesResponse) XXX_Size() int

func (*ShowQueriesResponse) XXX_Unmarshal added in v1.1.0 

func (m *ShowQueriesResponse) XXX_Unmarshal(b []byte) error

type ShowTagKeysRequest added in v1.2.0 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ShowTagKeysRequest) Descriptor added in v1.2.0 

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

func (*ShowTagKeysRequest) GetCondition added in v1.2.0 

func (m *ShowTagKeysRequest) GetCondition() string

func (*ShowTagKeysRequest) GetDb added in v1.2.0 

func (m *ShowTagKeysRequest) GetDb() string

func (*ShowTagKeysRequest) GetMeasurements added in v1.2.0 

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

func (*ShowTagKeysRequest) GetPtIDs added in v1.2.0 

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

func (*ShowTagKeysRequest) ProtoMessage added in v1.2.0 

func (*ShowTagKeysRequest) ProtoMessage()

func (*ShowTagKeysRequest) Reset added in v1.2.0 

func (m *ShowTagKeysRequest) Reset()

func (*ShowTagKeysRequest) String added in v1.2.0 

func (m *ShowTagKeysRequest) String() string

func (*ShowTagKeysRequest) XXX_DiscardUnknown added in v1.2.0 

func (m *ShowTagKeysRequest) XXX_DiscardUnknown()

func (*ShowTagKeysRequest) XXX_Marshal added in v1.2.0 

func (m *ShowTagKeysRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShowTagKeysRequest) XXX_Merge added in v1.2.0 

func (m *ShowTagKeysRequest) XXX_Merge(src proto.Message)

func (*ShowTagKeysRequest) XXX_Size added in v1.2.0 

func (m *ShowTagKeysRequest) XXX_Size() int

func (*ShowTagKeysRequest) XXX_Unmarshal added in v1.2.0 

func (m *ShowTagKeysRequest) XXX_Unmarshal(b []byte) error

type ShowTagKeysResponse added in v1.2.0 

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ShowTagKeysResponse) Descriptor added in v1.2.0 

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

func (*ShowTagKeysResponse) GetErr added in v1.2.0 

func (m *ShowTagKeysResponse) GetErr() string

func (*ShowTagKeysResponse) GetTagKeys added in v1.2.0 

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

func (*ShowTagKeysResponse) ProtoMessage added in v1.2.0 

func (*ShowTagKeysResponse) ProtoMessage()

func (*ShowTagKeysResponse) Reset added in v1.2.0 

func (m *ShowTagKeysResponse) Reset()

func (*ShowTagKeysResponse) String added in v1.2.0 

func (m *ShowTagKeysResponse) String() string

func (*ShowTagKeysResponse) XXX_DiscardUnknown added in v1.2.0 

func (m *ShowTagKeysResponse) XXX_DiscardUnknown()

func (*ShowTagKeysResponse) XXX_Marshal added in v1.2.0 

func (m *ShowTagKeysResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShowTagKeysResponse) XXX_Merge added in v1.2.0 

func (m *ShowTagKeysResponse) XXX_Merge(src proto.Message)

func (*ShowTagKeysResponse) XXX_Size added in v1.2.0 

func (m *ShowTagKeysResponse) XXX_Size() int

func (*ShowTagKeysResponse) XXX_Unmarshal added in v1.2.0 

func (m *ShowTagKeysResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ShowTagValuesRequest) Descriptor 

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

func (*ShowTagValuesRequest) GetCondition 

func (m *ShowTagValuesRequest) GetCondition() string

func (*ShowTagValuesRequest) GetDb 

func (m *ShowTagValuesRequest) GetDb() string

func (*ShowTagValuesRequest) GetPtIDs 

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

func (*ShowTagValuesRequest) GetTagKeys 

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

func (*ShowTagValuesRequest) ProtoMessage 

func (*ShowTagValuesRequest) ProtoMessage()

func (*ShowTagValuesRequest) Reset 

func (m *ShowTagValuesRequest) Reset()

func (*ShowTagValuesRequest) String 

func (m *ShowTagValuesRequest) String() string

func (*ShowTagValuesRequest) XXX_DiscardUnknown 

func (m *ShowTagValuesRequest) XXX_DiscardUnknown()

func (*ShowTagValuesRequest) XXX_Marshal 

func (m *ShowTagValuesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShowTagValuesRequest) XXX_Merge 

func (m *ShowTagValuesRequest) XXX_Merge(src proto.Message)

func (*ShowTagValuesRequest) XXX_Size 

func (m *ShowTagValuesRequest) XXX_Size() int

func (*ShowTagValuesRequest) XXX_Unmarshal 

func (m *ShowTagValuesRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ShowTagValuesResponse) Descriptor 

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

func (*ShowTagValuesResponse) GetErr 

func (m *ShowTagValuesResponse) GetErr() string

func (*ShowTagValuesResponse) GetValues 

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

func (*ShowTagValuesResponse) ProtoMessage 

func (*ShowTagValuesResponse) ProtoMessage()

func (*ShowTagValuesResponse) Reset 

func (m *ShowTagValuesResponse) Reset()

func (*ShowTagValuesResponse) String 

func (m *ShowTagValuesResponse) String() string

func (*ShowTagValuesResponse) XXX_DiscardUnknown 

func (m *ShowTagValuesResponse) XXX_DiscardUnknown()

func (*ShowTagValuesResponse) XXX_Marshal 

func (m *ShowTagValuesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShowTagValuesResponse) XXX_Merge 

func (m *ShowTagValuesResponse) XXX_Merge(src proto.Message)

func (*ShowTagValuesResponse) XXX_Size 

func (m *ShowTagValuesResponse) XXX_Size() int

func (*ShowTagValuesResponse) XXX_Unmarshal 

func (m *ShowTagValuesResponse) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*SysCtrlRequest) Descriptor 

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

func (*SysCtrlRequest) GetMod 

func (m *SysCtrlRequest) GetMod() string

func (*SysCtrlRequest) GetParam 

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

func (*SysCtrlRequest) ProtoMessage 

func (*SysCtrlRequest) ProtoMessage()

func (*SysCtrlRequest) Reset 

func (m *SysCtrlRequest) Reset()

func (*SysCtrlRequest) String 

func (m *SysCtrlRequest) String() string

func (*SysCtrlRequest) XXX_DiscardUnknown 

func (m *SysCtrlRequest) XXX_DiscardUnknown()

func (*SysCtrlRequest) XXX_Marshal 

func (m *SysCtrlRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SysCtrlRequest) XXX_Merge 

func (m *SysCtrlRequest) XXX_Merge(src proto.Message)

func (*SysCtrlRequest) XXX_Size 

func (m *SysCtrlRequest) XXX_Size() int

func (*SysCtrlRequest) XXX_Unmarshal 

func (m *SysCtrlRequest) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*SysCtrlResponse) Descriptor 

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

func (*SysCtrlResponse) GetErr 

func (m *SysCtrlResponse) GetErr() string

func (*SysCtrlResponse) GetResult 

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

func (*SysCtrlResponse) ProtoMessage 

func (*SysCtrlResponse) ProtoMessage()

func (*SysCtrlResponse) Reset 

func (m *SysCtrlResponse) Reset()

func (*SysCtrlResponse) String 

func (m *SysCtrlResponse) String() string

func (*SysCtrlResponse) XXX_DiscardUnknown 

func (m *SysCtrlResponse) XXX_DiscardUnknown()

func (*SysCtrlResponse) XXX_Marshal 

func (m *SysCtrlResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SysCtrlResponse) XXX_Merge 

func (m *SysCtrlResponse) XXX_Merge(src proto.Message)

func (*SysCtrlResponse) XXX_Size 

func (m *SysCtrlResponse) XXX_Size() int

func (*SysCtrlResponse) XXX_Unmarshal 

func (m *SysCtrlResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TagValuesSlice) Descriptor 

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

func (*TagValuesSlice) GetKeys 

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

func (*TagValuesSlice) GetMeasurement 

func (m *TagValuesSlice) GetMeasurement() string

func (*TagValuesSlice) GetValues 

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

func (*TagValuesSlice) ProtoMessage 

func (*TagValuesSlice) ProtoMessage()

func (*TagValuesSlice) Reset 

func (m *TagValuesSlice) Reset()

func (*TagValuesSlice) String 

func (m *TagValuesSlice) String() string

func (*TagValuesSlice) XXX_DiscardUnknown 

func (m *TagValuesSlice) XXX_DiscardUnknown()

func (*TagValuesSlice) XXX_Marshal 

func (m *TagValuesSlice) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TagValuesSlice) XXX_Merge 

func (m *TagValuesSlice) XXX_Merge(src proto.Message)

func (*TagValuesSlice) XXX_Size 

func (m *TagValuesSlice) XXX_Size() int

func (*TagValuesSlice) XXX_Unmarshal 

func (m *TagValuesSlice) XXX_Unmarshal(b []byte) error

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.