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 SetAdminPrivilegeCommand 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 SetAdminPrivilegeCommand
- 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",
18: "SetAdminPrivilegeCommand",
}
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,
"SetAdminPrivilegeCommand": 18,
}
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_SetAdminPrivilegeCommand_Command = &proto.ExtensionDesc{ ExtendedType: (*Command)(nil), ExtensionType: (*SetAdminPrivilegeCommand)(nil), Field: 118, Name: "internal.SetAdminPrivilegeCommand.command", Tag: "bytes,118,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 Command_SetAdminPrivilegeCommand Command_Type = 18 )
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 SetAdminPrivilegeCommand ¶
type SetAdminPrivilegeCommand struct {
Username *string `protobuf:"bytes,1,req" json:"Username,omitempty"`
Admin *bool `protobuf:"varint,2,req" json:"Admin,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (*SetAdminPrivilegeCommand) GetAdmin ¶
func (m *SetAdminPrivilegeCommand) GetAdmin() bool
func (*SetAdminPrivilegeCommand) GetUsername ¶
func (m *SetAdminPrivilegeCommand) GetUsername() string
func (*SetAdminPrivilegeCommand) ProtoMessage ¶
func (*SetAdminPrivilegeCommand) ProtoMessage()
func (*SetAdminPrivilegeCommand) Reset ¶
func (m *SetAdminPrivilegeCommand) Reset()
func (*SetAdminPrivilegeCommand) String ¶
func (m *SetAdminPrivilegeCommand) 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.