Documentation ¶
Overview ¶
Package internal is a generated protocol buffer package.
It is generated from these files:
internal/meta.proto
It has these top-level messages:
Data NodeInfo DatabaseInfo RetentionPolicyInfo ShardGroupInfo ShardInfo ContinuousQueryInfo UserInfo UserPrivilege Command CreateNodeCommand DeleteNodeCommand CreateDatabaseCommand DropDatabaseCommand CreateRetentionPolicyCommand DropRetentionPolicyCommand SetDefaultRetentionPolicyCommand UpdateRetentionPolicyCommand CreateShardGroupCommand DeleteShardGroupCommand CreateContinuousQueryCommand DropContinuousQueryCommand CreateUserCommand DropUserCommand UpdateUserCommand SetPrivilegeCommand SetDataCommand Response
Package internal is a generated protocol buffer package.
It is generated from these files:
meta.proto
It has these top-level messages:
Series Tag MeasurementFields Field
Index ¶
- Variables
- func GetPoints(datapath string, cdatabases chan<- database.Database, ...)
- type Command
- type Command_Type
- type ContinuousQueryInfo
- type CreateContinuousQueryCommand
- func (m *CreateContinuousQueryCommand) GetDatabase() string
- func (m *CreateContinuousQueryCommand) GetName() string
- func (m *CreateContinuousQueryCommand) GetQuery() string
- func (*CreateContinuousQueryCommand) ProtoMessage()
- func (m *CreateContinuousQueryCommand) Reset()
- func (m *CreateContinuousQueryCommand) String() string
- type CreateDatabaseCommand
- type CreateNodeCommand
- type CreateRetentionPolicyCommand
- type CreateShardGroupCommand
- func (m *CreateShardGroupCommand) GetDatabase() string
- func (m *CreateShardGroupCommand) GetPolicy() string
- func (m *CreateShardGroupCommand) GetTimestamp() int64
- func (*CreateShardGroupCommand) ProtoMessage()
- func (m *CreateShardGroupCommand) Reset()
- func (m *CreateShardGroupCommand) String() string
- type CreateUserCommand
- type Data
- func (m *Data) GetClusterID() uint64
- func (m *Data) GetDatabases() []*DatabaseInfo
- func (m *Data) GetIndex() uint64
- func (m *Data) GetMaxNodeID() uint64
- func (m *Data) GetMaxShardGroupID() uint64
- func (m *Data) GetMaxShardID() uint64
- func (m *Data) GetNodes() []*NodeInfo
- func (m *Data) GetTerm() uint64
- func (m *Data) GetUsers() []*UserInfo
- func (*Data) ProtoMessage()
- func (m *Data) Reset()
- func (m *Data) String() string
- type DatabaseInfo
- func (m *DatabaseInfo) GetContinuousQueries() []*ContinuousQueryInfo
- func (m *DatabaseInfo) GetDefaultRetentionPolicy() string
- func (m *DatabaseInfo) GetName() string
- func (m *DatabaseInfo) GetRetentionPolicies() []*RetentionPolicyInfo
- func (*DatabaseInfo) ProtoMessage()
- func (m *DatabaseInfo) Reset()
- func (m *DatabaseInfo) String() string
- type DeleteNodeCommand
- type DeleteShardGroupCommand
- func (m *DeleteShardGroupCommand) GetDatabase() string
- func (m *DeleteShardGroupCommand) GetPolicy() string
- func (m *DeleteShardGroupCommand) GetShardGroupID() uint64
- func (*DeleteShardGroupCommand) ProtoMessage()
- func (m *DeleteShardGroupCommand) Reset()
- func (m *DeleteShardGroupCommand) String() string
- type DropContinuousQueryCommand
- type DropDatabaseCommand
- type DropRetentionPolicyCommand
- type DropUserCommand
- type Field
- type MeasurementFields
- type NodeInfo
- type Response
- type RetentionPolicyInfo
- func (m *RetentionPolicyInfo) GetDuration() int64
- func (m *RetentionPolicyInfo) GetName() string
- func (m *RetentionPolicyInfo) GetReplicaN() uint32
- func (m *RetentionPolicyInfo) GetShardGroupDuration() int64
- func (m *RetentionPolicyInfo) GetShardGroups() []*ShardGroupInfo
- func (*RetentionPolicyInfo) ProtoMessage()
- func (m *RetentionPolicyInfo) Reset()
- func (m *RetentionPolicyInfo) String() string
- type Series
- type SetDataCommand
- type SetDefaultRetentionPolicyCommand
- type SetPrivilegeCommand
- type ShardGroupInfo
- func (m *ShardGroupInfo) GetDeletedAt() int64
- func (m *ShardGroupInfo) GetEndTime() int64
- func (m *ShardGroupInfo) GetID() uint64
- func (m *ShardGroupInfo) GetShards() []*ShardInfo
- func (m *ShardGroupInfo) GetStartTime() int64
- func (*ShardGroupInfo) ProtoMessage()
- func (m *ShardGroupInfo) Reset()
- func (m *ShardGroupInfo) String() string
- type ShardInfo
- type Tag
- type UpdateRetentionPolicyCommand
- func (m *UpdateRetentionPolicyCommand) GetDatabase() string
- func (m *UpdateRetentionPolicyCommand) GetDuration() int64
- func (m *UpdateRetentionPolicyCommand) GetName() string
- func (m *UpdateRetentionPolicyCommand) GetNewName() string
- func (m *UpdateRetentionPolicyCommand) GetReplicaN() uint32
- func (*UpdateRetentionPolicyCommand) ProtoMessage()
- func (m *UpdateRetentionPolicyCommand) Reset()
- func (m *UpdateRetentionPolicyCommand) String() string
- type UpdateUserCommand
- type UserInfo
- type UserPrivilege
Constants ¶
This section is empty.
Variables ¶
View Source
var Command_Type_name = map[int32]string{
1: "CreateNodeCommand",
2: "DeleteNodeCommand",
3: "CreateDatabaseCommand",
4: "DropDatabaseCommand",
5: "CreateRetentionPolicyCommand",
6: "DropRetentionPolicyCommand",
7: "SetDefaultRetentionPolicyCommand",
8: "UpdateRetentionPolicyCommand",
9: "CreateShardGroupCommand",
10: "DeleteShardGroupCommand",
11: "CreateContinuousQueryCommand",
12: "DropContinuousQueryCommand",
13: "CreateUserCommand",
14: "DropUserCommand",
15: "UpdateUserCommand",
16: "SetPrivilegeCommand",
17: "SetDataCommand",
}
View Source
var Command_Type_value = map[string]int32{
"CreateNodeCommand": 1,
"DeleteNodeCommand": 2,
"CreateDatabaseCommand": 3,
"DropDatabaseCommand": 4,
"CreateRetentionPolicyCommand": 5,
"DropRetentionPolicyCommand": 6,
"SetDefaultRetentionPolicyCommand": 7,
"UpdateRetentionPolicyCommand": 8,
"CreateShardGroupCommand": 9,
"DeleteShardGroupCommand": 10,
"CreateContinuousQueryCommand": 11,
"DropContinuousQueryCommand": 12,
"CreateUserCommand": 13,
"DropUserCommand": 14,
"UpdateUserCommand": 15,
"SetPrivilegeCommand": 16,
"SetDataCommand": 17,
}
View Source
var E_CreateContinuousQueryCommand_Command = &proto.ExtensionDesc{ ExtendedType: (*Command)(nil), ExtensionType: (*CreateContinuousQueryCommand)(nil), Field: 111, Name: "from090.CreateContinuousQueryCommand.command", Tag: "bytes,111,opt,name=command", }
View Source
var E_CreateDatabaseCommand_Command = &proto.ExtensionDesc{ ExtendedType: (*Command)(nil), ExtensionType: (*CreateDatabaseCommand)(nil), Field: 103, Name: "from090.CreateDatabaseCommand.command", Tag: "bytes,103,opt,name=command", }
View Source
var E_CreateNodeCommand_Command = &proto.ExtensionDesc{ ExtendedType: (*Command)(nil), ExtensionType: (*CreateNodeCommand)(nil), Field: 101, Name: "from090.CreateNodeCommand.command", Tag: "bytes,101,opt,name=command", }
View Source
var E_CreateRetentionPolicyCommand_Command = &proto.ExtensionDesc{ ExtendedType: (*Command)(nil), ExtensionType: (*CreateRetentionPolicyCommand)(nil), Field: 105, Name: "from090.CreateRetentionPolicyCommand.command", Tag: "bytes,105,opt,name=command", }
View Source
var E_CreateShardGroupCommand_Command = &proto.ExtensionDesc{ ExtendedType: (*Command)(nil), ExtensionType: (*CreateShardGroupCommand)(nil), Field: 109, Name: "from090.CreateShardGroupCommand.command", Tag: "bytes,109,opt,name=command", }
View Source
var E_CreateUserCommand_Command = &proto.ExtensionDesc{ ExtendedType: (*Command)(nil), ExtensionType: (*CreateUserCommand)(nil), Field: 113, Name: "from090.CreateUserCommand.command", Tag: "bytes,113,opt,name=command", }
View Source
var E_DeleteNodeCommand_Command = &proto.ExtensionDesc{ ExtendedType: (*Command)(nil), ExtensionType: (*DeleteNodeCommand)(nil), Field: 102, Name: "from090.DeleteNodeCommand.command", Tag: "bytes,102,opt,name=command", }
View Source
var E_DeleteShardGroupCommand_Command = &proto.ExtensionDesc{ ExtendedType: (*Command)(nil), ExtensionType: (*DeleteShardGroupCommand)(nil), Field: 110, Name: "from090.DeleteShardGroupCommand.command", Tag: "bytes,110,opt,name=command", }
View Source
var E_DropContinuousQueryCommand_Command = &proto.ExtensionDesc{ ExtendedType: (*Command)(nil), ExtensionType: (*DropContinuousQueryCommand)(nil), Field: 112, Name: "from090.DropContinuousQueryCommand.command", Tag: "bytes,112,opt,name=command", }
View Source
var E_DropDatabaseCommand_Command = &proto.ExtensionDesc{ ExtendedType: (*Command)(nil), ExtensionType: (*DropDatabaseCommand)(nil), Field: 104, Name: "from090.DropDatabaseCommand.command", Tag: "bytes,104,opt,name=command", }
View Source
var E_DropRetentionPolicyCommand_Command = &proto.ExtensionDesc{ ExtendedType: (*Command)(nil), ExtensionType: (*DropRetentionPolicyCommand)(nil), Field: 106, Name: "from090.DropRetentionPolicyCommand.command", Tag: "bytes,106,opt,name=command", }
View Source
var E_DropUserCommand_Command = &proto.ExtensionDesc{ ExtendedType: (*Command)(nil), ExtensionType: (*DropUserCommand)(nil), Field: 114, Name: "from090.DropUserCommand.command", Tag: "bytes,114,opt,name=command", }
View Source
var E_SetDataCommand_Command = &proto.ExtensionDesc{ ExtendedType: (*Command)(nil), ExtensionType: (*SetDataCommand)(nil), Field: 117, Name: "from090.SetDataCommand.command", Tag: "bytes,117,opt,name=command", }
View Source
var E_SetDefaultRetentionPolicyCommand_Command = &proto.ExtensionDesc{ ExtendedType: (*Command)(nil), ExtensionType: (*SetDefaultRetentionPolicyCommand)(nil), Field: 107, Name: "from090.SetDefaultRetentionPolicyCommand.command", Tag: "bytes,107,opt,name=command", }
View Source
var E_SetPrivilegeCommand_Command = &proto.ExtensionDesc{ ExtendedType: (*Command)(nil), ExtensionType: (*SetPrivilegeCommand)(nil), Field: 116, Name: "from090.SetPrivilegeCommand.command", Tag: "bytes,116,opt,name=command", }
View Source
var E_UpdateRetentionPolicyCommand_Command = &proto.ExtensionDesc{ ExtendedType: (*Command)(nil), ExtensionType: (*UpdateRetentionPolicyCommand)(nil), Field: 108, Name: "from090.UpdateRetentionPolicyCommand.command", Tag: "bytes,108,opt,name=command", }
View Source
var E_UpdateUserCommand_Command = &proto.ExtensionDesc{ ExtendedType: (*Command)(nil), ExtensionType: (*UpdateUserCommand)(nil), Field: 115, Name: "from090.UpdateUserCommand.command", Tag: "bytes,115,opt,name=command", }
Functions ¶
Types ¶
type Command ¶
type Command struct { Type *Command_Type `protobuf:"varint,1,req,name=type,enum=from090.Command_Type" json:"type,omitempty"` XXX_extensions map[int32]proto.Extension `json:"-"` XXX_unrecognized []byte `json:"-"` }
func (*Command) ExtensionRangeArray ¶
func (*Command) ExtensionRangeArray() []proto.ExtensionRange
func (*Command) GetType ¶
func (m *Command) GetType() Command_Type
func (*Command) ProtoMessage ¶
func (*Command) ProtoMessage()
type Command_Type ¶
type Command_Type int32
const ( Command_CreateNodeCommand Command_Type = 1 Command_DeleteNodeCommand Command_Type = 2 Command_CreateDatabaseCommand Command_Type = 3 Command_DropDatabaseCommand Command_Type = 4 Command_CreateRetentionPolicyCommand Command_Type = 5 Command_DropRetentionPolicyCommand Command_Type = 6 Command_SetDefaultRetentionPolicyCommand Command_Type = 7 Command_UpdateRetentionPolicyCommand Command_Type = 8 Command_CreateShardGroupCommand Command_Type = 9 Command_DeleteShardGroupCommand Command_Type = 10 Command_CreateContinuousQueryCommand Command_Type = 11 Command_DropContinuousQueryCommand Command_Type = 12 Command_CreateUserCommand Command_Type = 13 Command_DropUserCommand Command_Type = 14 Command_UpdateUserCommand Command_Type = 15 Command_SetPrivilegeCommand Command_Type = 16 Command_SetDataCommand Command_Type = 17 )
func (Command_Type) Enum ¶
func (x Command_Type) Enum() *Command_Type
func (Command_Type) String ¶
func (x Command_Type) String() string
func (*Command_Type) UnmarshalJSON ¶
func (x *Command_Type) UnmarshalJSON(data []byte) error
type ContinuousQueryInfo ¶
type ContinuousQueryInfo struct { Name *string `protobuf:"bytes,1,req" json:"Name,omitempty"` Query *string `protobuf:"bytes,2,req" json:"Query,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ContinuousQueryInfo) GetName ¶
func (m *ContinuousQueryInfo) GetName() string
func (*ContinuousQueryInfo) GetQuery ¶
func (m *ContinuousQueryInfo) GetQuery() string
func (*ContinuousQueryInfo) ProtoMessage ¶
func (*ContinuousQueryInfo) ProtoMessage()
func (*ContinuousQueryInfo) Reset ¶
func (m *ContinuousQueryInfo) Reset()
func (*ContinuousQueryInfo) String ¶
func (m *ContinuousQueryInfo) String() string
type CreateContinuousQueryCommand ¶
type CreateContinuousQueryCommand struct { Database *string `protobuf:"bytes,1,req" json:"Database,omitempty"` Name *string `protobuf:"bytes,2,req" json:"Name,omitempty"` Query *string `protobuf:"bytes,3,req" json:"Query,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CreateContinuousQueryCommand) GetDatabase ¶
func (m *CreateContinuousQueryCommand) GetDatabase() string
func (*CreateContinuousQueryCommand) GetName ¶
func (m *CreateContinuousQueryCommand) GetName() string
func (*CreateContinuousQueryCommand) GetQuery ¶
func (m *CreateContinuousQueryCommand) GetQuery() string
func (*CreateContinuousQueryCommand) ProtoMessage ¶
func (*CreateContinuousQueryCommand) ProtoMessage()
func (*CreateContinuousQueryCommand) Reset ¶
func (m *CreateContinuousQueryCommand) Reset()
func (*CreateContinuousQueryCommand) String ¶
func (m *CreateContinuousQueryCommand) String() string
type CreateDatabaseCommand ¶
type CreateDatabaseCommand struct { Name *string `protobuf:"bytes,1,req" json:"Name,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CreateDatabaseCommand) GetName ¶
func (m *CreateDatabaseCommand) GetName() string
func (*CreateDatabaseCommand) ProtoMessage ¶
func (*CreateDatabaseCommand) ProtoMessage()
func (*CreateDatabaseCommand) Reset ¶
func (m *CreateDatabaseCommand) Reset()
func (*CreateDatabaseCommand) String ¶
func (m *CreateDatabaseCommand) String() string
type CreateNodeCommand ¶
type CreateNodeCommand struct { Host *string `protobuf:"bytes,1,req" json:"Host,omitempty"` Rand *uint64 `protobuf:"varint,2,req" json:"Rand,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CreateNodeCommand) GetHost ¶
func (m *CreateNodeCommand) GetHost() string
func (*CreateNodeCommand) GetRand ¶
func (m *CreateNodeCommand) GetRand() uint64
func (*CreateNodeCommand) ProtoMessage ¶
func (*CreateNodeCommand) ProtoMessage()
func (*CreateNodeCommand) Reset ¶
func (m *CreateNodeCommand) Reset()
func (*CreateNodeCommand) String ¶
func (m *CreateNodeCommand) String() string
type CreateRetentionPolicyCommand ¶
type CreateRetentionPolicyCommand struct { Database *string `protobuf:"bytes,1,req" json:"Database,omitempty"` RetentionPolicy *RetentionPolicyInfo `protobuf:"bytes,2,req" json:"RetentionPolicy,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CreateRetentionPolicyCommand) GetDatabase ¶
func (m *CreateRetentionPolicyCommand) GetDatabase() string
func (*CreateRetentionPolicyCommand) GetRetentionPolicy ¶
func (m *CreateRetentionPolicyCommand) GetRetentionPolicy() *RetentionPolicyInfo
func (*CreateRetentionPolicyCommand) ProtoMessage ¶
func (*CreateRetentionPolicyCommand) ProtoMessage()
func (*CreateRetentionPolicyCommand) Reset ¶
func (m *CreateRetentionPolicyCommand) Reset()
func (*CreateRetentionPolicyCommand) String ¶
func (m *CreateRetentionPolicyCommand) String() string
type CreateShardGroupCommand ¶
type CreateShardGroupCommand struct { Database *string `protobuf:"bytes,1,req" json:"Database,omitempty"` Policy *string `protobuf:"bytes,2,req" json:"Policy,omitempty"` Timestamp *int64 `protobuf:"varint,3,req" json:"Timestamp,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CreateShardGroupCommand) GetDatabase ¶
func (m *CreateShardGroupCommand) GetDatabase() string
func (*CreateShardGroupCommand) GetPolicy ¶
func (m *CreateShardGroupCommand) GetPolicy() string
func (*CreateShardGroupCommand) GetTimestamp ¶
func (m *CreateShardGroupCommand) GetTimestamp() int64
func (*CreateShardGroupCommand) ProtoMessage ¶
func (*CreateShardGroupCommand) ProtoMessage()
func (*CreateShardGroupCommand) Reset ¶
func (m *CreateShardGroupCommand) Reset()
func (*CreateShardGroupCommand) String ¶
func (m *CreateShardGroupCommand) String() string
type CreateUserCommand ¶
type CreateUserCommand struct { Name *string `protobuf:"bytes,1,req" json:"Name,omitempty"` Hash *string `protobuf:"bytes,2,req" json:"Hash,omitempty"` Admin *bool `protobuf:"varint,3,req" json:"Admin,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CreateUserCommand) GetAdmin ¶
func (m *CreateUserCommand) GetAdmin() bool
func (*CreateUserCommand) GetHash ¶
func (m *CreateUserCommand) GetHash() string
func (*CreateUserCommand) GetName ¶
func (m *CreateUserCommand) GetName() string
func (*CreateUserCommand) ProtoMessage ¶
func (*CreateUserCommand) ProtoMessage()
func (*CreateUserCommand) Reset ¶
func (m *CreateUserCommand) Reset()
func (*CreateUserCommand) String ¶
func (m *CreateUserCommand) String() string
type Data ¶
type Data struct { Term *uint64 `protobuf:"varint,1,req" json:"Term,omitempty"` Index *uint64 `protobuf:"varint,2,req" json:"Index,omitempty"` ClusterID *uint64 `protobuf:"varint,3,req" json:"ClusterID,omitempty"` Nodes []*NodeInfo `protobuf:"bytes,4,rep" json:"Nodes,omitempty"` Databases []*DatabaseInfo `protobuf:"bytes,5,rep" json:"Databases,omitempty"` Users []*UserInfo `protobuf:"bytes,6,rep" json:"Users,omitempty"` MaxNodeID *uint64 `protobuf:"varint,7,req" json:"MaxNodeID,omitempty"` MaxShardGroupID *uint64 `protobuf:"varint,8,req" json:"MaxShardGroupID,omitempty"` MaxShardID *uint64 `protobuf:"varint,9,req" json:"MaxShardID,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*Data) GetClusterID ¶
func (*Data) GetDatabases ¶
func (m *Data) GetDatabases() []*DatabaseInfo
func (*Data) GetMaxNodeID ¶
func (*Data) GetMaxShardGroupID ¶
func (*Data) GetMaxShardID ¶
func (*Data) ProtoMessage ¶
func (*Data) ProtoMessage()
type DatabaseInfo ¶
type DatabaseInfo struct { Name *string `protobuf:"bytes,1,req" json:"Name,omitempty"` DefaultRetentionPolicy *string `protobuf:"bytes,2,req" json:"DefaultRetentionPolicy,omitempty"` RetentionPolicies []*RetentionPolicyInfo `protobuf:"bytes,3,rep" json:"RetentionPolicies,omitempty"` ContinuousQueries []*ContinuousQueryInfo `protobuf:"bytes,4,rep" json:"ContinuousQueries,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*DatabaseInfo) GetContinuousQueries ¶
func (m *DatabaseInfo) GetContinuousQueries() []*ContinuousQueryInfo
func (*DatabaseInfo) GetDefaultRetentionPolicy ¶
func (m *DatabaseInfo) GetDefaultRetentionPolicy() string
func (*DatabaseInfo) GetName ¶
func (m *DatabaseInfo) GetName() string
func (*DatabaseInfo) GetRetentionPolicies ¶
func (m *DatabaseInfo) GetRetentionPolicies() []*RetentionPolicyInfo
func (*DatabaseInfo) ProtoMessage ¶
func (*DatabaseInfo) ProtoMessage()
func (*DatabaseInfo) Reset ¶
func (m *DatabaseInfo) Reset()
func (*DatabaseInfo) String ¶
func (m *DatabaseInfo) String() string
type DeleteNodeCommand ¶
type DeleteNodeCommand struct { ID *uint64 `protobuf:"varint,1,req" json:"ID,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*DeleteNodeCommand) GetID ¶
func (m *DeleteNodeCommand) GetID() uint64
func (*DeleteNodeCommand) ProtoMessage ¶
func (*DeleteNodeCommand) ProtoMessage()
func (*DeleteNodeCommand) Reset ¶
func (m *DeleteNodeCommand) Reset()
func (*DeleteNodeCommand) String ¶
func (m *DeleteNodeCommand) String() string
type DeleteShardGroupCommand ¶
type DeleteShardGroupCommand struct { Database *string `protobuf:"bytes,1,req" json:"Database,omitempty"` Policy *string `protobuf:"bytes,2,req" json:"Policy,omitempty"` ShardGroupID *uint64 `protobuf:"varint,3,req" json:"ShardGroupID,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*DeleteShardGroupCommand) GetDatabase ¶
func (m *DeleteShardGroupCommand) GetDatabase() string
func (*DeleteShardGroupCommand) GetPolicy ¶
func (m *DeleteShardGroupCommand) GetPolicy() string
func (*DeleteShardGroupCommand) GetShardGroupID ¶
func (m *DeleteShardGroupCommand) GetShardGroupID() uint64
func (*DeleteShardGroupCommand) ProtoMessage ¶
func (*DeleteShardGroupCommand) ProtoMessage()
func (*DeleteShardGroupCommand) Reset ¶
func (m *DeleteShardGroupCommand) Reset()
func (*DeleteShardGroupCommand) String ¶
func (m *DeleteShardGroupCommand) String() string
type DropContinuousQueryCommand ¶
type DropContinuousQueryCommand struct { Database *string `protobuf:"bytes,1,req" json:"Database,omitempty"` Name *string `protobuf:"bytes,2,req" json:"Name,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*DropContinuousQueryCommand) GetDatabase ¶
func (m *DropContinuousQueryCommand) GetDatabase() string
func (*DropContinuousQueryCommand) GetName ¶
func (m *DropContinuousQueryCommand) GetName() string
func (*DropContinuousQueryCommand) ProtoMessage ¶
func (*DropContinuousQueryCommand) ProtoMessage()
func (*DropContinuousQueryCommand) Reset ¶
func (m *DropContinuousQueryCommand) Reset()
func (*DropContinuousQueryCommand) String ¶
func (m *DropContinuousQueryCommand) String() string
type DropDatabaseCommand ¶
type DropDatabaseCommand struct { Name *string `protobuf:"bytes,1,req" json:"Name,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*DropDatabaseCommand) GetName ¶
func (m *DropDatabaseCommand) GetName() string
func (*DropDatabaseCommand) ProtoMessage ¶
func (*DropDatabaseCommand) ProtoMessage()
func (*DropDatabaseCommand) Reset ¶
func (m *DropDatabaseCommand) Reset()
func (*DropDatabaseCommand) String ¶
func (m *DropDatabaseCommand) String() string
type DropRetentionPolicyCommand ¶
type DropRetentionPolicyCommand struct { Database *string `protobuf:"bytes,1,req" json:"Database,omitempty"` Name *string `protobuf:"bytes,2,req" json:"Name,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*DropRetentionPolicyCommand) GetDatabase ¶
func (m *DropRetentionPolicyCommand) GetDatabase() string
func (*DropRetentionPolicyCommand) GetName ¶
func (m *DropRetentionPolicyCommand) GetName() string
func (*DropRetentionPolicyCommand) ProtoMessage ¶
func (*DropRetentionPolicyCommand) ProtoMessage()
func (*DropRetentionPolicyCommand) Reset ¶
func (m *DropRetentionPolicyCommand) Reset()
func (*DropRetentionPolicyCommand) String ¶
func (m *DropRetentionPolicyCommand) String() string
type DropUserCommand ¶
type DropUserCommand struct { Name *string `protobuf:"bytes,1,req" json:"Name,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*DropUserCommand) GetName ¶
func (m *DropUserCommand) GetName() string
func (*DropUserCommand) ProtoMessage ¶
func (*DropUserCommand) ProtoMessage()
func (*DropUserCommand) Reset ¶
func (m *DropUserCommand) Reset()
func (*DropUserCommand) String ¶
func (m *DropUserCommand) String() string
type Field ¶
type Field struct { ID *int32 `protobuf:"varint,1,req" json:"ID,omitempty"` Name *string `protobuf:"bytes,2,req" json:"Name,omitempty"` Type *int32 `protobuf:"varint,3,req" json:"Type,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*Field) ProtoMessage ¶
func (*Field) ProtoMessage()
type MeasurementFields ¶
type MeasurementFields struct { Fields []*Field `protobuf:"bytes,1,rep" json:"Fields,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*MeasurementFields) GetFields ¶
func (m *MeasurementFields) GetFields() []*Field
func (*MeasurementFields) ProtoMessage ¶
func (*MeasurementFields) ProtoMessage()
func (*MeasurementFields) Reset ¶
func (m *MeasurementFields) Reset()
func (*MeasurementFields) String ¶
func (m *MeasurementFields) String() string
type NodeInfo ¶
type NodeInfo struct { ID *uint64 `protobuf:"varint,1,req" json:"ID,omitempty"` Host *string `protobuf:"bytes,2,req" json:"Host,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*NodeInfo) ProtoMessage ¶
func (*NodeInfo) ProtoMessage()
type Response ¶
type Response struct { OK *bool `protobuf:"varint,1,req" json:"OK,omitempty"` Error *string `protobuf:"bytes,2,opt" json:"Error,omitempty"` Index *uint64 `protobuf:"varint,3,opt" json:"Index,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
type RetentionPolicyInfo ¶
type RetentionPolicyInfo struct { Name *string `protobuf:"bytes,1,req" json:"Name,omitempty"` Duration *int64 `protobuf:"varint,2,req" json:"Duration,omitempty"` ShardGroupDuration *int64 `protobuf:"varint,3,req" json:"ShardGroupDuration,omitempty"` ReplicaN *uint32 `protobuf:"varint,4,req" json:"ReplicaN,omitempty"` ShardGroups []*ShardGroupInfo `protobuf:"bytes,5,rep" json:"ShardGroups,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*RetentionPolicyInfo) GetDuration ¶
func (m *RetentionPolicyInfo) GetDuration() int64
func (*RetentionPolicyInfo) GetName ¶
func (m *RetentionPolicyInfo) GetName() string
func (*RetentionPolicyInfo) GetReplicaN ¶
func (m *RetentionPolicyInfo) GetReplicaN() uint32
func (*RetentionPolicyInfo) GetShardGroupDuration ¶
func (m *RetentionPolicyInfo) GetShardGroupDuration() int64
func (*RetentionPolicyInfo) GetShardGroups ¶
func (m *RetentionPolicyInfo) GetShardGroups() []*ShardGroupInfo
func (*RetentionPolicyInfo) ProtoMessage ¶
func (*RetentionPolicyInfo) ProtoMessage()
func (*RetentionPolicyInfo) Reset ¶
func (m *RetentionPolicyInfo) Reset()
func (*RetentionPolicyInfo) String ¶
func (m *RetentionPolicyInfo) String() string
type Series ¶
type Series struct { Key *string `protobuf:"bytes,1,req" json:"Key,omitempty"` Tags []*Tag `protobuf:"bytes,2,rep" json:"Tags,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*Series) ProtoMessage ¶
func (*Series) ProtoMessage()
type SetDataCommand ¶
type SetDataCommand struct { Data *Data `protobuf:"bytes,1,req" json:"Data,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*SetDataCommand) GetData ¶
func (m *SetDataCommand) GetData() *Data
func (*SetDataCommand) ProtoMessage ¶
func (*SetDataCommand) ProtoMessage()
func (*SetDataCommand) Reset ¶
func (m *SetDataCommand) Reset()
func (*SetDataCommand) String ¶
func (m *SetDataCommand) String() string
type SetDefaultRetentionPolicyCommand ¶
type SetDefaultRetentionPolicyCommand struct { Database *string `protobuf:"bytes,1,req" json:"Database,omitempty"` Name *string `protobuf:"bytes,2,req" json:"Name,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*SetDefaultRetentionPolicyCommand) GetDatabase ¶
func (m *SetDefaultRetentionPolicyCommand) GetDatabase() string
func (*SetDefaultRetentionPolicyCommand) GetName ¶
func (m *SetDefaultRetentionPolicyCommand) GetName() string
func (*SetDefaultRetentionPolicyCommand) ProtoMessage ¶
func (*SetDefaultRetentionPolicyCommand) ProtoMessage()
func (*SetDefaultRetentionPolicyCommand) Reset ¶
func (m *SetDefaultRetentionPolicyCommand) Reset()
func (*SetDefaultRetentionPolicyCommand) String ¶
func (m *SetDefaultRetentionPolicyCommand) String() string
type SetPrivilegeCommand ¶
type SetPrivilegeCommand struct { Username *string `protobuf:"bytes,1,req" json:"Username,omitempty"` Database *string `protobuf:"bytes,2,req" json:"Database,omitempty"` Privilege *int32 `protobuf:"varint,3,req" json:"Privilege,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*SetPrivilegeCommand) GetDatabase ¶
func (m *SetPrivilegeCommand) GetDatabase() string
func (*SetPrivilegeCommand) GetPrivilege ¶
func (m *SetPrivilegeCommand) GetPrivilege() int32
func (*SetPrivilegeCommand) GetUsername ¶
func (m *SetPrivilegeCommand) GetUsername() string
func (*SetPrivilegeCommand) ProtoMessage ¶
func (*SetPrivilegeCommand) ProtoMessage()
func (*SetPrivilegeCommand) Reset ¶
func (m *SetPrivilegeCommand) Reset()
func (*SetPrivilegeCommand) String ¶
func (m *SetPrivilegeCommand) String() string
type ShardGroupInfo ¶
type ShardGroupInfo struct { ID *uint64 `protobuf:"varint,1,req" json:"ID,omitempty"` StartTime *int64 `protobuf:"varint,2,req" json:"StartTime,omitempty"` EndTime *int64 `protobuf:"varint,3,req" json:"EndTime,omitempty"` DeletedAt *int64 `protobuf:"varint,4,req" json:"DeletedAt,omitempty"` Shards []*ShardInfo `protobuf:"bytes,5,rep" json:"Shards,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ShardGroupInfo) GetDeletedAt ¶
func (m *ShardGroupInfo) GetDeletedAt() int64
func (*ShardGroupInfo) GetEndTime ¶
func (m *ShardGroupInfo) GetEndTime() int64
func (*ShardGroupInfo) GetID ¶
func (m *ShardGroupInfo) GetID() uint64
func (*ShardGroupInfo) GetShards ¶
func (m *ShardGroupInfo) GetShards() []*ShardInfo
func (*ShardGroupInfo) GetStartTime ¶
func (m *ShardGroupInfo) GetStartTime() int64
func (*ShardGroupInfo) ProtoMessage ¶
func (*ShardGroupInfo) ProtoMessage()
func (*ShardGroupInfo) Reset ¶
func (m *ShardGroupInfo) Reset()
func (*ShardGroupInfo) String ¶
func (m *ShardGroupInfo) String() string
type ShardInfo ¶
type ShardInfo struct { ID *uint64 `protobuf:"varint,1,req" json:"ID,omitempty"` OwnerIDs []uint64 `protobuf:"varint,2,rep" json:"OwnerIDs,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ShardInfo) GetOwnerIDs ¶
func (*ShardInfo) ProtoMessage ¶
func (*ShardInfo) ProtoMessage()
type Tag ¶
type Tag struct { Key *string `protobuf:"bytes,1,req" json:"Key,omitempty"` Value *string `protobuf:"bytes,2,req" json:"Value,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*Tag) ProtoMessage ¶
func (*Tag) ProtoMessage()
type UpdateRetentionPolicyCommand ¶
type UpdateRetentionPolicyCommand struct { Database *string `protobuf:"bytes,1,req" json:"Database,omitempty"` Name *string `protobuf:"bytes,2,req" json:"Name,omitempty"` NewName *string `protobuf:"bytes,3,opt" json:"NewName,omitempty"` Duration *int64 `protobuf:"varint,4,opt" json:"Duration,omitempty"` ReplicaN *uint32 `protobuf:"varint,5,opt" json:"ReplicaN,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*UpdateRetentionPolicyCommand) GetDatabase ¶
func (m *UpdateRetentionPolicyCommand) GetDatabase() string
func (*UpdateRetentionPolicyCommand) GetDuration ¶
func (m *UpdateRetentionPolicyCommand) GetDuration() int64
func (*UpdateRetentionPolicyCommand) GetName ¶
func (m *UpdateRetentionPolicyCommand) GetName() string
func (*UpdateRetentionPolicyCommand) GetNewName ¶
func (m *UpdateRetentionPolicyCommand) GetNewName() string
func (*UpdateRetentionPolicyCommand) GetReplicaN ¶
func (m *UpdateRetentionPolicyCommand) GetReplicaN() uint32
func (*UpdateRetentionPolicyCommand) ProtoMessage ¶
func (*UpdateRetentionPolicyCommand) ProtoMessage()
func (*UpdateRetentionPolicyCommand) Reset ¶
func (m *UpdateRetentionPolicyCommand) Reset()
func (*UpdateRetentionPolicyCommand) String ¶
func (m *UpdateRetentionPolicyCommand) String() string
type UpdateUserCommand ¶
type UpdateUserCommand struct { Name *string `protobuf:"bytes,1,req" json:"Name,omitempty"` Hash *string `protobuf:"bytes,2,req" json:"Hash,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*UpdateUserCommand) GetHash ¶
func (m *UpdateUserCommand) GetHash() string
func (*UpdateUserCommand) GetName ¶
func (m *UpdateUserCommand) GetName() string
func (*UpdateUserCommand) ProtoMessage ¶
func (*UpdateUserCommand) ProtoMessage()
func (*UpdateUserCommand) Reset ¶
func (m *UpdateUserCommand) Reset()
func (*UpdateUserCommand) String ¶
func (m *UpdateUserCommand) String() string
type UserInfo ¶
type UserInfo struct { Name *string `protobuf:"bytes,1,req" json:"Name,omitempty"` Hash *string `protobuf:"bytes,2,req" json:"Hash,omitempty"` Admin *bool `protobuf:"varint,3,req" json:"Admin,omitempty"` Privileges []*UserPrivilege `protobuf:"bytes,4,rep" json:"Privileges,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*UserInfo) GetPrivileges ¶
func (m *UserInfo) GetPrivileges() []*UserPrivilege
func (*UserInfo) ProtoMessage ¶
func (*UserInfo) ProtoMessage()
type UserPrivilege ¶
type UserPrivilege struct { Database *string `protobuf:"bytes,1,req" json:"Database,omitempty"` Privilege *int32 `protobuf:"varint,2,req" json:"Privilege,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*UserPrivilege) GetDatabase ¶
func (m *UserPrivilege) GetDatabase() string
func (*UserPrivilege) GetPrivilege ¶
func (m *UserPrivilege) GetPrivilege() int32
func (*UserPrivilege) ProtoMessage ¶
func (*UserPrivilege) ProtoMessage()
func (*UserPrivilege) Reset ¶
func (m *UserPrivilege) Reset()
func (*UserPrivilege) String ¶
func (m *UserPrivilege) String() string
Click to show internal directories.
Click to hide internal directories.