meta

Sep 7, 2016

Changes in this version

type Command

+ func (*Command) Descriptor() ([]byte, []int)

type Command_Type

+ func (Command_Type) EnumDescriptor() ([]byte, []int)

type ContinuousQueryInfo

+ func (*ContinuousQueryInfo) Descriptor() ([]byte, []int)

type CreateContinuousQueryCommand

+ func (*CreateContinuousQueryCommand) Descriptor() ([]byte, []int)

type CreateDataNodeCommand

+ func (*CreateDataNodeCommand) Descriptor() ([]byte, []int)

type CreateDatabaseCommand

+ func (*CreateDatabaseCommand) Descriptor() ([]byte, []int)

type CreateMetaNodeCommand

+ func (*CreateMetaNodeCommand) Descriptor() ([]byte, []int)

type CreateNodeCommand

+ func (*CreateNodeCommand) Descriptor() ([]byte, []int)

type CreateRetentionPolicyCommand

+ func (*CreateRetentionPolicyCommand) Descriptor() ([]byte, []int)

type CreateShardGroupCommand

+ func (*CreateShardGroupCommand) Descriptor() ([]byte, []int)

type CreateSubscriptionCommand

+ func (*CreateSubscriptionCommand) Descriptor() ([]byte, []int)

type CreateUserCommand

+ func (*CreateUserCommand) Descriptor() ([]byte, []int)

type Data

+ func (*Data) Descriptor() ([]byte, []int)

type DatabaseInfo

+ func (*DatabaseInfo) Descriptor() ([]byte, []int)

type DeleteDataNodeCommand

+ func (*DeleteDataNodeCommand) Descriptor() ([]byte, []int)

type DeleteMetaNodeCommand

+ func (*DeleteMetaNodeCommand) Descriptor() ([]byte, []int)

type DeleteNodeCommand

+ func (*DeleteNodeCommand) Descriptor() ([]byte, []int)

type DeleteShardGroupCommand

+ func (*DeleteShardGroupCommand) Descriptor() ([]byte, []int)

type DropContinuousQueryCommand

+ func (*DropContinuousQueryCommand) Descriptor() ([]byte, []int)

type DropDatabaseCommand

+ func (*DropDatabaseCommand) Descriptor() ([]byte, []int)

type DropRetentionPolicyCommand

+ func (*DropRetentionPolicyCommand) Descriptor() ([]byte, []int)

type DropShardCommand

+ func (*DropShardCommand) Descriptor() ([]byte, []int)

type DropSubscriptionCommand

+ func (*DropSubscriptionCommand) Descriptor() ([]byte, []int)

type DropUserCommand

+ func (*DropUserCommand) Descriptor() ([]byte, []int)

type NodeInfo

+ func (*NodeInfo) Descriptor() ([]byte, []int)

type RemovePeerCommand

+ func (*RemovePeerCommand) Descriptor() ([]byte, []int)

type Response

+ func (*Response) Descriptor() ([]byte, []int)

type RetentionPolicyInfo

+ func (*RetentionPolicyInfo) Descriptor() ([]byte, []int)

+ type RetentionPolicySpec struct

+ Duration *int64

+ Name *string

+ ReplicaN *uint32

+ ShardGroupDuration *int64

+ XXX_unrecognized []byte

+ func (*RetentionPolicySpec) Descriptor() ([]byte, []int)

+ func (*RetentionPolicySpec) ProtoMessage()

+ func (m *RetentionPolicySpec) GetDuration() int64

+ func (m *RetentionPolicySpec) GetName() string

+ func (m *RetentionPolicySpec) GetReplicaN() uint32

+ func (m *RetentionPolicySpec) GetShardGroupDuration() int64

+ func (m *RetentionPolicySpec) Reset()

+ func (m *RetentionPolicySpec) String() string

type SetAdminPrivilegeCommand

+ func (*SetAdminPrivilegeCommand) Descriptor() ([]byte, []int)

type SetDataCommand

+ func (*SetDataCommand) Descriptor() ([]byte, []int)

type SetDefaultRetentionPolicyCommand

+ func (*SetDefaultRetentionPolicyCommand) Descriptor() ([]byte, []int)

type SetMetaNodeCommand

+ func (*SetMetaNodeCommand) Descriptor() ([]byte, []int)

type SetPrivilegeCommand

+ func (*SetPrivilegeCommand) Descriptor() ([]byte, []int)

type ShardGroupInfo

+ TruncatedAt *int64

+ func (*ShardGroupInfo) Descriptor() ([]byte, []int)

+ func (m *ShardGroupInfo) GetTruncatedAt() int64

type ShardInfo

+ func (*ShardInfo) Descriptor() ([]byte, []int)

type ShardOwner

+ func (*ShardOwner) Descriptor() ([]byte, []int)

type SubscriptionInfo

+ func (*SubscriptionInfo) Descriptor() ([]byte, []int)

type UpdateDataNodeCommand

+ func (*UpdateDataNodeCommand) Descriptor() ([]byte, []int)

type UpdateNodeCommand

+ func (*UpdateNodeCommand) Descriptor() ([]byte, []int)

type UpdateRetentionPolicyCommand

+ func (*UpdateRetentionPolicyCommand) Descriptor() ([]byte, []int)

type UpdateUserCommand

+ func (*UpdateUserCommand) Descriptor() ([]byte, []int)

type UserInfo

+ func (*UserInfo) Descriptor() ([]byte, []int)

type UserPrivilege

+ func (*UserPrivilege) Descriptor() ([]byte, []int)

Apr 4, 2016

Changes in this version

+ var E_DropShardCommand_Command = &proto.ExtensionDesc

type Command_Type

+ const Command_DropShardCommand

+ type DropShardCommand struct

+ ID *uint64

+ XXX_unrecognized []byte

+ func (*DropShardCommand) ProtoMessage()

+ func (m *DropShardCommand) GetID() uint64

+ func (m *DropShardCommand) Reset()

+ func (m *DropShardCommand) String() string

Feb 18, 2016

Changes in this version

type CreateDatabaseCommand

+ RetentionPolicy *RetentionPolicyInfo

+ func (m *CreateDatabaseCommand) GetRetentionPolicy() *RetentionPolicyInfo

Feb 4, 2016

Changes in this version

+ var Command_Type_name = map[int32]string

+ var Command_Type_value = map[string]int32

+ var E_CreateContinuousQueryCommand_Command = &proto.ExtensionDesc

+ var E_CreateDataNodeCommand_Command = &proto.ExtensionDesc

+ var E_CreateDatabaseCommand_Command = &proto.ExtensionDesc

+ var E_CreateMetaNodeCommand_Command = &proto.ExtensionDesc

+ var E_CreateNodeCommand_Command = &proto.ExtensionDesc

+ var E_CreateRetentionPolicyCommand_Command = &proto.ExtensionDesc

+ var E_CreateShardGroupCommand_Command = &proto.ExtensionDesc

+ var E_CreateSubscriptionCommand_Command = &proto.ExtensionDesc

+ var E_CreateUserCommand_Command = &proto.ExtensionDesc

+ var E_DeleteDataNodeCommand_Command = &proto.ExtensionDesc

+ var E_DeleteMetaNodeCommand_Command = &proto.ExtensionDesc

+ var E_DeleteNodeCommand_Command = &proto.ExtensionDesc

+ var E_DeleteShardGroupCommand_Command = &proto.ExtensionDesc

+ var E_DropContinuousQueryCommand_Command = &proto.ExtensionDesc

+ var E_DropDatabaseCommand_Command = &proto.ExtensionDesc

+ var E_DropRetentionPolicyCommand_Command = &proto.ExtensionDesc

+ var E_DropSubscriptionCommand_Command = &proto.ExtensionDesc

+ var E_DropUserCommand_Command = &proto.ExtensionDesc

+ var E_RemovePeerCommand_Command = &proto.ExtensionDesc

+ var E_SetAdminPrivilegeCommand_Command = &proto.ExtensionDesc

+ var E_SetDataCommand_Command = &proto.ExtensionDesc

+ var E_SetDefaultRetentionPolicyCommand_Command = &proto.ExtensionDesc

+ var E_SetMetaNodeCommand_Command = &proto.ExtensionDesc

+ var E_SetPrivilegeCommand_Command = &proto.ExtensionDesc

+ var E_UpdateDataNodeCommand_Command = &proto.ExtensionDesc

+ var E_UpdateNodeCommand_Command = &proto.ExtensionDesc

+ var E_UpdateRetentionPolicyCommand_Command = &proto.ExtensionDesc

+ var E_UpdateUserCommand_Command = &proto.ExtensionDesc

+ type Command struct

+ Type *Command_Type

+ XXX_extensions map[int32]proto.Extension

+ XXX_unrecognized []byte

+ func (*Command) ExtensionRangeArray() []proto.ExtensionRange

+ func (*Command) ProtoMessage()

+ func (m *Command) ExtensionMap() map[int32]proto.Extension

+ func (m *Command) GetType() Command_Type

+ func (m *Command) Reset()

+ func (m *Command) String() string

+ type Command_Type int32

+ const Command_CreateContinuousQueryCommand

+ const Command_CreateDataNodeCommand

+ const Command_CreateDatabaseCommand

+ const Command_CreateMetaNodeCommand

+ const Command_CreateNodeCommand

+ const Command_CreateRetentionPolicyCommand

+ const Command_CreateShardGroupCommand

+ const Command_CreateSubscriptionCommand

+ const Command_CreateUserCommand

+ const Command_DeleteDataNodeCommand

+ const Command_DeleteMetaNodeCommand

+ const Command_DeleteNodeCommand

+ const Command_DeleteShardGroupCommand

+ const Command_DropContinuousQueryCommand

+ const Command_DropDatabaseCommand

+ const Command_DropRetentionPolicyCommand

+ const Command_DropSubscriptionCommand

+ const Command_DropUserCommand

+ const Command_RemovePeerCommand

+ const Command_SetAdminPrivilegeCommand

+ const Command_SetDataCommand

+ const Command_SetDefaultRetentionPolicyCommand

+ const Command_SetMetaNodeCommand

+ const Command_SetPrivilegeCommand

+ const Command_UpdateDataNodeCommand

+ const Command_UpdateNodeCommand

+ const Command_UpdateRetentionPolicyCommand

+ const Command_UpdateUserCommand

+ func (x *Command_Type) UnmarshalJSON(data []byte) error

+ func (x Command_Type) Enum() *Command_Type

+ func (x Command_Type) String() string

+ type ContinuousQueryInfo struct

+ Name *string

+ Query *string

+ XXX_unrecognized []byte

+ func (*ContinuousQueryInfo) ProtoMessage()

+ func (m *ContinuousQueryInfo) GetName() string

+ func (m *ContinuousQueryInfo) GetQuery() string

+ func (m *ContinuousQueryInfo) Reset()

+ func (m *ContinuousQueryInfo) String() string

+ type CreateContinuousQueryCommand struct

+ Database *string

+ Name *string

+ Query *string

+ XXX_unrecognized []byte

+ func (*CreateContinuousQueryCommand) ProtoMessage()

+ func (m *CreateContinuousQueryCommand) GetDatabase() string

+ func (m *CreateContinuousQueryCommand) GetName() string

+ func (m *CreateContinuousQueryCommand) GetQuery() string

+ func (m *CreateContinuousQueryCommand) Reset()

+ func (m *CreateContinuousQueryCommand) String() string

+ type CreateDataNodeCommand struct

+ HTTPAddr *string

+ TCPAddr *string

+ XXX_unrecognized []byte

+ func (*CreateDataNodeCommand) ProtoMessage()

+ func (m *CreateDataNodeCommand) GetHTTPAddr() string

+ func (m *CreateDataNodeCommand) GetTCPAddr() string

+ func (m *CreateDataNodeCommand) Reset()

+ func (m *CreateDataNodeCommand) String() string

+ type CreateDatabaseCommand struct

+ Name *string

+ XXX_unrecognized []byte

+ func (*CreateDatabaseCommand) ProtoMessage()

+ func (m *CreateDatabaseCommand) GetName() string

+ func (m *CreateDatabaseCommand) Reset()

+ func (m *CreateDatabaseCommand) String() string

+ type CreateMetaNodeCommand struct

+ HTTPAddr *string

+ Rand *uint64

+ TCPAddr *string

+ XXX_unrecognized []byte

+ func (*CreateMetaNodeCommand) ProtoMessage()

+ func (m *CreateMetaNodeCommand) GetHTTPAddr() string

+ func (m *CreateMetaNodeCommand) GetRand() uint64

+ func (m *CreateMetaNodeCommand) GetTCPAddr() string

+ func (m *CreateMetaNodeCommand) Reset()

+ func (m *CreateMetaNodeCommand) String() string

+ type CreateNodeCommand struct

+ Host *string

+ Rand *uint64

+ XXX_unrecognized []byte

+ func (*CreateNodeCommand) ProtoMessage()

+ func (m *CreateNodeCommand) GetHost() string

+ func (m *CreateNodeCommand) GetRand() uint64

+ func (m *CreateNodeCommand) Reset()

+ func (m *CreateNodeCommand) String() string

+ type CreateRetentionPolicyCommand struct

+ Database *string

+ RetentionPolicy *RetentionPolicyInfo

+ XXX_unrecognized []byte

+ func (*CreateRetentionPolicyCommand) ProtoMessage()

+ func (m *CreateRetentionPolicyCommand) GetDatabase() string

+ func (m *CreateRetentionPolicyCommand) GetRetentionPolicy() *RetentionPolicyInfo

+ func (m *CreateRetentionPolicyCommand) Reset()

+ func (m *CreateRetentionPolicyCommand) String() string

+ type CreateShardGroupCommand struct

+ Database *string

+ Policy *string

+ Timestamp *int64

+ XXX_unrecognized []byte

+ func (*CreateShardGroupCommand) ProtoMessage()

+ func (m *CreateShardGroupCommand) GetDatabase() string

+ func (m *CreateShardGroupCommand) GetPolicy() string

+ func (m *CreateShardGroupCommand) GetTimestamp() int64

+ func (m *CreateShardGroupCommand) Reset()

+ func (m *CreateShardGroupCommand) String() string

+ type CreateSubscriptionCommand struct

+ Database *string

+ Destinations []string

+ Mode *string

+ Name *string

+ RetentionPolicy *string

+ XXX_unrecognized []byte

+ func (*CreateSubscriptionCommand) ProtoMessage()

+ func (m *CreateSubscriptionCommand) GetDatabase() string

+ func (m *CreateSubscriptionCommand) GetDestinations() []string

+ func (m *CreateSubscriptionCommand) GetMode() string

+ func (m *CreateSubscriptionCommand) GetName() string

+ func (m *CreateSubscriptionCommand) GetRetentionPolicy() string

+ func (m *CreateSubscriptionCommand) Reset()

+ func (m *CreateSubscriptionCommand) String() string

+ type CreateUserCommand struct

+ Admin *bool

+ Hash *string

+ Name *string

+ XXX_unrecognized []byte

+ func (*CreateUserCommand) ProtoMessage()

+ func (m *CreateUserCommand) GetAdmin() bool

+ func (m *CreateUserCommand) GetHash() string

+ func (m *CreateUserCommand) GetName() string

+ func (m *CreateUserCommand) Reset()

+ func (m *CreateUserCommand) String() string

+ type Data struct

+ ClusterID *uint64

+ DataNodes []*NodeInfo

+ Databases []*DatabaseInfo

+ Index *uint64

+ MaxNodeID *uint64

+ MaxShardGroupID *uint64

+ MaxShardID *uint64

+ MetaNodes []*NodeInfo

+ Nodes []*NodeInfo

+ Term *uint64

+ Users []*UserInfo

+ XXX_unrecognized []byte

+ func (*Data) ProtoMessage()

+ func (m *Data) GetClusterID() uint64

+ func (m *Data) GetDataNodes() []*NodeInfo

+ 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) GetMetaNodes() []*NodeInfo

+ func (m *Data) GetNodes() []*NodeInfo

+ func (m *Data) GetTerm() uint64

+ func (m *Data) GetUsers() []*UserInfo

+ func (m *Data) Reset()

+ func (m *Data) String() string

+ type DatabaseInfo struct

+ ContinuousQueries []*ContinuousQueryInfo

+ DefaultRetentionPolicy *string

+ Name *string

+ RetentionPolicies []*RetentionPolicyInfo

+ XXX_unrecognized []byte

+ func (*DatabaseInfo) ProtoMessage()

+ func (m *DatabaseInfo) GetContinuousQueries() []*ContinuousQueryInfo

+ func (m *DatabaseInfo) GetDefaultRetentionPolicy() string

+ func (m *DatabaseInfo) GetName() string

+ func (m *DatabaseInfo) GetRetentionPolicies() []*RetentionPolicyInfo

+ func (m *DatabaseInfo) Reset()

+ func (m *DatabaseInfo) String() string

+ type DeleteDataNodeCommand struct

+ ID *uint64

+ XXX_unrecognized []byte

+ func (*DeleteDataNodeCommand) ProtoMessage()

+ func (m *DeleteDataNodeCommand) GetID() uint64

+ func (m *DeleteDataNodeCommand) Reset()

+ func (m *DeleteDataNodeCommand) String() string

+ type DeleteMetaNodeCommand struct

+ ID *uint64

+ XXX_unrecognized []byte

+ func (*DeleteMetaNodeCommand) ProtoMessage()

+ func (m *DeleteMetaNodeCommand) GetID() uint64

+ func (m *DeleteMetaNodeCommand) Reset()

+ func (m *DeleteMetaNodeCommand) String() string

+ type DeleteNodeCommand struct

+ Force *bool

+ ID *uint64

+ XXX_unrecognized []byte

+ func (*DeleteNodeCommand) ProtoMessage()

+ func (m *DeleteNodeCommand) GetForce() bool

+ func (m *DeleteNodeCommand) GetID() uint64

+ func (m *DeleteNodeCommand) Reset()

+ func (m *DeleteNodeCommand) String() string

+ type DeleteShardGroupCommand struct

+ Database *string

+ Policy *string

+ ShardGroupID *uint64

+ XXX_unrecognized []byte

+ func (*DeleteShardGroupCommand) ProtoMessage()

+ func (m *DeleteShardGroupCommand) GetDatabase() string

+ func (m *DeleteShardGroupCommand) GetPolicy() string

+ func (m *DeleteShardGroupCommand) GetShardGroupID() uint64

+ func (m *DeleteShardGroupCommand) Reset()

+ func (m *DeleteShardGroupCommand) String() string

+ type DropContinuousQueryCommand struct

+ Database *string

+ Name *string

+ XXX_unrecognized []byte

+ func (*DropContinuousQueryCommand) ProtoMessage()

+ func (m *DropContinuousQueryCommand) GetDatabase() string

+ func (m *DropContinuousQueryCommand) GetName() string

+ func (m *DropContinuousQueryCommand) Reset()

+ func (m *DropContinuousQueryCommand) String() string

+ type DropDatabaseCommand struct

+ Name *string

+ XXX_unrecognized []byte

+ func (*DropDatabaseCommand) ProtoMessage()

+ func (m *DropDatabaseCommand) GetName() string

+ func (m *DropDatabaseCommand) Reset()

+ func (m *DropDatabaseCommand) String() string

+ type DropRetentionPolicyCommand struct

+ Database *string

+ Name *string

+ XXX_unrecognized []byte

+ func (*DropRetentionPolicyCommand) ProtoMessage()

+ func (m *DropRetentionPolicyCommand) GetDatabase() string

+ func (m *DropRetentionPolicyCommand) GetName() string

+ func (m *DropRetentionPolicyCommand) Reset()

+ func (m *DropRetentionPolicyCommand) String() string

+ type DropSubscriptionCommand struct

+ Database *string

+ Name *string

+ RetentionPolicy *string

+ XXX_unrecognized []byte

+ func (*DropSubscriptionCommand) ProtoMessage()

+ func (m *DropSubscriptionCommand) GetDatabase() string

+ func (m *DropSubscriptionCommand) GetName() string

+ func (m *DropSubscriptionCommand) GetRetentionPolicy() string

+ func (m *DropSubscriptionCommand) Reset()

+ func (m *DropSubscriptionCommand) String() string

+ type DropUserCommand struct

+ Name *string

+ XXX_unrecognized []byte

+ func (*DropUserCommand) ProtoMessage()

+ func (m *DropUserCommand) GetName() string

+ func (m *DropUserCommand) Reset()

+ func (m *DropUserCommand) String() string

+ type NodeInfo struct

+ Host *string

+ ID *uint64

+ TCPHost *string

+ XXX_unrecognized []byte

+ func (*NodeInfo) ProtoMessage()

+ func (m *NodeInfo) GetHost() string

+ func (m *NodeInfo) GetID() uint64

+ func (m *NodeInfo) GetTCPHost() string

+ func (m *NodeInfo) Reset()

+ func (m *NodeInfo) String() string

+ type RemovePeerCommand struct

+ Addr *string

+ ID *uint64

+ XXX_unrecognized []byte

+ func (*RemovePeerCommand) ProtoMessage()

+ func (m *RemovePeerCommand) GetAddr() string

+ func (m *RemovePeerCommand) GetID() uint64

+ func (m *RemovePeerCommand) Reset()

+ func (m *RemovePeerCommand) String() string

+ type Response struct

+ Error *string

+ Index *uint64

+ OK *bool

+ XXX_unrecognized []byte

+ func (*Response) ProtoMessage()

+ func (m *Response) GetError() string

+ func (m *Response) GetIndex() uint64

+ func (m *Response) GetOK() bool

+ func (m *Response) Reset()

+ func (m *Response) String() string

+ type RetentionPolicyInfo struct

+ Duration *int64

+ Name *string

+ ReplicaN *uint32

+ ShardGroupDuration *int64

+ ShardGroups []*ShardGroupInfo

+ Subscriptions []*SubscriptionInfo

+ XXX_unrecognized []byte

+ func (*RetentionPolicyInfo) ProtoMessage()

+ 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 (m *RetentionPolicyInfo) GetSubscriptions() []*SubscriptionInfo

+ func (m *RetentionPolicyInfo) Reset()

+ func (m *RetentionPolicyInfo) String() string

+ type SetAdminPrivilegeCommand struct

+ Admin *bool

+ Username *string

+ XXX_unrecognized []byte

+ func (*SetAdminPrivilegeCommand) ProtoMessage()

+ func (m *SetAdminPrivilegeCommand) GetAdmin() bool

+ func (m *SetAdminPrivilegeCommand) GetUsername() string

+ func (m *SetAdminPrivilegeCommand) Reset()

+ func (m *SetAdminPrivilegeCommand) String() string

+ type SetDataCommand struct

+ Data *Data

+ XXX_unrecognized []byte

+ func (*SetDataCommand) ProtoMessage()

+ func (m *SetDataCommand) GetData() *Data

+ func (m *SetDataCommand) Reset()

+ func (m *SetDataCommand) String() string

+ type SetDefaultRetentionPolicyCommand struct

+ Database *string

+ Name *string

+ XXX_unrecognized []byte

+ func (*SetDefaultRetentionPolicyCommand) ProtoMessage()

+ func (m *SetDefaultRetentionPolicyCommand) GetDatabase() string

+ func (m *SetDefaultRetentionPolicyCommand) GetName() string

+ func (m *SetDefaultRetentionPolicyCommand) Reset()

+ func (m *SetDefaultRetentionPolicyCommand) String() string

+ type SetMetaNodeCommand struct

+ HTTPAddr *string

+ Rand *uint64

+ TCPAddr *string

+ XXX_unrecognized []byte

+ func (*SetMetaNodeCommand) ProtoMessage()

+ func (m *SetMetaNodeCommand) GetHTTPAddr() string

+ func (m *SetMetaNodeCommand) GetRand() uint64

+ func (m *SetMetaNodeCommand) GetTCPAddr() string

+ func (m *SetMetaNodeCommand) Reset()

+ func (m *SetMetaNodeCommand) String() string

+ type SetPrivilegeCommand struct

+ Database *string

+ Privilege *int32

+ Username *string

+ XXX_unrecognized []byte

+ func (*SetPrivilegeCommand) ProtoMessage()

+ func (m *SetPrivilegeCommand) GetDatabase() string

+ func (m *SetPrivilegeCommand) GetPrivilege() int32

+ func (m *SetPrivilegeCommand) GetUsername() string

+ func (m *SetPrivilegeCommand) Reset()

+ func (m *SetPrivilegeCommand) String() string

+ type ShardGroupInfo struct

+ DeletedAt *int64

+ EndTime *int64

+ ID *uint64

+ Shards []*ShardInfo

+ StartTime *int64

+ XXX_unrecognized []byte

+ func (*ShardGroupInfo) ProtoMessage()

+ 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 (m *ShardGroupInfo) Reset()

+ func (m *ShardGroupInfo) String() string

+ type ShardInfo struct

+ ID *uint64

+ OwnerIDs []uint64

+ Owners []*ShardOwner

+ XXX_unrecognized []byte

+ func (*ShardInfo) ProtoMessage()

+ func (m *ShardInfo) GetID() uint64

+ func (m *ShardInfo) GetOwnerIDs() []uint64

+ func (m *ShardInfo) GetOwners() []*ShardOwner

+ func (m *ShardInfo) Reset()

+ func (m *ShardInfo) String() string

+ type ShardOwner struct

+ NodeID *uint64

+ XXX_unrecognized []byte

+ func (*ShardOwner) ProtoMessage()

+ func (m *ShardOwner) GetNodeID() uint64

+ func (m *ShardOwner) Reset()

+ func (m *ShardOwner) String() string

+ type SubscriptionInfo struct

+ Destinations []string

+ Mode *string

+ Name *string

+ XXX_unrecognized []byte

+ func (*SubscriptionInfo) ProtoMessage()

+ func (m *SubscriptionInfo) GetDestinations() []string

+ func (m *SubscriptionInfo) GetMode() string

+ func (m *SubscriptionInfo) GetName() string

+ func (m *SubscriptionInfo) Reset()

+ func (m *SubscriptionInfo) String() string

+ type UpdateDataNodeCommand struct

+ Host *string

+ ID *uint64

+ TCPHost *string

+ XXX_unrecognized []byte

+ func (*UpdateDataNodeCommand) ProtoMessage()

+ func (m *UpdateDataNodeCommand) GetHost() string

+ func (m *UpdateDataNodeCommand) GetID() uint64

+ func (m *UpdateDataNodeCommand) GetTCPHost() string

+ func (m *UpdateDataNodeCommand) Reset()

+ func (m *UpdateDataNodeCommand) String() string

+ type UpdateNodeCommand struct

+ Host *string

+ ID *uint64

+ XXX_unrecognized []byte

+ func (*UpdateNodeCommand) ProtoMessage()

+ func (m *UpdateNodeCommand) GetHost() string

+ func (m *UpdateNodeCommand) GetID() uint64

+ func (m *UpdateNodeCommand) Reset()

+ func (m *UpdateNodeCommand) String() string

+ type UpdateRetentionPolicyCommand struct

+ Database *string

+ Duration *int64

+ Name *string

+ NewName *string

+ ReplicaN *uint32

+ XXX_unrecognized []byte

+ func (*UpdateRetentionPolicyCommand) ProtoMessage()

+ 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 (m *UpdateRetentionPolicyCommand) Reset()

+ func (m *UpdateRetentionPolicyCommand) String() string

+ type UpdateUserCommand struct

+ Hash *string

+ Name *string

+ XXX_unrecognized []byte

+ func (*UpdateUserCommand) ProtoMessage()

+ func (m *UpdateUserCommand) GetHash() string

+ func (m *UpdateUserCommand) GetName() string

+ func (m *UpdateUserCommand) Reset()

+ func (m *UpdateUserCommand) String() string

+ type UserInfo struct

+ Admin *bool

+ Hash *string

+ Name *string

+ Privileges []*UserPrivilege

+ XXX_unrecognized []byte

+ func (*UserInfo) ProtoMessage()

+ func (m *UserInfo) GetAdmin() bool

+ func (m *UserInfo) GetHash() string

+ func (m *UserInfo) GetName() string

+ func (m *UserInfo) GetPrivileges() []*UserPrivilege

+ func (m *UserInfo) Reset()

+ func (m *UserInfo) String() string

+ type UserPrivilege struct

+ Database *string

+ Privilege *int32

+ XXX_unrecognized []byte

+ func (*UserPrivilege) ProtoMessage()

+ func (m *UserPrivilege) GetDatabase() string

+ func (m *UserPrivilege) GetPrivilege() int32

+ func (m *UserPrivilege) Reset()

+ func (m *UserPrivilege) String() string