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
Index ¶
- Variables
- 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 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 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 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: "internal.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: "internal.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: "internal.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: "internal.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: "internal.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: "internal.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: "internal.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: "internal.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: "internal.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: "internal.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: "internal.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: "internal.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: "internal.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: "internal.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: "internal.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: "internal.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: "internal.UpdateUserCommand.command", Tag: "bytes,115,opt,name=command", }
Functions ¶
This section is empty.
Types ¶
type Command ¶
type Command struct { Type *Command_Type `protobuf:"varint,1,req,name=type,enum=internal.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 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 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 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.