Versions in this module Expand all Collapse all v1 v1.2.0 Feb 29, 2024 Changes in this version + var Command_Type_name = map[int32]string + var Command_Type_value = map[string]int32 + var E_AlterShardKeyCmd_Command = &proto.ExtensionDesc + var E_ContinuousQueryReportCommand_Command = &proto.ExtensionDesc + var E_CreateContinuousQueryCommand_Command = &proto.ExtensionDesc + var E_CreateDataNodeCommand_Command = &proto.ExtensionDesc + var E_CreateDatabaseCommand_Command = &proto.ExtensionDesc + var E_CreateDbPtViewCommand_Command = &proto.ExtensionDesc + var E_CreateDownSamplePolicyCommand_Command = &proto.ExtensionDesc + var E_CreateEventCommand_Command = &proto.ExtensionDesc + var E_CreateMeasurementCommand_Command = &proto.ExtensionDesc + var E_CreateMetaNodeCommand_Command = &proto.ExtensionDesc + var E_CreateRetentionPolicyCommand_Command = &proto.ExtensionDesc + var E_CreateShardGroupCommand_Command = &proto.ExtensionDesc + var E_CreateStreamCommand_Command = &proto.ExtensionDesc + var E_CreateSubscriptionCommand_Command = &proto.ExtensionDesc + var E_CreateUserCommand_Command = &proto.ExtensionDesc + var E_DeleteDataNodeCommand_Command = &proto.ExtensionDesc + var E_DeleteIndexGroupCommand_Command = &proto.ExtensionDesc + var E_DeleteMetaNodeCommand_Command = &proto.ExtensionDesc + var E_DeleteShardGroupCommand_Command = &proto.ExtensionDesc + var E_DropContinuousQueryCommand_Command = &proto.ExtensionDesc + var E_DropDatabaseCommand_Command = &proto.ExtensionDesc + var E_DropDownSamplePolicyCommand_Command = &proto.ExtensionDesc + var E_DropMeasurementCommand_Command = &proto.ExtensionDesc + var E_DropRetentionPolicyCommand_Command = &proto.ExtensionDesc + var E_DropShardCommand_Command = &proto.ExtensionDesc + var E_DropStreamCommand_Command = &proto.ExtensionDesc + var E_DropSubscriptionCommand_Command = &proto.ExtensionDesc + var E_DropUserCommand_Command = &proto.ExtensionDesc + var E_ExpandGroupsCommand_Command = &proto.ExtensionDesc + var E_GetContinuousQueryLeaseCommand_Command = &proto.ExtensionDesc + var E_GetDownSamplePolicyCommand_Command = &proto.ExtensionDesc + var E_GetMeasurementInfoStoreCommand_Command = &proto.ExtensionDesc + var E_GetMeasurementInfoWithinSameRpCommand_Command = &proto.ExtensionDesc + var E_GetMeasurementsInfoCommand_Command = &proto.ExtensionDesc + var E_MarkBalancerCommand_Command = &proto.ExtensionDesc + var E_MarkDatabaseDeleteCommand_Command = &proto.ExtensionDesc + var E_MarkMeasurementDeleteCommand_Command = &proto.ExtensionDesc + var E_MarkRetentionPolicyDeleteCommand_Command = &proto.ExtensionDesc + var E_MarkTakeoverCommand_Command = &proto.ExtensionDesc + var E_NotifyCQLeaseChangedCommand_Command = &proto.ExtensionDesc + var E_PruneGroupsCommand_Command = &proto.ExtensionDesc + var E_ReShardingCommand_Command = &proto.ExtensionDesc + var E_RegisterQueryIDOffsetCommand_Command = &proto.ExtensionDesc + var E_RemoveEventCommand_Command = &proto.ExtensionDesc + var E_RemoveNodeCommand_Command = &proto.ExtensionDesc + var E_ReportShardsLoadCommand_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_SetNodeSegregateStatusCommand_Command = &proto.ExtensionDesc + var E_SetPrivilegeCommand_Command = &proto.ExtensionDesc + var E_ShardDurationCommand_Command = &proto.ExtensionDesc + var E_Sql2MetaHeartbeatCommand_Command = &proto.ExtensionDesc + var E_TimeRangeCommand_Command = &proto.ExtensionDesc + var E_UpdateDbPtStatusCommand_Command = &proto.ExtensionDesc + var E_UpdateEventCommand_Command = &proto.ExtensionDesc + var E_UpdateMeasurementCommand_Command = &proto.ExtensionDesc + var E_UpdateNodeStatusCommand_Command = &proto.ExtensionDesc + var E_UpdatePtInfoCommand_Command = &proto.ExtensionDesc + var E_UpdatePtVersionCommand_Command = &proto.ExtensionDesc + var E_UpdateReplicationCommand_Command = &proto.ExtensionDesc + var E_UpdateRetentionPolicyCommand_Command = &proto.ExtensionDesc + var E_UpdateSchemaCommand_Command = &proto.ExtensionDesc + var E_UpdateShardDownSampleInfoCommand_Command = &proto.ExtensionDesc + var E_UpdateShardInfoTierCommand_Command = &proto.ExtensionDesc + var E_UpdateShardOwnerCommand_Command = &proto.ExtensionDesc + var E_UpdateUserCommand_Command = &proto.ExtensionDesc + var E_VerifyDataNodeCommand_Command = &proto.ExtensionDesc + type AlterShardKeyCmd struct + DBName *string + Name *string + RpName *string + Ski *ShardKeyInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AlterShardKeyCmd) Descriptor() ([]byte, []int) + func (*AlterShardKeyCmd) ProtoMessage() + func (m *AlterShardKeyCmd) GetDBName() string + func (m *AlterShardKeyCmd) GetName() string + func (m *AlterShardKeyCmd) GetRpName() string + func (m *AlterShardKeyCmd) GetSki() *ShardKeyInfo + func (m *AlterShardKeyCmd) Reset() + func (m *AlterShardKeyCmd) String() string + func (m *AlterShardKeyCmd) XXX_DiscardUnknown() + func (m *AlterShardKeyCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AlterShardKeyCmd) XXX_Merge(src proto.Message) + func (m *AlterShardKeyCmd) XXX_Size() int + func (m *AlterShardKeyCmd) XXX_Unmarshal(b []byte) error + type CQState struct + LastRunTime *int64 + Name *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CQState) Descriptor() ([]byte, []int) + func (*CQState) ProtoMessage() + func (m *CQState) GetLastRunTime() int64 + func (m *CQState) GetName() string + func (m *CQState) Reset() + func (m *CQState) String() string + func (m *CQState) XXX_DiscardUnknown() + func (m *CQState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CQState) XXX_Merge(src proto.Message) + func (m *CQState) XXX_Size() int + func (m *CQState) XXX_Unmarshal(b []byte) error + type CardinalityInfo struct + Cardinality *uint64 + TimeRange *TimeRangeInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CardinalityInfo) Descriptor() ([]byte, []int) + func (*CardinalityInfo) ProtoMessage() + func (m *CardinalityInfo) GetCardinality() uint64 + func (m *CardinalityInfo) GetTimeRange() *TimeRangeInfo + func (m *CardinalityInfo) Reset() + func (m *CardinalityInfo) String() string + func (m *CardinalityInfo) XXX_DiscardUnknown() + func (m *CardinalityInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CardinalityInfo) XXX_Merge(src proto.Message) + func (m *CardinalityInfo) XXX_Size() int + func (m *CardinalityInfo) XXX_Unmarshal(b []byte) error + type CardinalityResponse struct + Err *string + Infos []*MeasurementCardinalityInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CardinalityResponse) Descriptor() ([]byte, []int) + func (*CardinalityResponse) ProtoMessage() + func (m *CardinalityResponse) GetErr() string + func (m *CardinalityResponse) GetInfos() []*MeasurementCardinalityInfo + func (m *CardinalityResponse) Reset() + func (m *CardinalityResponse) String() string + func (m *CardinalityResponse) XXX_DiscardUnknown() + func (m *CardinalityResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CardinalityResponse) XXX_Merge(src proto.Message) + func (m *CardinalityResponse) XXX_Size() int + func (m *CardinalityResponse) XXX_Unmarshal(b []byte) error + type ColStoreInfo struct + CompactionType *int32 + PrimaryKey []string + PropertyKey []string + PropertyValue []string + SortKey []string + TimeClusterDuration *int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ColStoreInfo) Descriptor() ([]byte, []int) + func (*ColStoreInfo) ProtoMessage() + func (m *ColStoreInfo) GetCompactionType() int32 + func (m *ColStoreInfo) GetPrimaryKey() []string + func (m *ColStoreInfo) GetPropertyKey() []string + func (m *ColStoreInfo) GetPropertyValue() []string + func (m *ColStoreInfo) GetSortKey() []string + func (m *ColStoreInfo) GetTimeClusterDuration() int64 + func (m *ColStoreInfo) Reset() + func (m *ColStoreInfo) String() string + func (m *ColStoreInfo) XXX_DiscardUnknown() + func (m *ColStoreInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ColStoreInfo) XXX_Merge(src proto.Message) + func (m *ColStoreInfo) XXX_Size() int + func (m *ColStoreInfo) XXX_Unmarshal(b []byte) error + type Command struct + Type *Command_Type + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Command) Descriptor() ([]byte, []int) + func (*Command) ExtensionRangeArray() []proto.ExtensionRange + func (*Command) ProtoMessage() + func (m *Command) GetType() Command_Type + func (m *Command) Reset() + func (m *Command) String() string + func (m *Command) XXX_DiscardUnknown() + func (m *Command) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Command) XXX_Merge(src proto.Message) + func (m *Command) XXX_Size() int + func (m *Command) XXX_Unmarshal(b []byte) error + type Command_Type int32 + const Command_AlterShardKeyCmd + const Command_ContinuousQueryReportCommand + const Command_CreateContinuousQueryCommand + const Command_CreateDataNodeCommand + const Command_CreateDatabaseCommand + const Command_CreateDbPtViewCommand + const Command_CreateDownSamplePolicyCommand + const Command_CreateEventCommand + const Command_CreateMeasurementCommand + const Command_CreateMetaNodeCommand + const Command_CreateRetentionPolicyCommand + const Command_CreateShardGroupCommand + const Command_CreateStreamCommand + const Command_CreateSubscriptionCommand + const Command_CreateUserCommand + const Command_DeleteDataNodeCommand + const Command_DeleteIndexGroupCommand + const Command_DeleteMetaNodeCommand + const Command_DeleteShardGroupCommand + const Command_DropContinuousQueryCommand + const Command_DropDatabaseCommand + const Command_DropDownSamplePolicyCommand + const Command_DropMeasurementCommand + const Command_DropRetentionPolicyCommand + const Command_DropShardCommand + const Command_DropStreamCommand + const Command_DropSubscriptionCommand + const Command_DropUserCommand + const Command_ExpandGroupsCommand + const Command_GetContinuousQueryLeaseCommand + const Command_GetDBBriefInfoCommand + const Command_GetDownSamplePolicyCommand + const Command_GetMeasurementInfoStoreCommand + const Command_GetMeasurementInfoWithinSameRpCommand + const Command_GetMeasurementsInfoCommand + const Command_MarkBalancerCommand + const Command_MarkDatabaseDeleteCommand + const Command_MarkMeasurementDeleteCommand + const Command_MarkRetentionPolicyDeleteCommand + const Command_MarkTakeoverCommand + const Command_NotifyCQLeaseChangedCommand + const Command_PruneGroupsCommand + const Command_ReShardingCommand + const Command_RegisterQueryIDOffsetCommand + const Command_RemoveEventCommand + const Command_RemoveNodeCommand + const Command_ReportShardsCommand + const Command_SetAdminPrivilegeCommand + const Command_SetDataCommand + const Command_SetDefaultRetentionPolicyCommand + const Command_SetMetaNodeCommand + const Command_SetNodeSegregateStatusCommand + const Command_SetPrivilegeCommand + const Command_ShardDurationCommand + const Command_Sql2MetaHeartbeatCommand + const Command_TimeRangeCommand + const Command_UpdateDataNodeCommand + const Command_UpdateEventCommand + const Command_UpdateMeasurementCommand + const Command_UpdateNodeStatusCommand + const Command_UpdatePtInfoCommand + const Command_UpdatePtVersionCommand + const Command_UpdateReplicationCommand + const Command_UpdateRetentionPolicyCommand + const Command_UpdateSchemaCommand + const Command_UpdateShardDownSampleInfoCommand + const Command_UpdateShardInfoTierCommand + const Command_UpdateShardOwnerCommand + const Command_UpdateUserCommand + const Command_VerifyDataNodeCommand + func (Command_Type) EnumDescriptor() ([]byte, []int) + func (x *Command_Type) UnmarshalJSON(data []byte) error + func (x Command_Type) Enum() *Command_Type + func (x Command_Type) String() string + type ContinuousQueryInfo struct + LastRunTime *int64 + Name *string + Query *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ContinuousQueryInfo) Descriptor() ([]byte, []int) + func (*ContinuousQueryInfo) ProtoMessage() + func (m *ContinuousQueryInfo) GetLastRunTime() int64 + func (m *ContinuousQueryInfo) GetName() string + func (m *ContinuousQueryInfo) GetQuery() string + func (m *ContinuousQueryInfo) Reset() + func (m *ContinuousQueryInfo) String() string + func (m *ContinuousQueryInfo) XXX_DiscardUnknown() + func (m *ContinuousQueryInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ContinuousQueryInfo) XXX_Merge(src proto.Message) + func (m *ContinuousQueryInfo) XXX_Size() int + func (m *ContinuousQueryInfo) XXX_Unmarshal(b []byte) error + type ContinuousQueryReportCommand struct + CQStates []*CQState + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ContinuousQueryReportCommand) Descriptor() ([]byte, []int) + func (*ContinuousQueryReportCommand) ProtoMessage() + func (m *ContinuousQueryReportCommand) GetCQStates() []*CQState + func (m *ContinuousQueryReportCommand) Reset() + func (m *ContinuousQueryReportCommand) String() string + func (m *ContinuousQueryReportCommand) XXX_DiscardUnknown() + func (m *ContinuousQueryReportCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ContinuousQueryReportCommand) XXX_Merge(src proto.Message) + func (m *ContinuousQueryReportCommand) XXX_Size() int + func (m *ContinuousQueryReportCommand) XXX_Unmarshal(b []byte) error + type CreateContinuousQueryCommand struct + Database *string + Name *string + Query *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateContinuousQueryCommand) Descriptor() ([]byte, []int) + 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 + func (m *CreateContinuousQueryCommand) XXX_DiscardUnknown() + func (m *CreateContinuousQueryCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateContinuousQueryCommand) XXX_Merge(src proto.Message) + func (m *CreateContinuousQueryCommand) XXX_Size() int + func (m *CreateContinuousQueryCommand) XXX_Unmarshal(b []byte) error + type CreateDataNodeCommand struct + HTTPAddr *string + Role *string + TCPAddr *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateDataNodeCommand) Descriptor() ([]byte, []int) + func (*CreateDataNodeCommand) ProtoMessage() + func (m *CreateDataNodeCommand) GetHTTPAddr() string + func (m *CreateDataNodeCommand) GetRole() string + func (m *CreateDataNodeCommand) GetTCPAddr() string + func (m *CreateDataNodeCommand) Reset() + func (m *CreateDataNodeCommand) String() string + func (m *CreateDataNodeCommand) XXX_DiscardUnknown() + func (m *CreateDataNodeCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateDataNodeCommand) XXX_Merge(src proto.Message) + func (m *CreateDataNodeCommand) XXX_Size() int + func (m *CreateDataNodeCommand) XXX_Unmarshal(b []byte) error + type CreateDatabaseCommand struct + EnableTagArray *bool + Name *string + Options *ObsOptions + ReplicaNum *uint32 + RetentionPolicy *RetentionPolicyInfo + Ski *ShardKeyInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateDatabaseCommand) Descriptor() ([]byte, []int) + func (*CreateDatabaseCommand) ProtoMessage() + func (m *CreateDatabaseCommand) GetEnableTagArray() bool + func (m *CreateDatabaseCommand) GetName() string + func (m *CreateDatabaseCommand) GetOptions() *ObsOptions + func (m *CreateDatabaseCommand) GetReplicaNum() uint32 + func (m *CreateDatabaseCommand) GetRetentionPolicy() *RetentionPolicyInfo + func (m *CreateDatabaseCommand) GetSki() *ShardKeyInfo + func (m *CreateDatabaseCommand) Reset() + func (m *CreateDatabaseCommand) String() string + func (m *CreateDatabaseCommand) XXX_DiscardUnknown() + func (m *CreateDatabaseCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateDatabaseCommand) XXX_Merge(src proto.Message) + func (m *CreateDatabaseCommand) XXX_Size() int + func (m *CreateDatabaseCommand) XXX_Unmarshal(b []byte) error + type CreateDbPtViewCommand struct + DbName *string + ReplicaNum *uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateDbPtViewCommand) Descriptor() ([]byte, []int) + func (*CreateDbPtViewCommand) ProtoMessage() + func (m *CreateDbPtViewCommand) GetDbName() string + func (m *CreateDbPtViewCommand) GetReplicaNum() uint32 + func (m *CreateDbPtViewCommand) Reset() + func (m *CreateDbPtViewCommand) String() string + func (m *CreateDbPtViewCommand) XXX_DiscardUnknown() + func (m *CreateDbPtViewCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateDbPtViewCommand) XXX_Merge(src proto.Message) + func (m *CreateDbPtViewCommand) XXX_Size() int + func (m *CreateDbPtViewCommand) XXX_Unmarshal(b []byte) error + type CreateDownSamplePolicyCommand struct + Database *string + DownSamplePolicyInfo *DownSamplePolicyInfo + Name *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateDownSamplePolicyCommand) Descriptor() ([]byte, []int) + func (*CreateDownSamplePolicyCommand) ProtoMessage() + func (m *CreateDownSamplePolicyCommand) GetDatabase() string + func (m *CreateDownSamplePolicyCommand) GetDownSamplePolicyInfo() *DownSamplePolicyInfo + func (m *CreateDownSamplePolicyCommand) GetName() string + func (m *CreateDownSamplePolicyCommand) Reset() + func (m *CreateDownSamplePolicyCommand) String() string + func (m *CreateDownSamplePolicyCommand) XXX_DiscardUnknown() + func (m *CreateDownSamplePolicyCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateDownSamplePolicyCommand) XXX_Merge(src proto.Message) + func (m *CreateDownSamplePolicyCommand) XXX_Size() int + func (m *CreateDownSamplePolicyCommand) XXX_Unmarshal(b []byte) error + type CreateEventCommand struct + EventInfo *MigrateEventInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateEventCommand) Descriptor() ([]byte, []int) + func (*CreateEventCommand) ProtoMessage() + func (m *CreateEventCommand) GetEventInfo() *MigrateEventInfo + func (m *CreateEventCommand) Reset() + func (m *CreateEventCommand) String() string + func (m *CreateEventCommand) XXX_DiscardUnknown() + func (m *CreateEventCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateEventCommand) XXX_Merge(src proto.Message) + func (m *CreateEventCommand) XXX_Size() int + func (m *CreateEventCommand) XXX_Unmarshal(b []byte) error + type CreateMeasurementCommand struct + ColStoreInfo *ColStoreInfo + DBName *string + EngineType *uint32 + IR *IndexRelation + Name *string + Options *Options + RpName *string + SchemaInfo []*FieldSchema + Ski *ShardKeyInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateMeasurementCommand) Descriptor() ([]byte, []int) + func (*CreateMeasurementCommand) ProtoMessage() + func (m *CreateMeasurementCommand) GetColStoreInfo() *ColStoreInfo + func (m *CreateMeasurementCommand) GetDBName() string + func (m *CreateMeasurementCommand) GetEngineType() uint32 + func (m *CreateMeasurementCommand) GetIR() *IndexRelation + func (m *CreateMeasurementCommand) GetName() string + func (m *CreateMeasurementCommand) GetOptions() *Options + func (m *CreateMeasurementCommand) GetRpName() string + func (m *CreateMeasurementCommand) GetSchemaInfo() []*FieldSchema + func (m *CreateMeasurementCommand) GetSki() *ShardKeyInfo + func (m *CreateMeasurementCommand) Reset() + func (m *CreateMeasurementCommand) String() string + func (m *CreateMeasurementCommand) XXX_DiscardUnknown() + func (m *CreateMeasurementCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateMeasurementCommand) XXX_Merge(src proto.Message) + func (m *CreateMeasurementCommand) XXX_Size() int + func (m *CreateMeasurementCommand) XXX_Unmarshal(b []byte) error + type CreateMetaNodeCommand struct + HTTPAddr *string + RPCAddr *string + Rand *uint64 + TCPAddr *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateMetaNodeCommand) Descriptor() ([]byte, []int) + func (*CreateMetaNodeCommand) ProtoMessage() + func (m *CreateMetaNodeCommand) GetHTTPAddr() string + func (m *CreateMetaNodeCommand) GetRPCAddr() string + func (m *CreateMetaNodeCommand) GetRand() uint64 + func (m *CreateMetaNodeCommand) GetTCPAddr() string + func (m *CreateMetaNodeCommand) Reset() + func (m *CreateMetaNodeCommand) String() string + func (m *CreateMetaNodeCommand) XXX_DiscardUnknown() + func (m *CreateMetaNodeCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateMetaNodeCommand) XXX_Merge(src proto.Message) + func (m *CreateMetaNodeCommand) XXX_Size() int + func (m *CreateMetaNodeCommand) XXX_Unmarshal(b []byte) error + type CreateRetentionPolicyCommand struct + Database *string + DefaultRP *bool + RetentionPolicy *RetentionPolicyInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateRetentionPolicyCommand) Descriptor() ([]byte, []int) + func (*CreateRetentionPolicyCommand) ProtoMessage() + func (m *CreateRetentionPolicyCommand) GetDatabase() string + func (m *CreateRetentionPolicyCommand) GetDefaultRP() bool + func (m *CreateRetentionPolicyCommand) GetRetentionPolicy() *RetentionPolicyInfo + func (m *CreateRetentionPolicyCommand) Reset() + func (m *CreateRetentionPolicyCommand) String() string + func (m *CreateRetentionPolicyCommand) XXX_DiscardUnknown() + func (m *CreateRetentionPolicyCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateRetentionPolicyCommand) XXX_Merge(src proto.Message) + func (m *CreateRetentionPolicyCommand) XXX_Size() int + func (m *CreateRetentionPolicyCommand) XXX_Unmarshal(b []byte) error + type CreateShardGroupCommand struct + Database *string + EngineType *uint32 + Policy *string + ShardTier *uint64 + Timestamp *int64 + Version *uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateShardGroupCommand) Descriptor() ([]byte, []int) + func (*CreateShardGroupCommand) ProtoMessage() + func (m *CreateShardGroupCommand) GetDatabase() string + func (m *CreateShardGroupCommand) GetEngineType() uint32 + func (m *CreateShardGroupCommand) GetPolicy() string + func (m *CreateShardGroupCommand) GetShardTier() uint64 + func (m *CreateShardGroupCommand) GetTimestamp() int64 + func (m *CreateShardGroupCommand) GetVersion() uint32 + func (m *CreateShardGroupCommand) Reset() + func (m *CreateShardGroupCommand) String() string + func (m *CreateShardGroupCommand) XXX_DiscardUnknown() + func (m *CreateShardGroupCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateShardGroupCommand) XXX_Merge(src proto.Message) + func (m *CreateShardGroupCommand) XXX_Size() int + func (m *CreateShardGroupCommand) XXX_Unmarshal(b []byte) error + type CreateStreamCommand struct + StreamInfo *StreamInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateStreamCommand) Descriptor() ([]byte, []int) + func (*CreateStreamCommand) ProtoMessage() + func (m *CreateStreamCommand) GetStreamInfo() *StreamInfo + func (m *CreateStreamCommand) Reset() + func (m *CreateStreamCommand) String() string + func (m *CreateStreamCommand) XXX_DiscardUnknown() + func (m *CreateStreamCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateStreamCommand) XXX_Merge(src proto.Message) + func (m *CreateStreamCommand) XXX_Size() int + func (m *CreateStreamCommand) XXX_Unmarshal(b []byte) error + type CreateSubscriptionCommand struct + Database *string + Destinations []string + Mode *string + Name *string + RetentionPolicy *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateSubscriptionCommand) Descriptor() ([]byte, []int) + 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 + func (m *CreateSubscriptionCommand) XXX_DiscardUnknown() + func (m *CreateSubscriptionCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateSubscriptionCommand) XXX_Merge(src proto.Message) + func (m *CreateSubscriptionCommand) XXX_Size() int + func (m *CreateSubscriptionCommand) XXX_Unmarshal(b []byte) error + type CreateUserCommand struct + Admin *bool + Hash *string + Name *string + RwUser *bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateUserCommand) Descriptor() ([]byte, []int) + func (*CreateUserCommand) ProtoMessage() + func (m *CreateUserCommand) GetAdmin() bool + func (m *CreateUserCommand) GetHash() string + func (m *CreateUserCommand) GetName() string + func (m *CreateUserCommand) GetRwUser() bool + func (m *CreateUserCommand) Reset() + func (m *CreateUserCommand) String() string + func (m *CreateUserCommand) XXX_DiscardUnknown() + func (m *CreateUserCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateUserCommand) XXX_Merge(src proto.Message) + func (m *CreateUserCommand) XXX_Size() int + func (m *CreateUserCommand) XXX_Unmarshal(b []byte) error + type DBPtInfo struct + DbPt []*PtInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DBPtInfo) Descriptor() ([]byte, []int) + func (*DBPtInfo) ProtoMessage() + func (m *DBPtInfo) GetDbPt() []*PtInfo + func (m *DBPtInfo) Reset() + func (m *DBPtInfo) String() string + func (m *DBPtInfo) XXX_DiscardUnknown() + func (m *DBPtInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DBPtInfo) XXX_Merge(src proto.Message) + func (m *DBPtInfo) XXX_Size() int + func (m *DBPtInfo) XXX_Unmarshal(b []byte) error + type DBPtStatus struct + DB *string + PtID *uint32 + RpStats []*RpShardStatus + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DBPtStatus) Descriptor() ([]byte, []int) + func (*DBPtStatus) ProtoMessage() + func (m *DBPtStatus) GetDB() string + func (m *DBPtStatus) GetPtID() uint32 + func (m *DBPtStatus) GetRpStats() []*RpShardStatus + func (m *DBPtStatus) Reset() + func (m *DBPtStatus) String() string + func (m *DBPtStatus) XXX_DiscardUnknown() + func (m *DBPtStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DBPtStatus) XXX_Merge(src proto.Message) + func (m *DBPtStatus) XXX_Size() int + func (m *DBPtStatus) XXX_Unmarshal(b []byte) error + type Data struct + BalancerEnabled *bool + ClusterID *uint64 + ClusterPtNum *uint32 + DataNodes []*DataNode + Databases []*DatabaseInfo + Index *uint64 + MaxCQChangeID *uint64 + MaxConnId *uint64 + MaxDownSampleID *uint64 + MaxEventOpId *uint64 + MaxIndexGroupID *uint64 + MaxIndexID *uint64 + MaxNodeID *uint64 + MaxShardGroupID *uint64 + MaxShardID *uint64 + MaxStreamID *uint64 + MaxSubscriptionID *uint64 + MetaNodes []*NodeInfo + MigrateEvents []*MigrateEventInfo + Nodes []*NodeInfo + PtNumPerNode *uint32 + PtView map[string]*DBPtInfo + QueryIDInit map[string]uint64 + ReplicaGroups map[string]*Replications + Streams []*StreamInfo + TakeOverEnabled *bool + Term *uint64 + Users []*UserInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Data) Descriptor() ([]byte, []int) + func (*Data) ProtoMessage() + func (m *Data) GetBalancerEnabled() bool + func (m *Data) GetClusterID() uint64 + func (m *Data) GetClusterPtNum() uint32 + func (m *Data) GetDataNodes() []*DataNode + func (m *Data) GetDatabases() []*DatabaseInfo + func (m *Data) GetIndex() uint64 + func (m *Data) GetMaxCQChangeID() uint64 + func (m *Data) GetMaxConnId() uint64 + func (m *Data) GetMaxDownSampleID() uint64 + func (m *Data) GetMaxEventOpId() uint64 + func (m *Data) GetMaxIndexGroupID() uint64 + func (m *Data) GetMaxIndexID() uint64 + func (m *Data) GetMaxNodeID() uint64 + func (m *Data) GetMaxShardGroupID() uint64 + func (m *Data) GetMaxShardID() uint64 + func (m *Data) GetMaxStreamID() uint64 + func (m *Data) GetMaxSubscriptionID() uint64 + func (m *Data) GetMetaNodes() []*NodeInfo + func (m *Data) GetMigrateEvents() []*MigrateEventInfo + func (m *Data) GetNodes() []*NodeInfo + func (m *Data) GetPtNumPerNode() uint32 + func (m *Data) GetPtView() map[string]*DBPtInfo + func (m *Data) GetQueryIDInit() map[string]uint64 + func (m *Data) GetReplicaGroups() map[string]*Replications + func (m *Data) GetStreams() []*StreamInfo + func (m *Data) GetTakeOverEnabled() bool + func (m *Data) GetTerm() uint64 + func (m *Data) GetUsers() []*UserInfo + func (m *Data) Reset() + func (m *Data) String() string + func (m *Data) XXX_DiscardUnknown() + func (m *Data) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Data) XXX_Merge(src proto.Message) + func (m *Data) XXX_Size() int + func (m *Data) XXX_Unmarshal(b []byte) error + type DataNode struct + AliveConnID *uint64 + ConnID *uint64 + Ni *NodeInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DataNode) Descriptor() ([]byte, []int) + func (*DataNode) ProtoMessage() + func (m *DataNode) GetAliveConnID() uint64 + func (m *DataNode) GetConnID() uint64 + func (m *DataNode) GetNi() *NodeInfo + func (m *DataNode) Reset() + func (m *DataNode) String() string + func (m *DataNode) XXX_DiscardUnknown() + func (m *DataNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DataNode) XXX_Merge(src proto.Message) + func (m *DataNode) XXX_Size() int + func (m *DataNode) XXX_Unmarshal(b []byte) error + type DataNodeEvent struct + EventType *int64 + Host []byte + LTime *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DataNodeEvent) Descriptor() ([]byte, []int) + func (*DataNodeEvent) ProtoMessage() + func (m *DataNodeEvent) GetEventType() int64 + func (m *DataNodeEvent) GetHost() []byte + func (m *DataNodeEvent) GetLTime() uint64 + func (m *DataNodeEvent) Reset() + func (m *DataNodeEvent) String() string + func (m *DataNodeEvent) XXX_DiscardUnknown() + func (m *DataNodeEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DataNodeEvent) XXX_Merge(src proto.Message) + func (m *DataNodeEvent) XXX_Size() int + func (m *DataNodeEvent) XXX_Unmarshal(b []byte) error + type DatabaseBriefInfo struct + EnableTagArray *bool + Name *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DatabaseBriefInfo) Descriptor() ([]byte, []int) + func (*DatabaseBriefInfo) ProtoMessage() + func (m *DatabaseBriefInfo) GetEnableTagArray() bool + func (m *DatabaseBriefInfo) GetName() string + func (m *DatabaseBriefInfo) Reset() + func (m *DatabaseBriefInfo) String() string + func (m *DatabaseBriefInfo) XXX_DiscardUnknown() + func (m *DatabaseBriefInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DatabaseBriefInfo) XXX_Merge(src proto.Message) + func (m *DatabaseBriefInfo) XXX_Size() int + func (m *DatabaseBriefInfo) XXX_Unmarshal(b []byte) error + type DatabaseInfo struct + ContinuousQueries []*ContinuousQueryInfo + DefaultRetentionPolicy *string + EnableTagArray *bool + MarkDeleted *bool + Name *string + Options *ObsOptions + ReplicaN *int64 + RetentionPolicies []*RetentionPolicyInfo + ShardKey *ShardKeyInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DatabaseInfo) Descriptor() ([]byte, []int) + func (*DatabaseInfo) ProtoMessage() + func (m *DatabaseInfo) GetContinuousQueries() []*ContinuousQueryInfo + func (m *DatabaseInfo) GetDefaultRetentionPolicy() string + func (m *DatabaseInfo) GetEnableTagArray() bool + func (m *DatabaseInfo) GetMarkDeleted() bool + func (m *DatabaseInfo) GetName() string + func (m *DatabaseInfo) GetOptions() *ObsOptions + func (m *DatabaseInfo) GetReplicaN() int64 + func (m *DatabaseInfo) GetRetentionPolicies() []*RetentionPolicyInfo + func (m *DatabaseInfo) GetShardKey() *ShardKeyInfo + func (m *DatabaseInfo) Reset() + func (m *DatabaseInfo) String() string + func (m *DatabaseInfo) XXX_DiscardUnknown() + func (m *DatabaseInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DatabaseInfo) XXX_Merge(src proto.Message) + func (m *DatabaseInfo) XXX_Size() int + func (m *DatabaseInfo) XXX_Unmarshal(b []byte) error + type DbPt struct + DBBriefInfo *DatabaseBriefInfo + Db *string + Pt *PtInfo + Shards map[uint64]*ShardDurationInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DbPt) Descriptor() ([]byte, []int) + func (*DbPt) ProtoMessage() + func (m *DbPt) GetDBBriefInfo() *DatabaseBriefInfo + func (m *DbPt) GetDb() string + func (m *DbPt) GetPt() *PtInfo + func (m *DbPt) GetShards() map[uint64]*ShardDurationInfo + func (m *DbPt) Reset() + func (m *DbPt) String() string + func (m *DbPt) XXX_DiscardUnknown() + func (m *DbPt) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DbPt) XXX_Merge(src proto.Message) + func (m *DbPt) XXX_Size() int + func (m *DbPt) XXX_Unmarshal(b []byte) error + type DeleteDataNodeCommand struct + ID *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteDataNodeCommand) Descriptor() ([]byte, []int) + func (*DeleteDataNodeCommand) ProtoMessage() + func (m *DeleteDataNodeCommand) GetID() uint64 + func (m *DeleteDataNodeCommand) Reset() + func (m *DeleteDataNodeCommand) String() string + func (m *DeleteDataNodeCommand) XXX_DiscardUnknown() + func (m *DeleteDataNodeCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteDataNodeCommand) XXX_Merge(src proto.Message) + func (m *DeleteDataNodeCommand) XXX_Size() int + func (m *DeleteDataNodeCommand) XXX_Unmarshal(b []byte) error + type DeleteIndexGroupCommand struct + Database *string + IndexGroupID *uint64 + Policy *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteIndexGroupCommand) Descriptor() ([]byte, []int) + func (*DeleteIndexGroupCommand) ProtoMessage() + func (m *DeleteIndexGroupCommand) GetDatabase() string + func (m *DeleteIndexGroupCommand) GetIndexGroupID() uint64 + func (m *DeleteIndexGroupCommand) GetPolicy() string + func (m *DeleteIndexGroupCommand) Reset() + func (m *DeleteIndexGroupCommand) String() string + func (m *DeleteIndexGroupCommand) XXX_DiscardUnknown() + func (m *DeleteIndexGroupCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteIndexGroupCommand) XXX_Merge(src proto.Message) + func (m *DeleteIndexGroupCommand) XXX_Size() int + func (m *DeleteIndexGroupCommand) XXX_Unmarshal(b []byte) error + type DeleteMetaNodeCommand struct + ID *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteMetaNodeCommand) Descriptor() ([]byte, []int) + func (*DeleteMetaNodeCommand) ProtoMessage() + func (m *DeleteMetaNodeCommand) GetID() uint64 + func (m *DeleteMetaNodeCommand) Reset() + func (m *DeleteMetaNodeCommand) String() string + func (m *DeleteMetaNodeCommand) XXX_DiscardUnknown() + func (m *DeleteMetaNodeCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteMetaNodeCommand) XXX_Merge(src proto.Message) + func (m *DeleteMetaNodeCommand) XXX_Size() int + func (m *DeleteMetaNodeCommand) XXX_Unmarshal(b []byte) error + type DeleteShardGroupCommand struct + Database *string + DeleteType *int32 + DeletedAt *int64 + Policy *string + ShardGroupID *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteShardGroupCommand) Descriptor() ([]byte, []int) + func (*DeleteShardGroupCommand) ProtoMessage() + func (m *DeleteShardGroupCommand) GetDatabase() string + func (m *DeleteShardGroupCommand) GetDeleteType() int32 + func (m *DeleteShardGroupCommand) GetDeletedAt() int64 + func (m *DeleteShardGroupCommand) GetPolicy() string + func (m *DeleteShardGroupCommand) GetShardGroupID() uint64 + func (m *DeleteShardGroupCommand) Reset() + func (m *DeleteShardGroupCommand) String() string + func (m *DeleteShardGroupCommand) XXX_DiscardUnknown() + func (m *DeleteShardGroupCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteShardGroupCommand) XXX_Merge(src proto.Message) + func (m *DeleteShardGroupCommand) XXX_Size() int + func (m *DeleteShardGroupCommand) XXX_Unmarshal(b []byte) error + type DownSampleOperators struct + AggOps []string + DataType *int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DownSampleOperators) Descriptor() ([]byte, []int) + func (*DownSampleOperators) ProtoMessage() + func (m *DownSampleOperators) GetAggOps() []string + func (m *DownSampleOperators) GetDataType() int64 + func (m *DownSampleOperators) Reset() + func (m *DownSampleOperators) String() string + func (m *DownSampleOperators) XXX_DiscardUnknown() + func (m *DownSampleOperators) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DownSampleOperators) XXX_Merge(src proto.Message) + func (m *DownSampleOperators) XXX_Size() int + func (m *DownSampleOperators) XXX_Unmarshal(b []byte) error + type DownSamplePoliciesInfoWithDbRp struct + Infos []*DownSamplePolicyInfoWithDbRp + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DownSamplePoliciesInfoWithDbRp) Descriptor() ([]byte, []int) + func (*DownSamplePoliciesInfoWithDbRp) ProtoMessage() + func (m *DownSamplePoliciesInfoWithDbRp) GetInfos() []*DownSamplePolicyInfoWithDbRp + func (m *DownSamplePoliciesInfoWithDbRp) Reset() + func (m *DownSamplePoliciesInfoWithDbRp) String() string + func (m *DownSamplePoliciesInfoWithDbRp) XXX_DiscardUnknown() + func (m *DownSamplePoliciesInfoWithDbRp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DownSamplePoliciesInfoWithDbRp) XXX_Merge(src proto.Message) + func (m *DownSamplePoliciesInfoWithDbRp) XXX_Size() int + func (m *DownSamplePoliciesInfoWithDbRp) XXX_Unmarshal(b []byte) error + type DownSamplePolicy struct + SampleInterval *int64 + TimeInterval *int64 + WaterMark *int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DownSamplePolicy) Descriptor() ([]byte, []int) + func (*DownSamplePolicy) ProtoMessage() + func (m *DownSamplePolicy) GetSampleInterval() int64 + func (m *DownSamplePolicy) GetTimeInterval() int64 + func (m *DownSamplePolicy) GetWaterMark() int64 + func (m *DownSamplePolicy) Reset() + func (m *DownSamplePolicy) String() string + func (m *DownSamplePolicy) XXX_DiscardUnknown() + func (m *DownSamplePolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DownSamplePolicy) XXX_Merge(src proto.Message) + func (m *DownSamplePolicy) XXX_Size() int + func (m *DownSamplePolicy) XXX_Unmarshal(b []byte) error + type DownSamplePolicyInfo struct + Calls []*DownSampleOperators + DownSamplePolicies []*DownSamplePolicy + Duration *int64 + TaskID *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DownSamplePolicyInfo) Descriptor() ([]byte, []int) + func (*DownSamplePolicyInfo) ProtoMessage() + func (m *DownSamplePolicyInfo) GetCalls() []*DownSampleOperators + func (m *DownSamplePolicyInfo) GetDownSamplePolicies() []*DownSamplePolicy + func (m *DownSamplePolicyInfo) GetDuration() int64 + func (m *DownSamplePolicyInfo) GetTaskID() uint64 + func (m *DownSamplePolicyInfo) Reset() + func (m *DownSamplePolicyInfo) String() string + func (m *DownSamplePolicyInfo) XXX_DiscardUnknown() + func (m *DownSamplePolicyInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DownSamplePolicyInfo) XXX_Merge(src proto.Message) + func (m *DownSamplePolicyInfo) XXX_Size() int + func (m *DownSamplePolicyInfo) XXX_Unmarshal(b []byte) error + type DownSamplePolicyInfoWithDbRp struct + DbName *string + Info *DownSamplePolicyInfo + RpName *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DownSamplePolicyInfoWithDbRp) Descriptor() ([]byte, []int) + func (*DownSamplePolicyInfoWithDbRp) ProtoMessage() + func (m *DownSamplePolicyInfoWithDbRp) GetDbName() string + func (m *DownSamplePolicyInfoWithDbRp) GetInfo() *DownSamplePolicyInfo + func (m *DownSamplePolicyInfoWithDbRp) GetRpName() string + func (m *DownSamplePolicyInfoWithDbRp) Reset() + func (m *DownSamplePolicyInfoWithDbRp) String() string + func (m *DownSamplePolicyInfoWithDbRp) XXX_DiscardUnknown() + func (m *DownSamplePolicyInfoWithDbRp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DownSamplePolicyInfoWithDbRp) XXX_Merge(src proto.Message) + func (m *DownSamplePolicyInfoWithDbRp) XXX_Size() int + func (m *DownSamplePolicyInfoWithDbRp) XXX_Unmarshal(b []byte) error + type DropContinuousQueryCommand struct + Database *string + Name *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DropContinuousQueryCommand) Descriptor() ([]byte, []int) + func (*DropContinuousQueryCommand) ProtoMessage() + func (m *DropContinuousQueryCommand) GetDatabase() string + func (m *DropContinuousQueryCommand) GetName() string + func (m *DropContinuousQueryCommand) Reset() + func (m *DropContinuousQueryCommand) String() string + func (m *DropContinuousQueryCommand) XXX_DiscardUnknown() + func (m *DropContinuousQueryCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DropContinuousQueryCommand) XXX_Merge(src proto.Message) + func (m *DropContinuousQueryCommand) XXX_Size() int + func (m *DropContinuousQueryCommand) XXX_Unmarshal(b []byte) error + type DropDatabaseCommand struct + Name *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DropDatabaseCommand) Descriptor() ([]byte, []int) + func (*DropDatabaseCommand) ProtoMessage() + func (m *DropDatabaseCommand) GetName() string + func (m *DropDatabaseCommand) Reset() + func (m *DropDatabaseCommand) String() string + func (m *DropDatabaseCommand) XXX_DiscardUnknown() + func (m *DropDatabaseCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DropDatabaseCommand) XXX_Merge(src proto.Message) + func (m *DropDatabaseCommand) XXX_Size() int + func (m *DropDatabaseCommand) XXX_Unmarshal(b []byte) error + type DropDownSamplePolicyCommand struct + Database *string + DropAll *bool + RpName *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DropDownSamplePolicyCommand) Descriptor() ([]byte, []int) + func (*DropDownSamplePolicyCommand) ProtoMessage() + func (m *DropDownSamplePolicyCommand) GetDatabase() string + func (m *DropDownSamplePolicyCommand) GetDropAll() bool + func (m *DropDownSamplePolicyCommand) GetRpName() string + func (m *DropDownSamplePolicyCommand) Reset() + func (m *DropDownSamplePolicyCommand) String() string + func (m *DropDownSamplePolicyCommand) XXX_DiscardUnknown() + func (m *DropDownSamplePolicyCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DropDownSamplePolicyCommand) XXX_Merge(src proto.Message) + func (m *DropDownSamplePolicyCommand) XXX_Size() int + func (m *DropDownSamplePolicyCommand) XXX_Unmarshal(b []byte) error + type DropMeasurementCommand struct + Database *string + Measurement *string + Policy *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DropMeasurementCommand) Descriptor() ([]byte, []int) + func (*DropMeasurementCommand) ProtoMessage() + func (m *DropMeasurementCommand) GetDatabase() string + func (m *DropMeasurementCommand) GetMeasurement() string + func (m *DropMeasurementCommand) GetPolicy() string + func (m *DropMeasurementCommand) Reset() + func (m *DropMeasurementCommand) String() string + func (m *DropMeasurementCommand) XXX_DiscardUnknown() + func (m *DropMeasurementCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DropMeasurementCommand) XXX_Merge(src proto.Message) + func (m *DropMeasurementCommand) XXX_Size() int + func (m *DropMeasurementCommand) XXX_Unmarshal(b []byte) error + type DropRetentionPolicyCommand struct + Database *string + Name *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DropRetentionPolicyCommand) Descriptor() ([]byte, []int) + func (*DropRetentionPolicyCommand) ProtoMessage() + func (m *DropRetentionPolicyCommand) GetDatabase() string + func (m *DropRetentionPolicyCommand) GetName() string + func (m *DropRetentionPolicyCommand) Reset() + func (m *DropRetentionPolicyCommand) String() string + func (m *DropRetentionPolicyCommand) XXX_DiscardUnknown() + func (m *DropRetentionPolicyCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DropRetentionPolicyCommand) XXX_Merge(src proto.Message) + func (m *DropRetentionPolicyCommand) XXX_Size() int + func (m *DropRetentionPolicyCommand) XXX_Unmarshal(b []byte) error + type DropShardCommand struct + ID *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DropShardCommand) Descriptor() ([]byte, []int) + func (*DropShardCommand) ProtoMessage() + func (m *DropShardCommand) GetID() uint64 + func (m *DropShardCommand) Reset() + func (m *DropShardCommand) String() string + func (m *DropShardCommand) XXX_DiscardUnknown() + func (m *DropShardCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DropShardCommand) XXX_Merge(src proto.Message) + func (m *DropShardCommand) XXX_Size() int + func (m *DropShardCommand) XXX_Unmarshal(b []byte) error + type DropStreamCommand struct + Name *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DropStreamCommand) Descriptor() ([]byte, []int) + func (*DropStreamCommand) ProtoMessage() + func (m *DropStreamCommand) GetName() string + func (m *DropStreamCommand) Reset() + func (m *DropStreamCommand) String() string + func (m *DropStreamCommand) XXX_DiscardUnknown() + func (m *DropStreamCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DropStreamCommand) XXX_Merge(src proto.Message) + func (m *DropStreamCommand) XXX_Size() int + func (m *DropStreamCommand) XXX_Unmarshal(b []byte) error + type DropSubscriptionCommand struct + Database *string + Name *string + RetentionPolicy *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DropSubscriptionCommand) Descriptor() ([]byte, []int) + 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 + func (m *DropSubscriptionCommand) XXX_DiscardUnknown() + func (m *DropSubscriptionCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DropSubscriptionCommand) XXX_Merge(src proto.Message) + func (m *DropSubscriptionCommand) XXX_Size() int + func (m *DropSubscriptionCommand) XXX_Unmarshal(b []byte) error + type DropUserCommand struct + Name *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DropUserCommand) Descriptor() ([]byte, []int) + func (*DropUserCommand) ProtoMessage() + func (m *DropUserCommand) GetName() string + func (m *DropUserCommand) Reset() + func (m *DropUserCommand) String() string + func (m *DropUserCommand) XXX_DiscardUnknown() + func (m *DropUserCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DropUserCommand) XXX_Merge(src proto.Message) + func (m *DropUserCommand) XXX_Size() int + func (m *DropUserCommand) XXX_Unmarshal(b []byte) error + type DurationDescriptor struct + Duration *int64 + TierDuration *int64 + TierType *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DurationDescriptor) Descriptor() ([]byte, []int) + func (*DurationDescriptor) ProtoMessage() + func (m *DurationDescriptor) GetDuration() int64 + func (m *DurationDescriptor) GetTierDuration() int64 + func (m *DurationDescriptor) GetTierType() uint64 + func (m *DurationDescriptor) Reset() + func (m *DurationDescriptor) String() string + func (m *DurationDescriptor) XXX_DiscardUnknown() + func (m *DurationDescriptor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DurationDescriptor) XXX_Merge(src proto.Message) + func (m *DurationDescriptor) XXX_Size() int + func (m *DurationDescriptor) XXX_Unmarshal(b []byte) error + type ExpandGroupsCommand struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ExpandGroupsCommand) Descriptor() ([]byte, []int) + func (*ExpandGroupsCommand) ProtoMessage() + func (m *ExpandGroupsCommand) Reset() + func (m *ExpandGroupsCommand) String() string + func (m *ExpandGroupsCommand) XXX_DiscardUnknown() + func (m *ExpandGroupsCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ExpandGroupsCommand) XXX_Merge(src proto.Message) + func (m *ExpandGroupsCommand) XXX_Size() int + func (m *ExpandGroupsCommand) XXX_Unmarshal(b []byte) error + type FieldSchema struct + FieldName *string + FieldType *int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*FieldSchema) Descriptor() ([]byte, []int) + func (*FieldSchema) ProtoMessage() + func (m *FieldSchema) GetFieldName() string + func (m *FieldSchema) GetFieldType() int32 + func (m *FieldSchema) Reset() + func (m *FieldSchema) String() string + func (m *FieldSchema) XXX_DiscardUnknown() + func (m *FieldSchema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FieldSchema) XXX_Merge(src proto.Message) + func (m *FieldSchema) XXX_Size() int + func (m *FieldSchema) XXX_Unmarshal(b []byte) error + type GetContinuousQueryLeaseCommand struct + Host *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetContinuousQueryLeaseCommand) Descriptor() ([]byte, []int) + func (*GetContinuousQueryLeaseCommand) ProtoMessage() + func (m *GetContinuousQueryLeaseCommand) GetHost() string + func (m *GetContinuousQueryLeaseCommand) Reset() + func (m *GetContinuousQueryLeaseCommand) String() string + func (m *GetContinuousQueryLeaseCommand) XXX_DiscardUnknown() + func (m *GetContinuousQueryLeaseCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetContinuousQueryLeaseCommand) XXX_Merge(src proto.Message) + func (m *GetContinuousQueryLeaseCommand) XXX_Size() int + func (m *GetContinuousQueryLeaseCommand) XXX_Unmarshal(b []byte) error + type GetDownSamplePolicyCommand struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetDownSamplePolicyCommand) Descriptor() ([]byte, []int) + func (*GetDownSamplePolicyCommand) ProtoMessage() + func (m *GetDownSamplePolicyCommand) Reset() + func (m *GetDownSamplePolicyCommand) String() string + func (m *GetDownSamplePolicyCommand) XXX_DiscardUnknown() + func (m *GetDownSamplePolicyCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetDownSamplePolicyCommand) XXX_Merge(src proto.Message) + func (m *GetDownSamplePolicyCommand) XXX_Size() int + func (m *GetDownSamplePolicyCommand) XXX_Unmarshal(b []byte) error + type GetMeasurementInfoStoreCommand struct + DbName *string + MstName *string + RpName *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetMeasurementInfoStoreCommand) Descriptor() ([]byte, []int) + func (*GetMeasurementInfoStoreCommand) ProtoMessage() + func (m *GetMeasurementInfoStoreCommand) GetDbName() string + func (m *GetMeasurementInfoStoreCommand) GetMstName() string + func (m *GetMeasurementInfoStoreCommand) GetRpName() string + func (m *GetMeasurementInfoStoreCommand) Reset() + func (m *GetMeasurementInfoStoreCommand) String() string + func (m *GetMeasurementInfoStoreCommand) XXX_DiscardUnknown() + func (m *GetMeasurementInfoStoreCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetMeasurementInfoStoreCommand) XXX_Merge(src proto.Message) + func (m *GetMeasurementInfoStoreCommand) XXX_Size() int + func (m *GetMeasurementInfoStoreCommand) XXX_Unmarshal(b []byte) error + type GetMeasurementInfoWithinSameRpCommand struct + DataTypes []int64 + DbName *string + RpName *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetMeasurementInfoWithinSameRpCommand) Descriptor() ([]byte, []int) + func (*GetMeasurementInfoWithinSameRpCommand) ProtoMessage() + func (m *GetMeasurementInfoWithinSameRpCommand) GetDataTypes() []int64 + func (m *GetMeasurementInfoWithinSameRpCommand) GetDbName() string + func (m *GetMeasurementInfoWithinSameRpCommand) GetRpName() string + func (m *GetMeasurementInfoWithinSameRpCommand) Reset() + func (m *GetMeasurementInfoWithinSameRpCommand) String() string + func (m *GetMeasurementInfoWithinSameRpCommand) XXX_DiscardUnknown() + func (m *GetMeasurementInfoWithinSameRpCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetMeasurementInfoWithinSameRpCommand) XXX_Merge(src proto.Message) + func (m *GetMeasurementInfoWithinSameRpCommand) XXX_Size() int + func (m *GetMeasurementInfoWithinSameRpCommand) XXX_Unmarshal(b []byte) error + type GetMeasurementsInfoCommand struct + DbName *string + RpName *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetMeasurementsInfoCommand) Descriptor() ([]byte, []int) + func (*GetMeasurementsInfoCommand) ProtoMessage() + func (m *GetMeasurementsInfoCommand) GetDbName() string + func (m *GetMeasurementsInfoCommand) GetRpName() string + func (m *GetMeasurementsInfoCommand) Reset() + func (m *GetMeasurementsInfoCommand) String() string + func (m *GetMeasurementsInfoCommand) XXX_DiscardUnknown() + func (m *GetMeasurementsInfoCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetMeasurementsInfoCommand) XXX_Merge(src proto.Message) + func (m *GetMeasurementsInfoCommand) XXX_Size() int + func (m *GetMeasurementsInfoCommand) XXX_Unmarshal(b []byte) error + type IndexDescriptor struct + IndexGroupID *uint64 + IndexID *uint64 + TimeRange *TimeRangeInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IndexDescriptor) Descriptor() ([]byte, []int) + func (*IndexDescriptor) ProtoMessage() + func (m *IndexDescriptor) GetIndexGroupID() uint64 + func (m *IndexDescriptor) GetIndexID() uint64 + func (m *IndexDescriptor) GetTimeRange() *TimeRangeInfo + func (m *IndexDescriptor) Reset() + func (m *IndexDescriptor) String() string + func (m *IndexDescriptor) XXX_DiscardUnknown() + func (m *IndexDescriptor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IndexDescriptor) XXX_Merge(src proto.Message) + func (m *IndexDescriptor) XXX_Size() int + func (m *IndexDescriptor) XXX_Unmarshal(b []byte) error + type IndexGroupInfo struct + DeletedAt *int64 + EndTime *int64 + EngineType *uint32 + ID *uint64 + Indexes []*IndexInfo + StartTime *int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IndexGroupInfo) Descriptor() ([]byte, []int) + func (*IndexGroupInfo) ProtoMessage() + func (m *IndexGroupInfo) GetDeletedAt() int64 + func (m *IndexGroupInfo) GetEndTime() int64 + func (m *IndexGroupInfo) GetEngineType() uint32 + func (m *IndexGroupInfo) GetID() uint64 + func (m *IndexGroupInfo) GetIndexes() []*IndexInfo + func (m *IndexGroupInfo) GetStartTime() int64 + func (m *IndexGroupInfo) Reset() + func (m *IndexGroupInfo) String() string + func (m *IndexGroupInfo) XXX_DiscardUnknown() + func (m *IndexGroupInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IndexGroupInfo) XXX_Merge(src proto.Message) + func (m *IndexGroupInfo) XXX_Size() int + func (m *IndexGroupInfo) XXX_Unmarshal(b []byte) error + type IndexInfo struct + ID *uint64 + MarkDelete *bool + OwnerIDs []uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IndexInfo) Descriptor() ([]byte, []int) + func (*IndexInfo) ProtoMessage() + func (m *IndexInfo) GetID() uint64 + func (m *IndexInfo) GetMarkDelete() bool + func (m *IndexInfo) GetOwnerIDs() []uint32 + func (m *IndexInfo) Reset() + func (m *IndexInfo) String() string + func (m *IndexInfo) XXX_DiscardUnknown() + func (m *IndexInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IndexInfo) XXX_Merge(src proto.Message) + func (m *IndexInfo) XXX_Size() int + func (m *IndexInfo) XXX_Unmarshal(b []byte) error + type IndexList struct + IList []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IndexList) Descriptor() ([]byte, []int) + func (*IndexList) ProtoMessage() + func (m *IndexList) GetIList() []string + func (m *IndexList) Reset() + func (m *IndexList) String() string + func (m *IndexList) XXX_DiscardUnknown() + func (m *IndexList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IndexList) XXX_Merge(src proto.Message) + func (m *IndexList) XXX_Size() int + func (m *IndexList) XXX_Unmarshal(b []byte) error + type IndexOption struct + TimeClusterDuration *int64 + Tokenizers *string + Tokens *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IndexOption) Descriptor() ([]byte, []int) + func (*IndexOption) ProtoMessage() + func (m *IndexOption) GetTimeClusterDuration() int64 + func (m *IndexOption) GetTokenizers() string + func (m *IndexOption) GetTokens() string + func (m *IndexOption) Reset() + func (m *IndexOption) String() string + func (m *IndexOption) XXX_DiscardUnknown() + func (m *IndexOption) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IndexOption) XXX_Merge(src proto.Message) + func (m *IndexOption) XXX_Size() int + func (m *IndexOption) XXX_Unmarshal(b []byte) error + type IndexOptions struct + Infos []*IndexOption + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IndexOptions) Descriptor() ([]byte, []int) + func (*IndexOptions) ProtoMessage() + func (m *IndexOptions) GetInfos() []*IndexOption + func (m *IndexOptions) Reset() + func (m *IndexOptions) String() string + func (m *IndexOptions) XXX_DiscardUnknown() + func (m *IndexOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IndexOptions) XXX_Merge(src proto.Message) + func (m *IndexOptions) XXX_Size() int + func (m *IndexOptions) XXX_Unmarshal(b []byte) error + type IndexRelation struct + IndexLists []*IndexList + IndexName []string + IndexOptions []*IndexOptions + Oid []uint32 + Rid *uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IndexRelation) Descriptor() ([]byte, []int) + func (*IndexRelation) ProtoMessage() + func (m *IndexRelation) GetIndexLists() []*IndexList + func (m *IndexRelation) GetIndexName() []string + func (m *IndexRelation) GetIndexOptions() []*IndexOptions + func (m *IndexRelation) GetOid() []uint32 + func (m *IndexRelation) GetRid() uint32 + func (m *IndexRelation) Reset() + func (m *IndexRelation) String() string + func (m *IndexRelation) XXX_DiscardUnknown() + func (m *IndexRelation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IndexRelation) XXX_Merge(src proto.Message) + func (m *IndexRelation) XXX_Size() int + func (m *IndexRelation) XXX_Unmarshal(b []byte) error + type MarkBalancerCommand struct + Enable *bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MarkBalancerCommand) Descriptor() ([]byte, []int) + func (*MarkBalancerCommand) ProtoMessage() + func (m *MarkBalancerCommand) GetEnable() bool + func (m *MarkBalancerCommand) Reset() + func (m *MarkBalancerCommand) String() string + func (m *MarkBalancerCommand) XXX_DiscardUnknown() + func (m *MarkBalancerCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MarkBalancerCommand) XXX_Merge(src proto.Message) + func (m *MarkBalancerCommand) XXX_Size() int + func (m *MarkBalancerCommand) XXX_Unmarshal(b []byte) error + type MarkDatabaseDeleteCommand struct + Name *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MarkDatabaseDeleteCommand) Descriptor() ([]byte, []int) + func (*MarkDatabaseDeleteCommand) ProtoMessage() + func (m *MarkDatabaseDeleteCommand) GetName() string + func (m *MarkDatabaseDeleteCommand) Reset() + func (m *MarkDatabaseDeleteCommand) String() string + func (m *MarkDatabaseDeleteCommand) XXX_DiscardUnknown() + func (m *MarkDatabaseDeleteCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MarkDatabaseDeleteCommand) XXX_Merge(src proto.Message) + func (m *MarkDatabaseDeleteCommand) XXX_Size() int + func (m *MarkDatabaseDeleteCommand) XXX_Unmarshal(b []byte) error + type MarkMeasurementDeleteCommand struct + Database *string + Measurement *string + Policy *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MarkMeasurementDeleteCommand) Descriptor() ([]byte, []int) + func (*MarkMeasurementDeleteCommand) ProtoMessage() + func (m *MarkMeasurementDeleteCommand) GetDatabase() string + func (m *MarkMeasurementDeleteCommand) GetMeasurement() string + func (m *MarkMeasurementDeleteCommand) GetPolicy() string + func (m *MarkMeasurementDeleteCommand) Reset() + func (m *MarkMeasurementDeleteCommand) String() string + func (m *MarkMeasurementDeleteCommand) XXX_DiscardUnknown() + func (m *MarkMeasurementDeleteCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MarkMeasurementDeleteCommand) XXX_Merge(src proto.Message) + func (m *MarkMeasurementDeleteCommand) XXX_Size() int + func (m *MarkMeasurementDeleteCommand) XXX_Unmarshal(b []byte) error + type MarkRetentionPolicyDeleteCommand struct + Database *string + Name *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MarkRetentionPolicyDeleteCommand) Descriptor() ([]byte, []int) + func (*MarkRetentionPolicyDeleteCommand) ProtoMessage() + func (m *MarkRetentionPolicyDeleteCommand) GetDatabase() string + func (m *MarkRetentionPolicyDeleteCommand) GetName() string + func (m *MarkRetentionPolicyDeleteCommand) Reset() + func (m *MarkRetentionPolicyDeleteCommand) String() string + func (m *MarkRetentionPolicyDeleteCommand) XXX_DiscardUnknown() + func (m *MarkRetentionPolicyDeleteCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MarkRetentionPolicyDeleteCommand) XXX_Merge(src proto.Message) + func (m *MarkRetentionPolicyDeleteCommand) XXX_Size() int + func (m *MarkRetentionPolicyDeleteCommand) XXX_Unmarshal(b []byte) error + type MarkTakeoverCommand struct + Enable *bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MarkTakeoverCommand) Descriptor() ([]byte, []int) + func (*MarkTakeoverCommand) ProtoMessage() + func (m *MarkTakeoverCommand) GetEnable() bool + func (m *MarkTakeoverCommand) Reset() + func (m *MarkTakeoverCommand) String() string + func (m *MarkTakeoverCommand) XXX_DiscardUnknown() + func (m *MarkTakeoverCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MarkTakeoverCommand) XXX_Merge(src proto.Message) + func (m *MarkTakeoverCommand) XXX_Size() int + func (m *MarkTakeoverCommand) XXX_Unmarshal(b []byte) error + type MeasurementCardinalityInfo struct + Cardinality []*CardinalityInfo + Name *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MeasurementCardinalityInfo) Descriptor() ([]byte, []int) + func (*MeasurementCardinalityInfo) ProtoMessage() + func (m *MeasurementCardinalityInfo) GetCardinality() []*CardinalityInfo + func (m *MeasurementCardinalityInfo) GetName() string + func (m *MeasurementCardinalityInfo) Reset() + func (m *MeasurementCardinalityInfo) String() string + func (m *MeasurementCardinalityInfo) XXX_DiscardUnknown() + func (m *MeasurementCardinalityInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MeasurementCardinalityInfo) XXX_Merge(src proto.Message) + func (m *MeasurementCardinalityInfo) XXX_Size() int + func (m *MeasurementCardinalityInfo) XXX_Unmarshal(b []byte) error + type MeasurementFieldsInfo struct + MstName *string + TypeFields []*MeasurementTypeFields + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MeasurementFieldsInfo) Descriptor() ([]byte, []int) + func (*MeasurementFieldsInfo) ProtoMessage() + func (m *MeasurementFieldsInfo) GetMstName() string + func (m *MeasurementFieldsInfo) GetTypeFields() []*MeasurementTypeFields + func (m *MeasurementFieldsInfo) Reset() + func (m *MeasurementFieldsInfo) String() string + func (m *MeasurementFieldsInfo) XXX_DiscardUnknown() + func (m *MeasurementFieldsInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MeasurementFieldsInfo) XXX_Merge(src proto.Message) + func (m *MeasurementFieldsInfo) XXX_Size() int + func (m *MeasurementFieldsInfo) XXX_Unmarshal(b []byte) error + type MeasurementInfo struct + ColStoreInfo *ColStoreInfo + EngineType *uint32 + IndexRelation *IndexRelation + MarkDeleted *bool + Name *string + ObsOptions *ObsOptions + Options *Options + Schema map[string]int32 + ShardKeys []*ShardKeyInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MeasurementInfo) Descriptor() ([]byte, []int) + func (*MeasurementInfo) ProtoMessage() + func (m *MeasurementInfo) GetColStoreInfo() *ColStoreInfo + func (m *MeasurementInfo) GetEngineType() uint32 + func (m *MeasurementInfo) GetIndexRelation() *IndexRelation + func (m *MeasurementInfo) GetMarkDeleted() bool + func (m *MeasurementInfo) GetName() string + func (m *MeasurementInfo) GetObsOptions() *ObsOptions + func (m *MeasurementInfo) GetOptions() *Options + func (m *MeasurementInfo) GetSchema() map[string]int32 + func (m *MeasurementInfo) GetShardKeys() []*ShardKeyInfo + func (m *MeasurementInfo) Reset() + func (m *MeasurementInfo) String() string + func (m *MeasurementInfo) XXX_DiscardUnknown() + func (m *MeasurementInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MeasurementInfo) XXX_Merge(src proto.Message) + func (m *MeasurementInfo) XXX_Size() int + func (m *MeasurementInfo) XXX_Unmarshal(b []byte) error + type MeasurementTypeFields struct + Fields []string + Type *int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MeasurementTypeFields) Descriptor() ([]byte, []int) + func (*MeasurementTypeFields) ProtoMessage() + func (m *MeasurementTypeFields) GetFields() []string + func (m *MeasurementTypeFields) GetType() int64 + func (m *MeasurementTypeFields) Reset() + func (m *MeasurementTypeFields) String() string + func (m *MeasurementTypeFields) XXX_DiscardUnknown() + func (m *MeasurementTypeFields) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MeasurementTypeFields) XXX_Merge(src proto.Message) + func (m *MeasurementTypeFields) XXX_Size() int + func (m *MeasurementTypeFields) XXX_Unmarshal(b []byte) error + type MeasurementsInfo struct + MeasurementsInfo []*MeasurementInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MeasurementsInfo) Descriptor() ([]byte, []int) + func (*MeasurementsInfo) ProtoMessage() + func (m *MeasurementsInfo) GetMeasurementsInfo() []*MeasurementInfo + func (m *MeasurementsInfo) Reset() + func (m *MeasurementsInfo) String() string + func (m *MeasurementsInfo) XXX_DiscardUnknown() + func (m *MeasurementsInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MeasurementsInfo) XXX_Merge(src proto.Message) + func (m *MeasurementsInfo) XXX_Size() int + func (m *MeasurementsInfo) XXX_Unmarshal(b []byte) error + type MigrateEventInfo struct + AliveConnId *uint64 + CheckConflict *bool + CurrState *int32 + Dest *uint64 + EventId *string + EventType *int32 + OpId *uint64 + PreState *int32 + Pti *DbPt + Src *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MigrateEventInfo) Descriptor() ([]byte, []int) + func (*MigrateEventInfo) ProtoMessage() + func (m *MigrateEventInfo) GetAliveConnId() uint64 + func (m *MigrateEventInfo) GetCheckConflict() bool + func (m *MigrateEventInfo) GetCurrState() int32 + func (m *MigrateEventInfo) GetDest() uint64 + func (m *MigrateEventInfo) GetEventId() string + func (m *MigrateEventInfo) GetEventType() int32 + func (m *MigrateEventInfo) GetOpId() uint64 + func (m *MigrateEventInfo) GetPreState() int32 + func (m *MigrateEventInfo) GetPti() *DbPt + func (m *MigrateEventInfo) GetSrc() uint64 + func (m *MigrateEventInfo) Reset() + func (m *MigrateEventInfo) String() string + func (m *MigrateEventInfo) XXX_DiscardUnknown() + func (m *MigrateEventInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MigrateEventInfo) XXX_Merge(src proto.Message) + func (m *MigrateEventInfo) XXX_Size() int + func (m *MigrateEventInfo) XXX_Unmarshal(b []byte) error + type NodeInfo struct + GossipAddr *string + Host *string + ID *uint64 + LTime *uint64 + RPCAddr *string + Role *string + SegregateStatus *uint64 + Status *int64 + TCPHost *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*NodeInfo) Descriptor() ([]byte, []int) + func (*NodeInfo) ProtoMessage() + func (m *NodeInfo) GetGossipAddr() string + func (m *NodeInfo) GetHost() string + func (m *NodeInfo) GetID() uint64 + func (m *NodeInfo) GetLTime() uint64 + func (m *NodeInfo) GetRPCAddr() string + func (m *NodeInfo) GetRole() string + func (m *NodeInfo) GetSegregateStatus() uint64 + func (m *NodeInfo) GetStatus() int64 + func (m *NodeInfo) GetTCPHost() string + func (m *NodeInfo) Reset() + func (m *NodeInfo) String() string + func (m *NodeInfo) XXX_DiscardUnknown() + func (m *NodeInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NodeInfo) XXX_Merge(src proto.Message) + func (m *NodeInfo) XXX_Size() int + func (m *NodeInfo) XXX_Unmarshal(b []byte) error + type NodeStartInfo struct + ConnId *uint64 + DBBriefInfo []*DatabaseBriefInfo + DataIndex *uint64 + Durations []*ShardDurationInfo + LTime *uint64 + NodeID *uint64 + PtIds []uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*NodeStartInfo) Descriptor() ([]byte, []int) + func (*NodeStartInfo) ProtoMessage() + func (m *NodeStartInfo) GetConnId() uint64 + func (m *NodeStartInfo) GetDBBriefInfo() []*DatabaseBriefInfo + func (m *NodeStartInfo) GetDataIndex() uint64 + func (m *NodeStartInfo) GetDurations() []*ShardDurationInfo + func (m *NodeStartInfo) GetLTime() uint64 + func (m *NodeStartInfo) GetNodeID() uint64 + func (m *NodeStartInfo) GetPtIds() []uint32 + func (m *NodeStartInfo) Reset() + func (m *NodeStartInfo) String() string + func (m *NodeStartInfo) XXX_DiscardUnknown() + func (m *NodeStartInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NodeStartInfo) XXX_Merge(src proto.Message) + func (m *NodeStartInfo) XXX_Size() int + func (m *NodeStartInfo) XXX_Unmarshal(b []byte) error + type NotifyCQLeaseChangedCommand struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*NotifyCQLeaseChangedCommand) Descriptor() ([]byte, []int) + func (*NotifyCQLeaseChangedCommand) ProtoMessage() + func (m *NotifyCQLeaseChangedCommand) Reset() + func (m *NotifyCQLeaseChangedCommand) String() string + func (m *NotifyCQLeaseChangedCommand) XXX_DiscardUnknown() + func (m *NotifyCQLeaseChangedCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NotifyCQLeaseChangedCommand) XXX_Merge(src proto.Message) + func (m *NotifyCQLeaseChangedCommand) XXX_Size() int + func (m *NotifyCQLeaseChangedCommand) XXX_Unmarshal(b []byte) error + type ObsOptions struct + Ak *string + BasePath *string + BucketName *string + Enabled *bool + Endpoint *string + Sk *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ObsOptions) Descriptor() ([]byte, []int) + func (*ObsOptions) ProtoMessage() + func (m *ObsOptions) GetAk() string + func (m *ObsOptions) GetBasePath() string + func (m *ObsOptions) GetBucketName() string + func (m *ObsOptions) GetEnabled() bool + func (m *ObsOptions) GetEndpoint() string + func (m *ObsOptions) GetSk() string + func (m *ObsOptions) Reset() + func (m *ObsOptions) String() string + func (m *ObsOptions) XXX_DiscardUnknown() + func (m *ObsOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ObsOptions) XXX_Merge(src proto.Message) + func (m *ObsOptions) XXX_Size() int + func (m *ObsOptions) XXX_Unmarshal(b []byte) error + type Options struct + AppendMeta *bool + CaseInSensitive *bool + ReadThreshold *int32 + SplitChar *string + StorageCapacity *int32 + TagsSplit *string + Ttl *int64 + WriteThreshold *int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Options) Descriptor() ([]byte, []int) + func (*Options) ProtoMessage() + func (m *Options) GetAppendMeta() bool + func (m *Options) GetCaseInSensitive() bool + func (m *Options) GetReadThreshold() int32 + func (m *Options) GetSplitChar() string + func (m *Options) GetStorageCapacity() int32 + func (m *Options) GetTagsSplit() string + func (m *Options) GetTtl() int64 + func (m *Options) GetWriteThreshold() int32 + func (m *Options) Reset() + func (m *Options) String() string + func (m *Options) XXX_DiscardUnknown() + func (m *Options) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Options) XXX_Merge(src proto.Message) + func (m *Options) XXX_Size() int + func (m *Options) XXX_Unmarshal(b []byte) error + type Peer struct + ID *uint32 + Role *uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Peer) Descriptor() ([]byte, []int) + func (*Peer) ProtoMessage() + func (m *Peer) GetID() uint32 + func (m *Peer) GetRole() uint32 + func (m *Peer) Reset() + func (m *Peer) String() string + func (m *Peer) XXX_DiscardUnknown() + func (m *Peer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Peer) XXX_Merge(src proto.Message) + func (m *Peer) XXX_Size() int + func (m *Peer) XXX_Unmarshal(b []byte) error + type PruneGroupsCommand struct + ID *uint64 + ShardGroup *bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PruneGroupsCommand) Descriptor() ([]byte, []int) + func (*PruneGroupsCommand) ProtoMessage() + func (m *PruneGroupsCommand) GetID() uint64 + func (m *PruneGroupsCommand) GetShardGroup() bool + func (m *PruneGroupsCommand) Reset() + func (m *PruneGroupsCommand) String() string + func (m *PruneGroupsCommand) XXX_DiscardUnknown() + func (m *PruneGroupsCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PruneGroupsCommand) XXX_Merge(src proto.Message) + func (m *PruneGroupsCommand) XXX_Size() int + func (m *PruneGroupsCommand) XXX_Unmarshal(b []byte) error + type PtInfo struct + Owner *PtOwner + PtId *uint32 + RGID *uint32 + Status *uint32 + Ver *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PtInfo) Descriptor() ([]byte, []int) + func (*PtInfo) ProtoMessage() + func (m *PtInfo) GetOwner() *PtOwner + func (m *PtInfo) GetPtId() uint32 + func (m *PtInfo) GetRGID() uint32 + func (m *PtInfo) GetStatus() uint32 + func (m *PtInfo) GetVer() uint64 + func (m *PtInfo) Reset() + func (m *PtInfo) String() string + func (m *PtInfo) XXX_DiscardUnknown() + func (m *PtInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PtInfo) XXX_Merge(src proto.Message) + func (m *PtInfo) XXX_Size() int + func (m *PtInfo) XXX_Unmarshal(b []byte) error + type PtOwner struct + NodeID *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PtOwner) Descriptor() ([]byte, []int) + func (*PtOwner) ProtoMessage() + func (m *PtOwner) GetNodeID() uint64 + func (m *PtOwner) Reset() + func (m *PtOwner) String() string + func (m *PtOwner) XXX_DiscardUnknown() + func (m *PtOwner) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PtOwner) XXX_Merge(src proto.Message) + func (m *PtOwner) XXX_Size() int + func (m *PtOwner) XXX_Unmarshal(b []byte) error + type ReShardingCommand struct + Database *string + RpName *string + ShardBounds []string + ShardGroupID *uint64 + SplitTime *int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReShardingCommand) Descriptor() ([]byte, []int) + func (*ReShardingCommand) ProtoMessage() + func (m *ReShardingCommand) GetDatabase() string + func (m *ReShardingCommand) GetRpName() string + func (m *ReShardingCommand) GetShardBounds() []string + func (m *ReShardingCommand) GetShardGroupID() uint64 + func (m *ReShardingCommand) GetSplitTime() int64 + func (m *ReShardingCommand) Reset() + func (m *ReShardingCommand) String() string + func (m *ReShardingCommand) XXX_DiscardUnknown() + func (m *ReShardingCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReShardingCommand) XXX_Merge(src proto.Message) + func (m *ReShardingCommand) XXX_Size() int + func (m *ReShardingCommand) XXX_Unmarshal(b []byte) error + type RegisterQueryIDOffsetCommand struct + Host *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RegisterQueryIDOffsetCommand) Descriptor() ([]byte, []int) + func (*RegisterQueryIDOffsetCommand) ProtoMessage() + func (m *RegisterQueryIDOffsetCommand) GetHost() string + func (m *RegisterQueryIDOffsetCommand) Reset() + func (m *RegisterQueryIDOffsetCommand) String() string + func (m *RegisterQueryIDOffsetCommand) XXX_DiscardUnknown() + func (m *RegisterQueryIDOffsetCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RegisterQueryIDOffsetCommand) XXX_Merge(src proto.Message) + func (m *RegisterQueryIDOffsetCommand) XXX_Size() int + func (m *RegisterQueryIDOffsetCommand) XXX_Unmarshal(b []byte) error + type RemoveEventCommand struct + EventId *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RemoveEventCommand) Descriptor() ([]byte, []int) + func (*RemoveEventCommand) ProtoMessage() + func (m *RemoveEventCommand) GetEventId() string + func (m *RemoveEventCommand) Reset() + func (m *RemoveEventCommand) String() string + func (m *RemoveEventCommand) XXX_DiscardUnknown() + func (m *RemoveEventCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RemoveEventCommand) XXX_Merge(src proto.Message) + func (m *RemoveEventCommand) XXX_Size() int + func (m *RemoveEventCommand) XXX_Unmarshal(b []byte) error + type RemoveNodeCommand struct + NodeIds []uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RemoveNodeCommand) Descriptor() ([]byte, []int) + func (*RemoveNodeCommand) ProtoMessage() + func (m *RemoveNodeCommand) GetNodeIds() []uint64 + func (m *RemoveNodeCommand) Reset() + func (m *RemoveNodeCommand) String() string + func (m *RemoveNodeCommand) XXX_DiscardUnknown() + func (m *RemoveNodeCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RemoveNodeCommand) XXX_Merge(src proto.Message) + func (m *RemoveNodeCommand) XXX_Size() int + func (m *RemoveNodeCommand) XXX_Unmarshal(b []byte) error + type ReplicaGroup struct + ID *uint32 + MasterID *uint32 + Peers []*Peer + Status *uint32 + Term *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReplicaGroup) Descriptor() ([]byte, []int) + func (*ReplicaGroup) ProtoMessage() + func (m *ReplicaGroup) GetID() uint32 + func (m *ReplicaGroup) GetMasterID() uint32 + func (m *ReplicaGroup) GetPeers() []*Peer + func (m *ReplicaGroup) GetStatus() uint32 + func (m *ReplicaGroup) GetTerm() uint64 + func (m *ReplicaGroup) Reset() + func (m *ReplicaGroup) String() string + func (m *ReplicaGroup) XXX_DiscardUnknown() + func (m *ReplicaGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReplicaGroup) XXX_Merge(src proto.Message) + func (m *ReplicaGroup) XXX_Size() int + func (m *ReplicaGroup) XXX_Unmarshal(b []byte) error + type Replications struct + Groups []*ReplicaGroup + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Replications) Descriptor() ([]byte, []int) + func (*Replications) ProtoMessage() + func (m *Replications) GetGroups() []*ReplicaGroup + func (m *Replications) Reset() + func (m *Replications) String() string + func (m *Replications) XXX_DiscardUnknown() + func (m *Replications) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Replications) XXX_Merge(src proto.Message) + func (m *Replications) XXX_Size() int + func (m *Replications) XXX_Unmarshal(b []byte) error + type ReportShardsLoadCommand struct + DBPTStat []*DBPtStatus + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReportShardsLoadCommand) Descriptor() ([]byte, []int) + func (*ReportShardsLoadCommand) ProtoMessage() + func (m *ReportShardsLoadCommand) GetDBPTStat() []*DBPtStatus + func (m *ReportShardsLoadCommand) Reset() + func (m *ReportShardsLoadCommand) String() string + func (m *ReportShardsLoadCommand) XXX_DiscardUnknown() + func (m *ReportShardsLoadCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReportShardsLoadCommand) XXX_Merge(src proto.Message) + func (m *ReportShardsLoadCommand) XXX_Size() int + func (m *ReportShardsLoadCommand) XXX_Unmarshal(b []byte) error + type Response struct + Error *string + Index *uint64 + OK *bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Response) Descriptor() ([]byte, []int) + 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 + func (m *Response) XXX_DiscardUnknown() + func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Response) XXX_Merge(src proto.Message) + func (m *Response) XXX_Size() int + func (m *Response) XXX_Unmarshal(b []byte) error + type RetentionPolicyInfo struct + DownSamplePolicyInfo *DownSamplePolicyInfo + Duration *int64 + HotDuration *int64 + IndexGroupDuration *int64 + IndexGroups []*IndexGroupInfo + MarkDeleted *bool + Measurements []*MeasurementInfo + MstVersions map[string]uint32 + Name *string + ReplicaN *uint32 + ShardGroupDuration *int64 + ShardGroups []*ShardGroupInfo + Subscriptions []*SubscriptionInfo + WarmDuration *int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RetentionPolicyInfo) Descriptor() ([]byte, []int) + func (*RetentionPolicyInfo) ProtoMessage() + func (m *RetentionPolicyInfo) GetDownSamplePolicyInfo() *DownSamplePolicyInfo + func (m *RetentionPolicyInfo) GetDuration() int64 + func (m *RetentionPolicyInfo) GetHotDuration() int64 + func (m *RetentionPolicyInfo) GetIndexGroupDuration() int64 + func (m *RetentionPolicyInfo) GetIndexGroups() []*IndexGroupInfo + func (m *RetentionPolicyInfo) GetMarkDeleted() bool + func (m *RetentionPolicyInfo) GetMeasurements() []*MeasurementInfo + func (m *RetentionPolicyInfo) GetMstVersions() map[string]uint32 + 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) GetWarmDuration() int64 + func (m *RetentionPolicyInfo) Reset() + func (m *RetentionPolicyInfo) String() string + func (m *RetentionPolicyInfo) XXX_DiscardUnknown() + func (m *RetentionPolicyInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RetentionPolicyInfo) XXX_Merge(src proto.Message) + func (m *RetentionPolicyInfo) XXX_Size() int + func (m *RetentionPolicyInfo) XXX_Unmarshal(b []byte) error + type RetentionPolicySpec struct + Duration *int64 + Name *string + ReplicaN *uint32 + ShardGroupDuration *int64 + WarmDuration *int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + 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) GetWarmDuration() int64 + func (m *RetentionPolicySpec) Reset() + func (m *RetentionPolicySpec) String() string + func (m *RetentionPolicySpec) XXX_DiscardUnknown() + func (m *RetentionPolicySpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RetentionPolicySpec) XXX_Merge(src proto.Message) + func (m *RetentionPolicySpec) XXX_Size() int + func (m *RetentionPolicySpec) XXX_Unmarshal(b []byte) error + type RpMeasurementsFieldsInfo struct + MeasurementInfos []*MeasurementFieldsInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RpMeasurementsFieldsInfo) Descriptor() ([]byte, []int) + func (*RpMeasurementsFieldsInfo) ProtoMessage() + func (m *RpMeasurementsFieldsInfo) GetMeasurementInfos() []*MeasurementFieldsInfo + func (m *RpMeasurementsFieldsInfo) Reset() + func (m *RpMeasurementsFieldsInfo) String() string + func (m *RpMeasurementsFieldsInfo) XXX_DiscardUnknown() + func (m *RpMeasurementsFieldsInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RpMeasurementsFieldsInfo) XXX_Merge(src proto.Message) + func (m *RpMeasurementsFieldsInfo) XXX_Size() int + func (m *RpMeasurementsFieldsInfo) XXX_Unmarshal(b []byte) error + type RpShardStatus struct + RpName *string + ShardStats *ShardStatus + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RpShardStatus) Descriptor() ([]byte, []int) + func (*RpShardStatus) ProtoMessage() + func (m *RpShardStatus) GetRpName() string + func (m *RpShardStatus) GetShardStats() *ShardStatus + func (m *RpShardStatus) Reset() + func (m *RpShardStatus) String() string + func (m *RpShardStatus) XXX_DiscardUnknown() + func (m *RpShardStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RpShardStatus) XXX_Merge(src proto.Message) + func (m *RpShardStatus) XXX_Size() int + func (m *RpShardStatus) XXX_Unmarshal(b []byte) error + type SetAdminPrivilegeCommand struct + Admin *bool + Username *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SetAdminPrivilegeCommand) Descriptor() ([]byte, []int) + func (*SetAdminPrivilegeCommand) ProtoMessage() + func (m *SetAdminPrivilegeCommand) GetAdmin() bool + func (m *SetAdminPrivilegeCommand) GetUsername() string + func (m *SetAdminPrivilegeCommand) Reset() + func (m *SetAdminPrivilegeCommand) String() string + func (m *SetAdminPrivilegeCommand) XXX_DiscardUnknown() + func (m *SetAdminPrivilegeCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SetAdminPrivilegeCommand) XXX_Merge(src proto.Message) + func (m *SetAdminPrivilegeCommand) XXX_Size() int + func (m *SetAdminPrivilegeCommand) XXX_Unmarshal(b []byte) error + type SetDataCommand struct + Data *Data + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SetDataCommand) Descriptor() ([]byte, []int) + func (*SetDataCommand) ProtoMessage() + func (m *SetDataCommand) GetData() *Data + func (m *SetDataCommand) Reset() + func (m *SetDataCommand) String() string + func (m *SetDataCommand) XXX_DiscardUnknown() + func (m *SetDataCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SetDataCommand) XXX_Merge(src proto.Message) + func (m *SetDataCommand) XXX_Size() int + func (m *SetDataCommand) XXX_Unmarshal(b []byte) error + type SetDefaultRetentionPolicyCommand struct + Database *string + Name *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SetDefaultRetentionPolicyCommand) Descriptor() ([]byte, []int) + func (*SetDefaultRetentionPolicyCommand) ProtoMessage() + func (m *SetDefaultRetentionPolicyCommand) GetDatabase() string + func (m *SetDefaultRetentionPolicyCommand) GetName() string + func (m *SetDefaultRetentionPolicyCommand) Reset() + func (m *SetDefaultRetentionPolicyCommand) String() string + func (m *SetDefaultRetentionPolicyCommand) XXX_DiscardUnknown() + func (m *SetDefaultRetentionPolicyCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SetDefaultRetentionPolicyCommand) XXX_Merge(src proto.Message) + func (m *SetDefaultRetentionPolicyCommand) XXX_Size() int + func (m *SetDefaultRetentionPolicyCommand) XXX_Unmarshal(b []byte) error + type SetMetaNodeCommand struct + HTTPAddr *string + RPCAddr *string + Rand *uint64 + TCPAddr *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SetMetaNodeCommand) Descriptor() ([]byte, []int) + func (*SetMetaNodeCommand) ProtoMessage() + func (m *SetMetaNodeCommand) GetHTTPAddr() string + func (m *SetMetaNodeCommand) GetRPCAddr() string + func (m *SetMetaNodeCommand) GetRand() uint64 + func (m *SetMetaNodeCommand) GetTCPAddr() string + func (m *SetMetaNodeCommand) Reset() + func (m *SetMetaNodeCommand) String() string + func (m *SetMetaNodeCommand) XXX_DiscardUnknown() + func (m *SetMetaNodeCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SetMetaNodeCommand) XXX_Merge(src proto.Message) + func (m *SetMetaNodeCommand) XXX_Size() int + func (m *SetMetaNodeCommand) XXX_Unmarshal(b []byte) error + type SetNodeSegregateStatusCommand struct + NodeIds []uint64 + Status []uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SetNodeSegregateStatusCommand) Descriptor() ([]byte, []int) + func (*SetNodeSegregateStatusCommand) ProtoMessage() + func (m *SetNodeSegregateStatusCommand) GetNodeIds() []uint64 + func (m *SetNodeSegregateStatusCommand) GetStatus() []uint64 + func (m *SetNodeSegregateStatusCommand) Reset() + func (m *SetNodeSegregateStatusCommand) String() string + func (m *SetNodeSegregateStatusCommand) XXX_DiscardUnknown() + func (m *SetNodeSegregateStatusCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SetNodeSegregateStatusCommand) XXX_Merge(src proto.Message) + func (m *SetNodeSegregateStatusCommand) XXX_Size() int + func (m *SetNodeSegregateStatusCommand) XXX_Unmarshal(b []byte) error + type SetPrivilegeCommand struct + Database *string + Privilege *int32 + Username *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SetPrivilegeCommand) Descriptor() ([]byte, []int) + 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 + func (m *SetPrivilegeCommand) XXX_DiscardUnknown() + func (m *SetPrivilegeCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SetPrivilegeCommand) XXX_Merge(src proto.Message) + func (m *SetPrivilegeCommand) XXX_Size() int + func (m *SetPrivilegeCommand) XXX_Unmarshal(b []byte) error + type ShardDownSampleUpdateInfo struct + DownSampleLvl *int64 + Ident *ShardIdentifier + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShardDownSampleUpdateInfo) Descriptor() ([]byte, []int) + func (*ShardDownSampleUpdateInfo) ProtoMessage() + func (m *ShardDownSampleUpdateInfo) GetDownSampleLvl() int64 + func (m *ShardDownSampleUpdateInfo) GetIdent() *ShardIdentifier + func (m *ShardDownSampleUpdateInfo) Reset() + func (m *ShardDownSampleUpdateInfo) String() string + func (m *ShardDownSampleUpdateInfo) XXX_DiscardUnknown() + func (m *ShardDownSampleUpdateInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShardDownSampleUpdateInfo) XXX_Merge(src proto.Message) + func (m *ShardDownSampleUpdateInfo) XXX_Size() int + func (m *ShardDownSampleUpdateInfo) XXX_Unmarshal(b []byte) error + type ShardDownSampleUpdateInfos struct + Infos []*ShardDownSampleUpdateInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShardDownSampleUpdateInfos) Descriptor() ([]byte, []int) + func (*ShardDownSampleUpdateInfos) ProtoMessage() + func (m *ShardDownSampleUpdateInfos) GetInfos() []*ShardDownSampleUpdateInfo + func (m *ShardDownSampleUpdateInfos) Reset() + func (m *ShardDownSampleUpdateInfos) String() string + func (m *ShardDownSampleUpdateInfos) XXX_DiscardUnknown() + func (m *ShardDownSampleUpdateInfos) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShardDownSampleUpdateInfos) XXX_Merge(src proto.Message) + func (m *ShardDownSampleUpdateInfos) XXX_Size() int + func (m *ShardDownSampleUpdateInfos) XXX_Unmarshal(b []byte) error + type ShardDurationCommand struct + Index *uint64 + NodeId *uint64 + Pts []uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShardDurationCommand) Descriptor() ([]byte, []int) + func (*ShardDurationCommand) ProtoMessage() + func (m *ShardDurationCommand) GetIndex() uint64 + func (m *ShardDurationCommand) GetNodeId() uint64 + func (m *ShardDurationCommand) GetPts() []uint32 + func (m *ShardDurationCommand) Reset() + func (m *ShardDurationCommand) String() string + func (m *ShardDurationCommand) XXX_DiscardUnknown() + func (m *ShardDurationCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShardDurationCommand) XXX_Merge(src proto.Message) + func (m *ShardDurationCommand) XXX_Size() int + func (m *ShardDurationCommand) XXX_Unmarshal(b []byte) error + type ShardDurationInfo struct + DurationInfo *DurationDescriptor + Ident *ShardIdentifier + MeasurementInfo []*MeasurementInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShardDurationInfo) Descriptor() ([]byte, []int) + func (*ShardDurationInfo) ProtoMessage() + func (m *ShardDurationInfo) GetDurationInfo() *DurationDescriptor + func (m *ShardDurationInfo) GetIdent() *ShardIdentifier + func (m *ShardDurationInfo) GetMeasurementInfo() []*MeasurementInfo + func (m *ShardDurationInfo) Reset() + func (m *ShardDurationInfo) String() string + func (m *ShardDurationInfo) XXX_DiscardUnknown() + func (m *ShardDurationInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShardDurationInfo) XXX_Merge(src proto.Message) + func (m *ShardDurationInfo) XXX_Size() int + func (m *ShardDurationInfo) XXX_Unmarshal(b []byte) error + type ShardDurationResponse struct + DataIndex *uint64 + Durations []*ShardDurationInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShardDurationResponse) Descriptor() ([]byte, []int) + func (*ShardDurationResponse) ProtoMessage() + func (m *ShardDurationResponse) GetDataIndex() uint64 + func (m *ShardDurationResponse) GetDurations() []*ShardDurationInfo + func (m *ShardDurationResponse) Reset() + func (m *ShardDurationResponse) String() string + func (m *ShardDurationResponse) XXX_DiscardUnknown() + func (m *ShardDurationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShardDurationResponse) XXX_Merge(src proto.Message) + func (m *ShardDurationResponse) XXX_Size() int + func (m *ShardDurationResponse) XXX_Unmarshal(b []byte) error + type ShardGroupInfo struct + DeletedAt *int64 + EndTime *int64 + EngineType *uint32 + ID *uint64 + Shards []*ShardInfo + StartTime *int64 + TruncatedAt *int64 + Version *uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShardGroupInfo) Descriptor() ([]byte, []int) + func (*ShardGroupInfo) ProtoMessage() + func (m *ShardGroupInfo) GetDeletedAt() int64 + func (m *ShardGroupInfo) GetEndTime() int64 + func (m *ShardGroupInfo) GetEngineType() uint32 + func (m *ShardGroupInfo) GetID() uint64 + func (m *ShardGroupInfo) GetShards() []*ShardInfo + func (m *ShardGroupInfo) GetStartTime() int64 + func (m *ShardGroupInfo) GetTruncatedAt() int64 + func (m *ShardGroupInfo) GetVersion() uint32 + func (m *ShardGroupInfo) Reset() + func (m *ShardGroupInfo) String() string + func (m *ShardGroupInfo) XXX_DiscardUnknown() + func (m *ShardGroupInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShardGroupInfo) XXX_Merge(src proto.Message) + func (m *ShardGroupInfo) XXX_Size() int + func (m *ShardGroupInfo) XXX_Unmarshal(b []byte) error + type ShardIdentifier struct + DownSampleID *uint64 + DownSampleLevel *int64 + EngineType *uint32 + OwnerDb *string + OwnerPt *uint32 + Policy *string + ReadOnly *bool + ShardGroupID *uint64 + ShardID *uint64 + ShardType *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShardIdentifier) Descriptor() ([]byte, []int) + func (*ShardIdentifier) ProtoMessage() + func (m *ShardIdentifier) GetDownSampleID() uint64 + func (m *ShardIdentifier) GetDownSampleLevel() int64 + func (m *ShardIdentifier) GetEngineType() uint32 + func (m *ShardIdentifier) GetOwnerDb() string + func (m *ShardIdentifier) GetOwnerPt() uint32 + func (m *ShardIdentifier) GetPolicy() string + func (m *ShardIdentifier) GetReadOnly() bool + func (m *ShardIdentifier) GetShardGroupID() uint64 + func (m *ShardIdentifier) GetShardID() uint64 + func (m *ShardIdentifier) GetShardType() string + func (m *ShardIdentifier) Reset() + func (m *ShardIdentifier) String() string + func (m *ShardIdentifier) XXX_DiscardUnknown() + func (m *ShardIdentifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShardIdentifier) XXX_Merge(src proto.Message) + func (m *ShardIdentifier) XXX_Size() int + func (m *ShardIdentifier) XXX_Unmarshal(b []byte) error + type ShardInfo struct + DownSampleID *uint64 + DownSampleLevel *int64 + ID *uint64 + IndexID *uint64 + MarkDelete *bool + Max *string + Min *string + OwnerIDs []uint32 + ReadOnly *bool + Tier *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShardInfo) Descriptor() ([]byte, []int) + func (*ShardInfo) ProtoMessage() + func (m *ShardInfo) GetDownSampleID() uint64 + func (m *ShardInfo) GetDownSampleLevel() int64 + func (m *ShardInfo) GetID() uint64 + func (m *ShardInfo) GetIndexID() uint64 + func (m *ShardInfo) GetMarkDelete() bool + func (m *ShardInfo) GetMax() string + func (m *ShardInfo) GetMin() string + func (m *ShardInfo) GetOwnerIDs() []uint32 + func (m *ShardInfo) GetReadOnly() bool + func (m *ShardInfo) GetTier() uint64 + func (m *ShardInfo) Reset() + func (m *ShardInfo) String() string + func (m *ShardInfo) XXX_DiscardUnknown() + func (m *ShardInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShardInfo) XXX_Merge(src proto.Message) + func (m *ShardInfo) XXX_Size() int + func (m *ShardInfo) XXX_Unmarshal(b []byte) error + type ShardKeyInfo struct + SgID *uint64 + ShardKey []string + Type *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShardKeyInfo) Descriptor() ([]byte, []int) + func (*ShardKeyInfo) ProtoMessage() + func (m *ShardKeyInfo) GetSgID() uint64 + func (m *ShardKeyInfo) GetShardKey() []string + func (m *ShardKeyInfo) GetType() string + func (m *ShardKeyInfo) Reset() + func (m *ShardKeyInfo) String() string + func (m *ShardKeyInfo) XXX_DiscardUnknown() + func (m *ShardKeyInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShardKeyInfo) XXX_Merge(src proto.Message) + func (m *ShardKeyInfo) XXX_Size() int + func (m *ShardKeyInfo) XXX_Unmarshal(b []byte) error + type ShardOwner struct + NodeID *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShardOwner) Descriptor() ([]byte, []int) + func (*ShardOwner) ProtoMessage() + func (m *ShardOwner) GetNodeID() uint64 + func (m *ShardOwner) Reset() + func (m *ShardOwner) String() string + func (m *ShardOwner) XXX_DiscardUnknown() + func (m *ShardOwner) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShardOwner) XXX_Merge(src proto.Message) + func (m *ShardOwner) XXX_Size() int + func (m *ShardOwner) XXX_Unmarshal(b []byte) error + type ShardStatus struct + MaxTime *int64 + SeriesCount *int32 + ShardID *uint64 + ShardSize *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShardStatus) Descriptor() ([]byte, []int) + func (*ShardStatus) ProtoMessage() + func (m *ShardStatus) GetMaxTime() int64 + func (m *ShardStatus) GetSeriesCount() int32 + func (m *ShardStatus) GetShardID() uint64 + func (m *ShardStatus) GetShardSize() uint64 + func (m *ShardStatus) Reset() + func (m *ShardStatus) String() string + func (m *ShardStatus) XXX_DiscardUnknown() + func (m *ShardStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShardStatus) XXX_Merge(src proto.Message) + func (m *ShardStatus) XXX_Size() int + func (m *ShardStatus) XXX_Unmarshal(b []byte) error + type ShardTimeRangeInfo struct + OwnerIndex *IndexDescriptor + ShardDuration *ShardDurationInfo + ShardType *string + TimeRange *TimeRangeInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ShardTimeRangeInfo) Descriptor() ([]byte, []int) + func (*ShardTimeRangeInfo) ProtoMessage() + func (m *ShardTimeRangeInfo) GetOwnerIndex() *IndexDescriptor + func (m *ShardTimeRangeInfo) GetShardDuration() *ShardDurationInfo + func (m *ShardTimeRangeInfo) GetShardType() string + func (m *ShardTimeRangeInfo) GetTimeRange() *TimeRangeInfo + func (m *ShardTimeRangeInfo) Reset() + func (m *ShardTimeRangeInfo) String() string + func (m *ShardTimeRangeInfo) XXX_DiscardUnknown() + func (m *ShardTimeRangeInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ShardTimeRangeInfo) XXX_Merge(src proto.Message) + func (m *ShardTimeRangeInfo) XXX_Size() int + func (m *ShardTimeRangeInfo) XXX_Unmarshal(b []byte) error + type Sql2MetaHeartbeatCommand struct + Host *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Sql2MetaHeartbeatCommand) Descriptor() ([]byte, []int) + func (*Sql2MetaHeartbeatCommand) ProtoMessage() + func (m *Sql2MetaHeartbeatCommand) GetHost() string + func (m *Sql2MetaHeartbeatCommand) Reset() + func (m *Sql2MetaHeartbeatCommand) String() string + func (m *Sql2MetaHeartbeatCommand) XXX_DiscardUnknown() + func (m *Sql2MetaHeartbeatCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Sql2MetaHeartbeatCommand) XXX_Merge(src proto.Message) + func (m *Sql2MetaHeartbeatCommand) XXX_Size() int + func (m *Sql2MetaHeartbeatCommand) XXX_Unmarshal(b []byte) error + type StreamCall struct + Alias *string + Call *string + Field *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamCall) Descriptor() ([]byte, []int) + func (*StreamCall) ProtoMessage() + func (m *StreamCall) GetAlias() string + func (m *StreamCall) GetCall() string + func (m *StreamCall) GetField() string + func (m *StreamCall) Reset() + func (m *StreamCall) String() string + func (m *StreamCall) XXX_DiscardUnknown() + func (m *StreamCall) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamCall) XXX_Merge(src proto.Message) + func (m *StreamCall) XXX_Size() int + func (m *StreamCall) XXX_Unmarshal(b []byte) error + type StreamInfo struct + Calls []*StreamCall + Delay *int64 + DesMst *StreamMeasurementInfo + Dims []string + ID *uint64 + Interval *int64 + Name *string + SrcMst *StreamMeasurementInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamInfo) Descriptor() ([]byte, []int) + func (*StreamInfo) ProtoMessage() + func (m *StreamInfo) GetCalls() []*StreamCall + func (m *StreamInfo) GetDelay() int64 + func (m *StreamInfo) GetDesMst() *StreamMeasurementInfo + func (m *StreamInfo) GetDims() []string + func (m *StreamInfo) GetID() uint64 + func (m *StreamInfo) GetInterval() int64 + func (m *StreamInfo) GetName() string + func (m *StreamInfo) GetSrcMst() *StreamMeasurementInfo + func (m *StreamInfo) Reset() + func (m *StreamInfo) String() string + func (m *StreamInfo) XXX_DiscardUnknown() + func (m *StreamInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamInfo) XXX_Merge(src proto.Message) + func (m *StreamInfo) XXX_Size() int + func (m *StreamInfo) XXX_Unmarshal(b []byte) error + type StreamInfos struct + Infos []*StreamInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamInfos) Descriptor() ([]byte, []int) + func (*StreamInfos) ProtoMessage() + func (m *StreamInfos) GetInfos() []*StreamInfo + func (m *StreamInfos) Reset() + func (m *StreamInfos) String() string + func (m *StreamInfos) XXX_DiscardUnknown() + func (m *StreamInfos) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamInfos) XXX_Merge(src proto.Message) + func (m *StreamInfos) XXX_Size() int + func (m *StreamInfos) XXX_Unmarshal(b []byte) error + type StreamMeasurementInfo struct + Database *string + Name *string + RetentionPolicy *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamMeasurementInfo) Descriptor() ([]byte, []int) + func (*StreamMeasurementInfo) ProtoMessage() + func (m *StreamMeasurementInfo) GetDatabase() string + func (m *StreamMeasurementInfo) GetName() string + func (m *StreamMeasurementInfo) GetRetentionPolicy() string + func (m *StreamMeasurementInfo) Reset() + func (m *StreamMeasurementInfo) String() string + func (m *StreamMeasurementInfo) XXX_DiscardUnknown() + func (m *StreamMeasurementInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamMeasurementInfo) XXX_Merge(src proto.Message) + func (m *StreamMeasurementInfo) XXX_Size() int + func (m *StreamMeasurementInfo) XXX_Unmarshal(b []byte) error + type SubscriptionInfo struct + Destinations []string + Mode *string + Name *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SubscriptionInfo) Descriptor() ([]byte, []int) + 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 + func (m *SubscriptionInfo) XXX_DiscardUnknown() + func (m *SubscriptionInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SubscriptionInfo) XXX_Merge(src proto.Message) + func (m *SubscriptionInfo) XXX_Size() int + func (m *SubscriptionInfo) XXX_Unmarshal(b []byte) error + type TimeRangeCommand struct + Database *string + Policy *string + ShardID *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TimeRangeCommand) Descriptor() ([]byte, []int) + func (*TimeRangeCommand) ProtoMessage() + func (m *TimeRangeCommand) GetDatabase() string + func (m *TimeRangeCommand) GetPolicy() string + func (m *TimeRangeCommand) GetShardID() uint64 + func (m *TimeRangeCommand) Reset() + func (m *TimeRangeCommand) String() string + func (m *TimeRangeCommand) XXX_DiscardUnknown() + func (m *TimeRangeCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TimeRangeCommand) XXX_Merge(src proto.Message) + func (m *TimeRangeCommand) XXX_Size() int + func (m *TimeRangeCommand) XXX_Unmarshal(b []byte) error + type TimeRangeInfo struct + EndTime *int64 + StartTime *int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TimeRangeInfo) Descriptor() ([]byte, []int) + func (*TimeRangeInfo) ProtoMessage() + func (m *TimeRangeInfo) GetEndTime() int64 + func (m *TimeRangeInfo) GetStartTime() int64 + func (m *TimeRangeInfo) Reset() + func (m *TimeRangeInfo) String() string + func (m *TimeRangeInfo) XXX_DiscardUnknown() + func (m *TimeRangeInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TimeRangeInfo) XXX_Merge(src proto.Message) + func (m *TimeRangeInfo) XXX_Size() int + func (m *TimeRangeInfo) XXX_Unmarshal(b []byte) error + type UpdateDbPtStatusCommand struct + DB *string + Error *string + NodeId *uint64 + PT *uint32 + TaskID *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateDbPtStatusCommand) Descriptor() ([]byte, []int) + func (*UpdateDbPtStatusCommand) ProtoMessage() + func (m *UpdateDbPtStatusCommand) GetDB() string + func (m *UpdateDbPtStatusCommand) GetError() string + func (m *UpdateDbPtStatusCommand) GetNodeId() uint64 + func (m *UpdateDbPtStatusCommand) GetPT() uint32 + func (m *UpdateDbPtStatusCommand) GetTaskID() uint64 + func (m *UpdateDbPtStatusCommand) Reset() + func (m *UpdateDbPtStatusCommand) String() string + func (m *UpdateDbPtStatusCommand) XXX_DiscardUnknown() + func (m *UpdateDbPtStatusCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateDbPtStatusCommand) XXX_Merge(src proto.Message) + func (m *UpdateDbPtStatusCommand) XXX_Size() int + func (m *UpdateDbPtStatusCommand) XXX_Unmarshal(b []byte) error + type UpdateEventCommand struct + EventInfo *MigrateEventInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateEventCommand) Descriptor() ([]byte, []int) + func (*UpdateEventCommand) ProtoMessage() + func (m *UpdateEventCommand) GetEventInfo() *MigrateEventInfo + func (m *UpdateEventCommand) Reset() + func (m *UpdateEventCommand) String() string + func (m *UpdateEventCommand) XXX_DiscardUnknown() + func (m *UpdateEventCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateEventCommand) XXX_Merge(src proto.Message) + func (m *UpdateEventCommand) XXX_Size() int + func (m *UpdateEventCommand) XXX_Unmarshal(b []byte) error + type UpdateMeasurementCommand struct + Db *string + Mst *string + Options *Options + Rp *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateMeasurementCommand) Descriptor() ([]byte, []int) + func (*UpdateMeasurementCommand) ProtoMessage() + func (m *UpdateMeasurementCommand) GetDb() string + func (m *UpdateMeasurementCommand) GetMst() string + func (m *UpdateMeasurementCommand) GetOptions() *Options + func (m *UpdateMeasurementCommand) GetRp() string + func (m *UpdateMeasurementCommand) Reset() + func (m *UpdateMeasurementCommand) String() string + func (m *UpdateMeasurementCommand) XXX_DiscardUnknown() + func (m *UpdateMeasurementCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateMeasurementCommand) XXX_Merge(src proto.Message) + func (m *UpdateMeasurementCommand) XXX_Size() int + func (m *UpdateMeasurementCommand) XXX_Unmarshal(b []byte) error + type UpdateNodeStatusCommand struct + GossipAddr *string + ID *uint64 + Ltime *uint64 + Status *int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateNodeStatusCommand) Descriptor() ([]byte, []int) + func (*UpdateNodeStatusCommand) ProtoMessage() + func (m *UpdateNodeStatusCommand) GetGossipAddr() string + func (m *UpdateNodeStatusCommand) GetID() uint64 + func (m *UpdateNodeStatusCommand) GetLtime() uint64 + func (m *UpdateNodeStatusCommand) GetStatus() int32 + func (m *UpdateNodeStatusCommand) Reset() + func (m *UpdateNodeStatusCommand) String() string + func (m *UpdateNodeStatusCommand) XXX_DiscardUnknown() + func (m *UpdateNodeStatusCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateNodeStatusCommand) XXX_Merge(src proto.Message) + func (m *UpdateNodeStatusCommand) XXX_Size() int + func (m *UpdateNodeStatusCommand) XXX_Unmarshal(b []byte) error + type UpdatePtInfoCommand struct + Db *string + OwnerNode *uint64 + Pt *PtInfo + Status *uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdatePtInfoCommand) Descriptor() ([]byte, []int) + func (*UpdatePtInfoCommand) ProtoMessage() + func (m *UpdatePtInfoCommand) GetDb() string + func (m *UpdatePtInfoCommand) GetOwnerNode() uint64 + func (m *UpdatePtInfoCommand) GetPt() *PtInfo + func (m *UpdatePtInfoCommand) GetStatus() uint32 + func (m *UpdatePtInfoCommand) Reset() + func (m *UpdatePtInfoCommand) String() string + func (m *UpdatePtInfoCommand) XXX_DiscardUnknown() + func (m *UpdatePtInfoCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdatePtInfoCommand) XXX_Merge(src proto.Message) + func (m *UpdatePtInfoCommand) XXX_Size() int + func (m *UpdatePtInfoCommand) XXX_Unmarshal(b []byte) error + type UpdatePtVersionCommand struct + Db *string + Pt *uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdatePtVersionCommand) Descriptor() ([]byte, []int) + func (*UpdatePtVersionCommand) ProtoMessage() + func (m *UpdatePtVersionCommand) GetDb() string + func (m *UpdatePtVersionCommand) GetPt() uint32 + func (m *UpdatePtVersionCommand) Reset() + func (m *UpdatePtVersionCommand) String() string + func (m *UpdatePtVersionCommand) XXX_DiscardUnknown() + func (m *UpdatePtVersionCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdatePtVersionCommand) XXX_Merge(src proto.Message) + func (m *UpdatePtVersionCommand) XXX_Size() int + func (m *UpdatePtVersionCommand) XXX_Unmarshal(b []byte) error + type UpdateReplicationCommand struct + Database *string + MasterId *uint32 + Peers []*Peer + RepGroupId *uint32 + RgStatus *uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateReplicationCommand) Descriptor() ([]byte, []int) + func (*UpdateReplicationCommand) ProtoMessage() + func (m *UpdateReplicationCommand) GetDatabase() string + func (m *UpdateReplicationCommand) GetMasterId() uint32 + func (m *UpdateReplicationCommand) GetPeers() []*Peer + func (m *UpdateReplicationCommand) GetRepGroupId() uint32 + func (m *UpdateReplicationCommand) GetRgStatus() uint32 + func (m *UpdateReplicationCommand) Reset() + func (m *UpdateReplicationCommand) String() string + func (m *UpdateReplicationCommand) XXX_DiscardUnknown() + func (m *UpdateReplicationCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateReplicationCommand) XXX_Merge(src proto.Message) + func (m *UpdateReplicationCommand) XXX_Size() int + func (m *UpdateReplicationCommand) XXX_Unmarshal(b []byte) error + type UpdateRetentionPolicyCommand struct + Database *string + Duration *int64 + HotDuration *int64 + IndexGroupDuration *int64 + MakeDefault *bool + Name *string + NewName *string + ReplicaN *uint32 + ShardGroupDuration *int64 + WarmDuration *int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateRetentionPolicyCommand) Descriptor() ([]byte, []int) + func (*UpdateRetentionPolicyCommand) ProtoMessage() + func (m *UpdateRetentionPolicyCommand) GetDatabase() string + func (m *UpdateRetentionPolicyCommand) GetDuration() int64 + func (m *UpdateRetentionPolicyCommand) GetHotDuration() int64 + func (m *UpdateRetentionPolicyCommand) GetIndexGroupDuration() int64 + func (m *UpdateRetentionPolicyCommand) GetMakeDefault() bool + func (m *UpdateRetentionPolicyCommand) GetName() string + func (m *UpdateRetentionPolicyCommand) GetNewName() string + func (m *UpdateRetentionPolicyCommand) GetReplicaN() uint32 + func (m *UpdateRetentionPolicyCommand) GetShardGroupDuration() int64 + func (m *UpdateRetentionPolicyCommand) GetWarmDuration() int64 + func (m *UpdateRetentionPolicyCommand) Reset() + func (m *UpdateRetentionPolicyCommand) String() string + func (m *UpdateRetentionPolicyCommand) XXX_DiscardUnknown() + func (m *UpdateRetentionPolicyCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateRetentionPolicyCommand) XXX_Merge(src proto.Message) + func (m *UpdateRetentionPolicyCommand) XXX_Size() int + func (m *UpdateRetentionPolicyCommand) XXX_Unmarshal(b []byte) error + type UpdateSchemaCommand struct + Database *string + FieldToCreate []*FieldSchema + Measurement *string + RpName *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateSchemaCommand) Descriptor() ([]byte, []int) + func (*UpdateSchemaCommand) ProtoMessage() + func (m *UpdateSchemaCommand) GetDatabase() string + func (m *UpdateSchemaCommand) GetFieldToCreate() []*FieldSchema + func (m *UpdateSchemaCommand) GetMeasurement() string + func (m *UpdateSchemaCommand) GetRpName() string + func (m *UpdateSchemaCommand) Reset() + func (m *UpdateSchemaCommand) String() string + func (m *UpdateSchemaCommand) XXX_DiscardUnknown() + func (m *UpdateSchemaCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateSchemaCommand) XXX_Merge(src proto.Message) + func (m *UpdateSchemaCommand) XXX_Size() int + func (m *UpdateSchemaCommand) XXX_Unmarshal(b []byte) error + type UpdateShardDownSampleInfoCommand struct + Ident *ShardIdentifier + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateShardDownSampleInfoCommand) Descriptor() ([]byte, []int) + func (*UpdateShardDownSampleInfoCommand) ProtoMessage() + func (m *UpdateShardDownSampleInfoCommand) GetIdent() *ShardIdentifier + func (m *UpdateShardDownSampleInfoCommand) Reset() + func (m *UpdateShardDownSampleInfoCommand) String() string + func (m *UpdateShardDownSampleInfoCommand) XXX_DiscardUnknown() + func (m *UpdateShardDownSampleInfoCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateShardDownSampleInfoCommand) XXX_Merge(src proto.Message) + func (m *UpdateShardDownSampleInfoCommand) XXX_Size() int + func (m *UpdateShardDownSampleInfoCommand) XXX_Unmarshal(b []byte) error + type UpdateShardInfoTierCommand struct + DbName *string + RpName *string + ShardID *uint64 + Tier *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateShardInfoTierCommand) Descriptor() ([]byte, []int) + func (*UpdateShardInfoTierCommand) ProtoMessage() + func (m *UpdateShardInfoTierCommand) GetDbName() string + func (m *UpdateShardInfoTierCommand) GetRpName() string + func (m *UpdateShardInfoTierCommand) GetShardID() uint64 + func (m *UpdateShardInfoTierCommand) GetTier() uint64 + func (m *UpdateShardInfoTierCommand) Reset() + func (m *UpdateShardInfoTierCommand) String() string + func (m *UpdateShardInfoTierCommand) XXX_DiscardUnknown() + func (m *UpdateShardInfoTierCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateShardInfoTierCommand) XXX_Merge(src proto.Message) + func (m *UpdateShardInfoTierCommand) XXX_Size() int + func (m *UpdateShardInfoTierCommand) XXX_Unmarshal(b []byte) error + type UpdateShardOwnerCommand struct + DbName *string + OwnerId *int64 + RpName *string + ShardId *int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateShardOwnerCommand) Descriptor() ([]byte, []int) + func (*UpdateShardOwnerCommand) ProtoMessage() + func (m *UpdateShardOwnerCommand) GetDbName() string + func (m *UpdateShardOwnerCommand) GetOwnerId() int64 + func (m *UpdateShardOwnerCommand) GetRpName() string + func (m *UpdateShardOwnerCommand) GetShardId() int64 + func (m *UpdateShardOwnerCommand) Reset() + func (m *UpdateShardOwnerCommand) String() string + func (m *UpdateShardOwnerCommand) XXX_DiscardUnknown() + func (m *UpdateShardOwnerCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateShardOwnerCommand) XXX_Merge(src proto.Message) + func (m *UpdateShardOwnerCommand) XXX_Size() int + func (m *UpdateShardOwnerCommand) XXX_Unmarshal(b []byte) error + type UpdateUserCommand struct + Hash *string + Name *string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateUserCommand) Descriptor() ([]byte, []int) + func (*UpdateUserCommand) ProtoMessage() + func (m *UpdateUserCommand) GetHash() string + func (m *UpdateUserCommand) GetName() string + func (m *UpdateUserCommand) Reset() + func (m *UpdateUserCommand) String() string + func (m *UpdateUserCommand) XXX_DiscardUnknown() + func (m *UpdateUserCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateUserCommand) XXX_Merge(src proto.Message) + func (m *UpdateUserCommand) XXX_Size() int + func (m *UpdateUserCommand) XXX_Unmarshal(b []byte) error + type UserInfo struct + Admin *bool + Hash *string + Name *string + Privileges []*UserPrivilege + RwUser *bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UserInfo) Descriptor() ([]byte, []int) + 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) GetRwUser() bool + func (m *UserInfo) Reset() + func (m *UserInfo) String() string + func (m *UserInfo) XXX_DiscardUnknown() + func (m *UserInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UserInfo) XXX_Merge(src proto.Message) + func (m *UserInfo) XXX_Size() int + func (m *UserInfo) XXX_Unmarshal(b []byte) error + type UserPrivilege struct + Database *string + Privilege *int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UserPrivilege) Descriptor() ([]byte, []int) + func (*UserPrivilege) ProtoMessage() + func (m *UserPrivilege) GetDatabase() string + func (m *UserPrivilege) GetPrivilege() int32 + func (m *UserPrivilege) Reset() + func (m *UserPrivilege) String() string + func (m *UserPrivilege) XXX_DiscardUnknown() + func (m *UserPrivilege) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UserPrivilege) XXX_Merge(src proto.Message) + func (m *UserPrivilege) XXX_Size() int + func (m *UserPrivilege) XXX_Unmarshal(b []byte) error + type VerifyDataNodeCommand struct + NodeID *uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*VerifyDataNodeCommand) Descriptor() ([]byte, []int) + func (*VerifyDataNodeCommand) ProtoMessage() + func (m *VerifyDataNodeCommand) GetNodeID() uint64 + func (m *VerifyDataNodeCommand) Reset() + func (m *VerifyDataNodeCommand) String() string + func (m *VerifyDataNodeCommand) XXX_DiscardUnknown() + func (m *VerifyDataNodeCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *VerifyDataNodeCommand) XXX_Merge(src proto.Message) + func (m *VerifyDataNodeCommand) XXX_Size() int + func (m *VerifyDataNodeCommand) XXX_Unmarshal(b []byte) error