proto

package
v1.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 29, 2024 License: Apache-2.0, MIT Imports: 3 Imported by: 0

README

How to Use Protobuf in Go Environment

This document is going to provide you with the step-by-step instructions on how to use protobuf in Go environment.

Installing Protobuf

Linux

Run the following commands:

# PROTOC_ZIP=protoc-3.14.0-linux-x86_64.zip
curl -OL https://github.com/protocolbuffers/protobuf/releases/download/v3.14.0/$PROTOC_ZIP
sudo unzip -o $PROTOC_ZIP -d /usr/local bin/protoc
sudo unzip -o $PROTOC_ZIP -d /usr/local 'include/*'
rm -f $PROTOC_ZIP

Installing Gogo Plugin

Run the following commands:

go install github.com/gogo/protobuf/protoc-gen-gogo@latest

Executing Command

With the installation of Protobuf and Gogo plugin, you can now use Protobuf in your Go project. Here are the commands for generating Protobuf Go code:

# Generate Go code from .proto file
protoc --gogo_out=. ./meta.proto

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Command_Type_name = map[int32]string{
	3:   "CreateDatabaseCommand",
	4:   "DropDatabaseCommand",
	5:   "CreateRetentionPolicyCommand",
	6:   "DropRetentionPolicyCommand",
	7:   "SetDefaultRetentionPolicyCommand",
	8:   "UpdateRetentionPolicyCommand",
	9:   "CreateShardGroupCommand",
	10:  "DeleteShardGroupCommand",
	13:  "CreateUserCommand",
	14:  "DropUserCommand",
	15:  "UpdateUserCommand",
	16:  "SetPrivilegeCommand",
	17:  "SetDataCommand",
	18:  "SetAdminPrivilegeCommand",
	21:  "CreateSubscriptionCommand",
	22:  "DropSubscriptionCommand",
	24:  "CreateMetaNodeCommand",
	25:  "CreateDataNodeCommand",
	26:  "UpdateDataNodeCommand",
	27:  "DeleteMetaNodeCommand",
	28:  "DeleteDataNodeCommand",
	29:  "SetMetaNodeCommand",
	30:  "DropShardCommand",
	31:  "MarkDatabaseDeleteCommand",
	35:  "UpdateShardOwnerCommand",
	39:  "MarkRetentionPolicyDeleteCommand",
	49:  "CreateMeasurementCommand",
	50:  "AlterShardKeyCmd",
	52:  "ReShardingCommand",
	53:  "UpdateSchemaCommand",
	54:  "ReportShardsCommand",
	57:  "PruneGroupsCommand",
	58:  "MarkMeasurementDeleteCommand",
	59:  "DropMeasurementCommand",
	60:  "TimeRangeCommand",
	61:  "ShardDurationCommand",
	62:  "DeleteIndexGroupCommand",
	63:  "UpdateShardInfoTierCommand",
	64:  "UpdateNodeStatusCommand",
	65:  "CreateEventCommand",
	66:  "UpdateEventCommand",
	67:  "UpdatePtInfoCommand",
	68:  "RemoveEventCommand",
	69:  "CreateDownSamplePolicyCommand",
	70:  "DropDownSamplePolicyCommand",
	71:  "GetDownSamplePolicyCommand",
	72:  "CreateDbPtViewCommand",
	73:  "GetMeasurementInfoWithinSameRpCommand",
	74:  "UpdateShardDownSampleInfoCommand",
	75:  "MarkTakeoverCommand",
	76:  "MarkBalancerCommand",
	77:  "CreateStreamCommand",
	78:  "DropStreamCommand",
	79:  "GetMeasurementInfoStoreCommand",
	80:  "VerifyDataNodeCommand",
	81:  "ExpandGroupsCommand",
	82:  "UpdatePtVersionCommand",
	83:  "GetDBBriefInfoCommand",
	84:  "GetMeasurementsInfoCommand",
	85:  "RegisterQueryIDOffsetCommand",
	86:  "CreateContinuousQueryCommand",
	87:  "Sql2MetaHeartbeatCommand",
	88:  "ContinuousQueryReportCommand",
	89:  "GetContinuousQueryLeaseCommand",
	90:  "DropContinuousQueryCommand",
	91:  "NotifyCQLeaseChangedCommand",
	92:  "SetNodeSegregateStatusCommand",
	93:  "RemoveNodeCommand",
	94:  "UpdateReplicationCommand",
	101: "UpdateMeasurementCommand",
}
View Source 
var Command_Type_value = map[string]int32{
	"CreateDatabaseCommand":                 3,
	"DropDatabaseCommand":                   4,
	"CreateRetentionPolicyCommand":          5,
	"DropRetentionPolicyCommand":            6,
	"SetDefaultRetentionPolicyCommand":      7,
	"UpdateRetentionPolicyCommand":          8,
	"CreateShardGroupCommand":               9,
	"DeleteShardGroupCommand":               10,
	"CreateUserCommand":                     13,
	"DropUserCommand":                       14,
	"UpdateUserCommand":                     15,
	"SetPrivilegeCommand":                   16,
	"SetDataCommand":                        17,
	"SetAdminPrivilegeCommand":              18,
	"CreateSubscriptionCommand":             21,
	"DropSubscriptionCommand":               22,
	"CreateMetaNodeCommand":                 24,
	"CreateDataNodeCommand":                 25,
	"UpdateDataNodeCommand":                 26,
	"DeleteMetaNodeCommand":                 27,
	"DeleteDataNodeCommand":                 28,
	"SetMetaNodeCommand":                    29,
	"DropShardCommand":                      30,
	"MarkDatabaseDeleteCommand":             31,
	"UpdateShardOwnerCommand":               35,
	"MarkRetentionPolicyDeleteCommand":      39,
	"CreateMeasurementCommand":              49,
	"AlterShardKeyCmd":                      50,
	"ReShardingCommand":                     52,
	"UpdateSchemaCommand":                   53,
	"ReportShardsCommand":                   54,
	"PruneGroupsCommand":                    57,
	"MarkMeasurementDeleteCommand":          58,
	"DropMeasurementCommand":                59,
	"TimeRangeCommand":                      60,
	"ShardDurationCommand":                  61,
	"DeleteIndexGroupCommand":               62,
	"UpdateShardInfoTierCommand":            63,
	"UpdateNodeStatusCommand":               64,
	"CreateEventCommand":                    65,
	"UpdateEventCommand":                    66,
	"UpdatePtInfoCommand":                   67,
	"RemoveEventCommand":                    68,
	"CreateDownSamplePolicyCommand":         69,
	"DropDownSamplePolicyCommand":           70,
	"GetDownSamplePolicyCommand":            71,
	"CreateDbPtViewCommand":                 72,
	"GetMeasurementInfoWithinSameRpCommand": 73,
	"UpdateShardDownSampleInfoCommand":      74,
	"MarkTakeoverCommand":                   75,
	"MarkBalancerCommand":                   76,
	"CreateStreamCommand":                   77,
	"DropStreamCommand":                     78,
	"GetMeasurementInfoStoreCommand":        79,
	"VerifyDataNodeCommand":                 80,
	"ExpandGroupsCommand":                   81,
	"UpdatePtVersionCommand":                82,
	"GetDBBriefInfoCommand":                 83,
	"GetMeasurementsInfoCommand":            84,
	"RegisterQueryIDOffsetCommand":          85,
	"CreateContinuousQueryCommand":          86,
	"Sql2MetaHeartbeatCommand":              87,
	"ContinuousQueryReportCommand":          88,
	"GetContinuousQueryLeaseCommand":        89,
	"DropContinuousQueryCommand":            90,
	"NotifyCQLeaseChangedCommand":           91,
	"SetNodeSegregateStatusCommand":         92,
	"RemoveNodeCommand":                     93,
	"UpdateReplicationCommand":              94,
	"UpdateMeasurementCommand":              101,
}
View Source 
var E_AlterShardKeyCmd_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*AlterShardKeyCmd)(nil),
	Field:         150,
	Name:          "proto.AlterShardKeyCmd.command",
	Tag:           "bytes,150,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_ContinuousQueryReportCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*ContinuousQueryReportCommand)(nil),
	Field:         187,
	Name:          "proto.ContinuousQueryReportCommand.command",
	Tag:           "bytes,187,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_CreateContinuousQueryCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*CreateContinuousQueryCommand)(nil),
	Field:         185,
	Name:          "proto.CreateContinuousQueryCommand.command",
	Tag:           "bytes,185,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_CreateDataNodeCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*CreateDataNodeCommand)(nil),
	Field:         125,
	Name:          "proto.CreateDataNodeCommand.command",
	Tag:           "bytes,125,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_CreateDatabaseCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*CreateDatabaseCommand)(nil),
	Field:         103,
	Name:          "proto.CreateDatabaseCommand.command",
	Tag:           "bytes,103,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_CreateDbPtViewCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*CreateDbPtViewCommand)(nil),
	Field:         172,
	Name:          "proto.CreateDbPtViewCommand.command",
	Tag:           "bytes,172,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_CreateDownSamplePolicyCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*CreateDownSamplePolicyCommand)(nil),
	Field:         169,
	Name:          "proto.CreateDownSamplePolicyCommand.command",
	Tag:           "bytes,169,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_CreateEventCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*CreateEventCommand)(nil),
	Field:         165,
	Name:          "proto.CreateEventCommand.command",
	Tag:           "bytes,165,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_CreateMeasurementCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*CreateMeasurementCommand)(nil),
	Field:         149,
	Name:          "proto.CreateMeasurementCommand.command",
	Tag:           "bytes,149,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_CreateMetaNodeCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*CreateMetaNodeCommand)(nil),
	Field:         124,
	Name:          "proto.CreateMetaNodeCommand.command",
	Tag:           "bytes,124,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_CreateRetentionPolicyCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*CreateRetentionPolicyCommand)(nil),
	Field:         105,
	Name:          "proto.CreateRetentionPolicyCommand.command",
	Tag:           "bytes,105,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_CreateShardGroupCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*CreateShardGroupCommand)(nil),
	Field:         109,
	Name:          "proto.CreateShardGroupCommand.command",
	Tag:           "bytes,109,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_CreateStreamCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*CreateStreamCommand)(nil),
	Field:         177,
	Name:          "proto.CreateStreamCommand.command",
	Tag:           "bytes,177,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_CreateSubscriptionCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*CreateSubscriptionCommand)(nil),
	Field:         121,
	Name:          "proto.CreateSubscriptionCommand.command",
	Tag:           "bytes,121,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_CreateUserCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*CreateUserCommand)(nil),
	Field:         113,
	Name:          "proto.CreateUserCommand.command",
	Tag:           "bytes,113,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_DeleteDataNodeCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*DeleteDataNodeCommand)(nil),
	Field:         128,
	Name:          "proto.DeleteDataNodeCommand.command",
	Tag:           "bytes,128,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_DeleteIndexGroupCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*DeleteIndexGroupCommand)(nil),
	Field:         162,
	Name:          "proto.DeleteIndexGroupCommand.command",
	Tag:           "bytes,162,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_DeleteMetaNodeCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*DeleteMetaNodeCommand)(nil),
	Field:         127,
	Name:          "proto.DeleteMetaNodeCommand.command",
	Tag:           "bytes,127,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_DeleteShardGroupCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*DeleteShardGroupCommand)(nil),
	Field:         110,
	Name:          "proto.DeleteShardGroupCommand.command",
	Tag:           "bytes,110,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_DropContinuousQueryCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*DropContinuousQueryCommand)(nil),
	Field:         189,
	Name:          "proto.DropContinuousQueryCommand.command",
	Tag:           "bytes,189,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_DropDatabaseCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*DropDatabaseCommand)(nil),
	Field:         104,
	Name:          "proto.DropDatabaseCommand.command",
	Tag:           "bytes,104,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_DropDownSamplePolicyCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*DropDownSamplePolicyCommand)(nil),
	Field:         170,
	Name:          "proto.DropDownSamplePolicyCommand.command",
	Tag:           "bytes,170,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_DropMeasurementCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*DropMeasurementCommand)(nil),
	Field:         159,
	Name:          "proto.DropMeasurementCommand.command",
	Tag:           "bytes,159,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_DropRetentionPolicyCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*DropRetentionPolicyCommand)(nil),
	Field:         106,
	Name:          "proto.DropRetentionPolicyCommand.command",
	Tag:           "bytes,106,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_DropShardCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*DropShardCommand)(nil),
	Field:         130,
	Name:          "proto.DropShardCommand.command",
	Tag:           "bytes,130,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_DropStreamCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*DropStreamCommand)(nil),
	Field:         178,
	Name:          "proto.DropStreamCommand.command",
	Tag:           "bytes,178,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_DropSubscriptionCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*DropSubscriptionCommand)(nil),
	Field:         122,
	Name:          "proto.DropSubscriptionCommand.command",
	Tag:           "bytes,122,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_DropUserCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*DropUserCommand)(nil),
	Field:         114,
	Name:          "proto.DropUserCommand.command",
	Tag:           "bytes,114,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_ExpandGroupsCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*ExpandGroupsCommand)(nil),
	Field:         181,
	Name:          "proto.ExpandGroupsCommand.command",
	Tag:           "bytes,181,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_GetContinuousQueryLeaseCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*GetContinuousQueryLeaseCommand)(nil),
	Field:         188,
	Name:          "proto.GetContinuousQueryLeaseCommand.command",
	Tag:           "bytes,188,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_GetDownSamplePolicyCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*GetDownSamplePolicyCommand)(nil),
	Field:         171,
	Name:          "proto.GetDownSamplePolicyCommand.command",
	Tag:           "bytes,171,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_GetMeasurementInfoStoreCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*GetMeasurementInfoStoreCommand)(nil),
	Field:         179,
	Name:          "proto.GetMeasurementInfoStoreCommand.command",
	Tag:           "bytes,179,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_GetMeasurementInfoWithinSameRpCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*GetMeasurementInfoWithinSameRpCommand)(nil),
	Field:         173,
	Name:          "proto.GetMeasurementInfoWithinSameRpCommand.command",
	Tag:           "bytes,173,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_GetMeasurementsInfoCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*GetMeasurementsInfoCommand)(nil),
	Field:         183,
	Name:          "proto.GetMeasurementsInfoCommand.command",
	Tag:           "bytes,183,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_MarkBalancerCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*MarkBalancerCommand)(nil),
	Field:         176,
	Name:          "proto.MarkBalancerCommand.command",
	Tag:           "bytes,176,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_MarkDatabaseDeleteCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*MarkDatabaseDeleteCommand)(nil),
	Field:         131,
	Name:          "proto.MarkDatabaseDeleteCommand.command",
	Tag:           "bytes,131,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_MarkMeasurementDeleteCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*MarkMeasurementDeleteCommand)(nil),
	Field:         158,
	Name:          "proto.MarkMeasurementDeleteCommand.command",
	Tag:           "bytes,158,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_MarkRetentionPolicyDeleteCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*MarkRetentionPolicyDeleteCommand)(nil),
	Field:         139,
	Name:          "proto.MarkRetentionPolicyDeleteCommand.command",
	Tag:           "bytes,139,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_MarkTakeoverCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*MarkTakeoverCommand)(nil),
	Field:         175,
	Name:          "proto.MarkTakeoverCommand.command",
	Tag:           "bytes,175,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_NotifyCQLeaseChangedCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*NotifyCQLeaseChangedCommand)(nil),
	Field:         190,
	Name:          "proto.NotifyCQLeaseChangedCommand.command",
	Tag:           "bytes,190,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_PruneGroupsCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*PruneGroupsCommand)(nil),
	Field:         157,
	Name:          "proto.PruneGroupsCommand.command",
	Tag:           "bytes,157,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_ReShardingCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*ReShardingCommand)(nil),
	Field:         152,
	Name:          "proto.ReShardingCommand.command",
	Tag:           "bytes,152,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_RegisterQueryIDOffsetCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*RegisterQueryIDOffsetCommand)(nil),
	Field:         184,
	Name:          "proto.RegisterQueryIDOffsetCommand.command",
	Tag:           "bytes,184,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_RemoveEventCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*RemoveEventCommand)(nil),
	Field:         168,
	Name:          "proto.RemoveEventCommand.command",
	Tag:           "bytes,168,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_RemoveNodeCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*RemoveNodeCommand)(nil),
	Field:         192,
	Name:          "proto.RemoveNodeCommand.command",
	Tag:           "bytes,192,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_ReportShardsLoadCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*ReportShardsLoadCommand)(nil),
	Field:         154,
	Name:          "proto.ReportShardsLoadCommand.command",
	Tag:           "bytes,154,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_SetAdminPrivilegeCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*SetAdminPrivilegeCommand)(nil),
	Field:         118,
	Name:          "proto.SetAdminPrivilegeCommand.command",
	Tag:           "bytes,118,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_SetDataCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*SetDataCommand)(nil),
	Field:         117,
	Name:          "proto.SetDataCommand.command",
	Tag:           "bytes,117,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_SetDefaultRetentionPolicyCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*SetDefaultRetentionPolicyCommand)(nil),
	Field:         107,
	Name:          "proto.SetDefaultRetentionPolicyCommand.command",
	Tag:           "bytes,107,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_SetMetaNodeCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*SetMetaNodeCommand)(nil),
	Field:         129,
	Name:          "proto.SetMetaNodeCommand.command",
	Tag:           "bytes,129,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_SetNodeSegregateStatusCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*SetNodeSegregateStatusCommand)(nil),
	Field:         191,
	Name:          "proto.SetNodeSegregateStatusCommand.command",
	Tag:           "bytes,191,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_SetPrivilegeCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*SetPrivilegeCommand)(nil),
	Field:         116,
	Name:          "proto.SetPrivilegeCommand.command",
	Tag:           "bytes,116,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_ShardDurationCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*ShardDurationCommand)(nil),
	Field:         161,
	Name:          "proto.ShardDurationCommand.command",
	Tag:           "bytes,161,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_Sql2MetaHeartbeatCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*Sql2MetaHeartbeatCommand)(nil),
	Field:         186,
	Name:          "proto.Sql2MetaHeartbeatCommand.command",
	Tag:           "bytes,186,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_TimeRangeCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*TimeRangeCommand)(nil),
	Field:         160,
	Name:          "proto.TimeRangeCommand.command",
	Tag:           "bytes,160,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_UpdateDbPtStatusCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*UpdateDbPtStatusCommand)(nil),
	Field:         151,
	Name:          "proto.UpdateDbPtStatusCommand.command",
	Tag:           "bytes,151,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_UpdateEventCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*UpdateEventCommand)(nil),
	Field:         166,
	Name:          "proto.UpdateEventCommand.command",
	Tag:           "bytes,166,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_UpdateMeasurementCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*UpdateMeasurementCommand)(nil),
	Field:         194,
	Name:          "proto.UpdateMeasurementCommand.command",
	Tag:           "bytes,194,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_UpdateNodeStatusCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*UpdateNodeStatusCommand)(nil),
	Field:         164,
	Name:          "proto.UpdateNodeStatusCommand.command",
	Tag:           "bytes,164,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_UpdatePtInfoCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*UpdatePtInfoCommand)(nil),
	Field:         167,
	Name:          "proto.UpdatePtInfoCommand.command",
	Tag:           "bytes,167,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_UpdatePtVersionCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*UpdatePtVersionCommand)(nil),
	Field:         182,
	Name:          "proto.UpdatePtVersionCommand.command",
	Tag:           "bytes,182,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_UpdateReplicationCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*UpdateReplicationCommand)(nil),
	Field:         193,
	Name:          "proto.UpdateReplicationCommand.command",
	Tag:           "bytes,193,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_UpdateRetentionPolicyCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*UpdateRetentionPolicyCommand)(nil),
	Field:         108,
	Name:          "proto.UpdateRetentionPolicyCommand.command",
	Tag:           "bytes,108,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_UpdateSchemaCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*UpdateSchemaCommand)(nil),
	Field:         153,
	Name:          "proto.UpdateSchemaCommand.command",
	Tag:           "bytes,153,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_UpdateShardDownSampleInfoCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*UpdateShardDownSampleInfoCommand)(nil),
	Field:         174,
	Name:          "proto.UpdateShardDownSampleInfoCommand.command",
	Tag:           "bytes,174,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_UpdateShardInfoTierCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*UpdateShardInfoTierCommand)(nil),
	Field:         163,
	Name:          "proto.UpdateShardInfoTierCommand.command",
	Tag:           "bytes,163,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_UpdateShardOwnerCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*UpdateShardOwnerCommand)(nil),
	Field:         135,
	Name:          "proto.UpdateShardOwnerCommand.command",
	Tag:           "bytes,135,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_UpdateUserCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*UpdateUserCommand)(nil),
	Field:         115,
	Name:          "proto.UpdateUserCommand.command",
	Tag:           "bytes,115,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_VerifyDataNodeCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*VerifyDataNodeCommand)(nil),
	Field:         180,
	Name:          "proto.VerifyDataNodeCommand.command",
	Tag:           "bytes,180,opt,name=command",
	Filename:      "meta.proto",
}

Functions

This section is empty.

Types

type AlterShardKeyCmd 

type AlterShardKeyCmd struct {
	DBName               *string       `protobuf:"bytes,1,req,name=DBName" json:"DBName,omitempty"`
	RpName               *string       `protobuf:"bytes,2,req,name=RpName" json:"RpName,omitempty"`
	Name                 *string       `protobuf:"bytes,3,req,name=Name" json:"Name,omitempty"`
	Ski                  *ShardKeyInfo `protobuf:"bytes,4,opt,name=Ski" json:"Ski,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*AlterShardKeyCmd) Descriptor 

func (*AlterShardKeyCmd) Descriptor() ([]byte, []int)

func (*AlterShardKeyCmd) GetDBName 

func (m *AlterShardKeyCmd) GetDBName() string

func (*AlterShardKeyCmd) GetName 

func (m *AlterShardKeyCmd) GetName() string

func (*AlterShardKeyCmd) GetRpName 

func (m *AlterShardKeyCmd) GetRpName() string

func (*AlterShardKeyCmd) GetSki 

func (m *AlterShardKeyCmd) GetSki() *ShardKeyInfo

func (*AlterShardKeyCmd) ProtoMessage 

func (*AlterShardKeyCmd) ProtoMessage()

func (*AlterShardKeyCmd) Reset 

func (m *AlterShardKeyCmd) Reset()

func (*AlterShardKeyCmd) String 

func (m *AlterShardKeyCmd) String() string

func (*AlterShardKeyCmd) XXX_DiscardUnknown 

func (m *AlterShardKeyCmd) XXX_DiscardUnknown()

func (*AlterShardKeyCmd) XXX_Marshal 

func (m *AlterShardKeyCmd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AlterShardKeyCmd) XXX_Merge 

func (m *AlterShardKeyCmd) XXX_Merge(src proto.Message)

func (*AlterShardKeyCmd) XXX_Size 

func (m *AlterShardKeyCmd) XXX_Size() int

func (*AlterShardKeyCmd) XXX_Unmarshal 

func (m *AlterShardKeyCmd) XXX_Unmarshal(b []byte) error

type CQState 

type CQState struct {
	Name                 *string  `protobuf:"bytes,1,req,name=Name" json:"Name,omitempty"`
	LastRunTime          *int64   `protobuf:"varint,2,req,name=LastRunTime" json:"LastRunTime,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CQState) Descriptor 

func (*CQState) Descriptor() ([]byte, []int)

func (*CQState) GetLastRunTime 

func (m *CQState) GetLastRunTime() int64

func (*CQState) GetName 

func (m *CQState) GetName() string

func (*CQState) ProtoMessage 

func (*CQState) ProtoMessage()

func (*CQState) Reset 

func (m *CQState) Reset()

func (*CQState) String 

func (m *CQState) String() string

func (*CQState) XXX_DiscardUnknown 

func (m *CQState) XXX_DiscardUnknown()

func (*CQState) XXX_Marshal 

func (m *CQState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CQState) XXX_Merge 

func (m *CQState) XXX_Merge(src proto.Message)

func (*CQState) XXX_Size 

func (m *CQState) XXX_Size() int

func (*CQState) XXX_Unmarshal 

func (m *CQState) XXX_Unmarshal(b []byte) error

type CardinalityInfo 

type CardinalityInfo struct {
	TimeRange            *TimeRangeInfo `protobuf:"bytes,1,req,name=TimeRange" json:"TimeRange,omitempty"`
	Cardinality          *uint64        `protobuf:"varint,2,req,name=Cardinality" json:"Cardinality,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*CardinalityInfo) Descriptor 

func (*CardinalityInfo) Descriptor() ([]byte, []int)

func (*CardinalityInfo) GetCardinality 

func (m *CardinalityInfo) GetCardinality() uint64

func (*CardinalityInfo) GetTimeRange 

func (m *CardinalityInfo) GetTimeRange() *TimeRangeInfo

func (*CardinalityInfo) ProtoMessage 

func (*CardinalityInfo) ProtoMessage()

func (*CardinalityInfo) Reset 

func (m *CardinalityInfo) Reset()

func (*CardinalityInfo) String 

func (m *CardinalityInfo) String() string

func (*CardinalityInfo) XXX_DiscardUnknown 

func (m *CardinalityInfo) XXX_DiscardUnknown()

func (*CardinalityInfo) XXX_Marshal 

func (m *CardinalityInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CardinalityInfo) XXX_Merge 

func (m *CardinalityInfo) XXX_Merge(src proto.Message)

func (*CardinalityInfo) XXX_Size 

func (m *CardinalityInfo) XXX_Size() int

func (*CardinalityInfo) XXX_Unmarshal 

func (m *CardinalityInfo) XXX_Unmarshal(b []byte) error

type CardinalityResponse 

type CardinalityResponse struct {
	Infos                []*MeasurementCardinalityInfo `protobuf:"bytes,1,rep,name=Infos" json:"Infos,omitempty"`
	Err                  *string                       `protobuf:"bytes,2,opt,name=Err" json:"Err,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*CardinalityResponse) Descriptor 

func (*CardinalityResponse) Descriptor() ([]byte, []int)

func (*CardinalityResponse) GetErr 

func (m *CardinalityResponse) GetErr() string

func (*CardinalityResponse) GetInfos 

func (m *CardinalityResponse) GetInfos() []*MeasurementCardinalityInfo

func (*CardinalityResponse) ProtoMessage 

func (*CardinalityResponse) ProtoMessage()

func (*CardinalityResponse) Reset 

func (m *CardinalityResponse) Reset()

func (*CardinalityResponse) String 

func (m *CardinalityResponse) String() string

func (*CardinalityResponse) XXX_DiscardUnknown 

func (m *CardinalityResponse) XXX_DiscardUnknown()

func (*CardinalityResponse) XXX_Marshal 

func (m *CardinalityResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CardinalityResponse) XXX_Merge 

func (m *CardinalityResponse) XXX_Merge(src proto.Message)

func (*CardinalityResponse) XXX_Size 

func (m *CardinalityResponse) XXX_Size() int

func (*CardinalityResponse) XXX_Unmarshal 

func (m *CardinalityResponse) XXX_Unmarshal(b []byte) error

type ColStoreInfo 

type ColStoreInfo struct {
	PrimaryKey           []string `protobuf:"bytes,1,rep,name=PrimaryKey" json:"PrimaryKey,omitempty"`
	SortKey              []string `protobuf:"bytes,2,rep,name=SortKey" json:"SortKey,omitempty"`
	PropertyKey          []string `protobuf:"bytes,3,rep,name=PropertyKey" json:"PropertyKey,omitempty"`
	PropertyValue        []string `protobuf:"bytes,4,rep,name=PropertyValue" json:"PropertyValue,omitempty"`
	TimeClusterDuration  *int64   `protobuf:"varint,5,opt,name=TimeClusterDuration" json:"TimeClusterDuration,omitempty"`
	CompactionType       *int32   `protobuf:"varint,6,opt,name=CompactionType" json:"CompactionType,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ColStoreInfo) Descriptor 

func (*ColStoreInfo) Descriptor() ([]byte, []int)

func (*ColStoreInfo) GetCompactionType 

func (m *ColStoreInfo) GetCompactionType() int32

func (*ColStoreInfo) GetPrimaryKey 

func (m *ColStoreInfo) GetPrimaryKey() []string

func (*ColStoreInfo) GetPropertyKey 

func (m *ColStoreInfo) GetPropertyKey() []string

func (*ColStoreInfo) GetPropertyValue 

func (m *ColStoreInfo) GetPropertyValue() []string

func (*ColStoreInfo) GetSortKey 

func (m *ColStoreInfo) GetSortKey() []string

func (*ColStoreInfo) GetTimeClusterDuration 

func (m *ColStoreInfo) GetTimeClusterDuration() int64

func (*ColStoreInfo) ProtoMessage 

func (*ColStoreInfo) ProtoMessage()

func (*ColStoreInfo) Reset 

func (m *ColStoreInfo) Reset()

func (*ColStoreInfo) String 

func (m *ColStoreInfo) String() string

func (*ColStoreInfo) XXX_DiscardUnknown 

func (m *ColStoreInfo) XXX_DiscardUnknown()

func (*ColStoreInfo) XXX_Marshal 

func (m *ColStoreInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ColStoreInfo) XXX_Merge 

func (m *ColStoreInfo) XXX_Merge(src proto.Message)

func (*ColStoreInfo) XXX_Size 

func (m *ColStoreInfo) XXX_Size() int

func (*ColStoreInfo) XXX_Unmarshal 

func (m *ColStoreInfo) XXX_Unmarshal(b []byte) error

type Command 

type Command struct {
	Type                         *Command_Type `protobuf:"varint,1,req,name=type,enum=proto.Command_Type" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral         struct{}      `json:"-"`
	proto.XXX_InternalExtensions `json:"-"`
	XXX_unrecognized             []byte `json:"-"`
	XXX_sizecache                int32  `json:"-"`
}

func (*Command) Descriptor 

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

func (*Command) ExtensionRangeArray 

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

func (*Command) GetType 

func (m *Command) GetType() Command_Type

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) Reset 

func (m *Command) Reset()

func (*Command) String 

func (m *Command) String() string

func (*Command) XXX_DiscardUnknown 

func (m *Command) XXX_DiscardUnknown()

func (*Command) XXX_Marshal 

func (m *Command) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Command) XXX_Merge 

func (m *Command) XXX_Merge(src proto.Message)

func (*Command) XXX_Size 

func (m *Command) XXX_Size() int

func (*Command) XXX_Unmarshal 

func (m *Command) XXX_Unmarshal(b []byte) error

type Command_Type 

type Command_Type int32
const (
	Command_CreateDatabaseCommand                 Command_Type = 3
	Command_DropDatabaseCommand                   Command_Type = 4
	Command_CreateRetentionPolicyCommand          Command_Type = 5
	Command_DropRetentionPolicyCommand            Command_Type = 6
	Command_SetDefaultRetentionPolicyCommand      Command_Type = 7
	Command_UpdateRetentionPolicyCommand          Command_Type = 8
	Command_CreateShardGroupCommand               Command_Type = 9
	Command_DeleteShardGroupCommand               Command_Type = 10
	Command_CreateUserCommand                     Command_Type = 13
	Command_DropUserCommand                       Command_Type = 14
	Command_UpdateUserCommand                     Command_Type = 15
	Command_SetPrivilegeCommand                   Command_Type = 16
	Command_SetDataCommand                        Command_Type = 17
	Command_SetAdminPrivilegeCommand              Command_Type = 18
	Command_CreateSubscriptionCommand             Command_Type = 21
	Command_DropSubscriptionCommand               Command_Type = 22
	Command_CreateMetaNodeCommand                 Command_Type = 24
	Command_CreateDataNodeCommand                 Command_Type = 25
	Command_UpdateDataNodeCommand                 Command_Type = 26
	Command_DeleteMetaNodeCommand                 Command_Type = 27
	Command_DeleteDataNodeCommand                 Command_Type = 28
	Command_SetMetaNodeCommand                    Command_Type = 29
	Command_DropShardCommand                      Command_Type = 30
	Command_MarkDatabaseDeleteCommand             Command_Type = 31
	Command_UpdateShardOwnerCommand               Command_Type = 35
	Command_MarkRetentionPolicyDeleteCommand      Command_Type = 39
	Command_CreateMeasurementCommand              Command_Type = 49
	Command_AlterShardKeyCmd                      Command_Type = 50
	Command_ReShardingCommand                     Command_Type = 52
	Command_UpdateSchemaCommand                   Command_Type = 53
	Command_ReportShardsCommand                   Command_Type = 54
	Command_PruneGroupsCommand                    Command_Type = 57
	Command_MarkMeasurementDeleteCommand          Command_Type = 58
	Command_DropMeasurementCommand                Command_Type = 59
	Command_TimeRangeCommand                      Command_Type = 60
	Command_ShardDurationCommand                  Command_Type = 61
	Command_DeleteIndexGroupCommand               Command_Type = 62
	Command_UpdateShardInfoTierCommand            Command_Type = 63
	Command_UpdateNodeStatusCommand               Command_Type = 64
	Command_CreateEventCommand                    Command_Type = 65
	Command_UpdateEventCommand                    Command_Type = 66
	Command_UpdatePtInfoCommand                   Command_Type = 67
	Command_RemoveEventCommand                    Command_Type = 68
	Command_CreateDownSamplePolicyCommand         Command_Type = 69
	Command_DropDownSamplePolicyCommand           Command_Type = 70
	Command_GetDownSamplePolicyCommand            Command_Type = 71
	Command_CreateDbPtViewCommand                 Command_Type = 72
	Command_GetMeasurementInfoWithinSameRpCommand Command_Type = 73
	Command_UpdateShardDownSampleInfoCommand      Command_Type = 74
	Command_MarkTakeoverCommand                   Command_Type = 75
	Command_MarkBalancerCommand                   Command_Type = 76
	Command_CreateStreamCommand                   Command_Type = 77
	Command_DropStreamCommand                     Command_Type = 78
	Command_GetMeasurementInfoStoreCommand        Command_Type = 79
	Command_VerifyDataNodeCommand                 Command_Type = 80
	Command_ExpandGroupsCommand                   Command_Type = 81
	Command_UpdatePtVersionCommand                Command_Type = 82
	Command_GetDBBriefInfoCommand                 Command_Type = 83
	Command_GetMeasurementsInfoCommand            Command_Type = 84
	Command_RegisterQueryIDOffsetCommand          Command_Type = 85
	Command_CreateContinuousQueryCommand          Command_Type = 86
	Command_Sql2MetaHeartbeatCommand              Command_Type = 87
	Command_ContinuousQueryReportCommand          Command_Type = 88
	Command_GetContinuousQueryLeaseCommand        Command_Type = 89
	Command_DropContinuousQueryCommand            Command_Type = 90
	Command_NotifyCQLeaseChangedCommand           Command_Type = 91
	Command_SetNodeSegregateStatusCommand         Command_Type = 92
	Command_RemoveNodeCommand                     Command_Type = 93
	Command_UpdateReplicationCommand              Command_Type = 94
	Command_UpdateMeasurementCommand              Command_Type = 101
)

func (Command_Type) Enum 

func (x Command_Type) Enum() *Command_Type

func (Command_Type) EnumDescriptor 

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

func (Command_Type) String 

func (x Command_Type) String() string

func (*Command_Type) UnmarshalJSON 

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

type ContinuousQueryInfo 

type ContinuousQueryInfo struct {
	Name                 *string  `protobuf:"bytes,1,req,name=Name" json:"Name,omitempty"`
	Query                *string  `protobuf:"bytes,2,req,name=Query" json:"Query,omitempty"`
	LastRunTime          *int64   `protobuf:"varint,3,opt,name=LastRunTime" json:"LastRunTime,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ContinuousQueryInfo) Descriptor 

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

func (*ContinuousQueryInfo) GetLastRunTime 

func (m *ContinuousQueryInfo) GetLastRunTime() int64

func (*ContinuousQueryInfo) GetName 

func (m *ContinuousQueryInfo) GetName() string

func (*ContinuousQueryInfo) GetQuery 

func (m *ContinuousQueryInfo) GetQuery() string

func (*ContinuousQueryInfo) ProtoMessage 

func (*ContinuousQueryInfo) ProtoMessage()

func (*ContinuousQueryInfo) Reset 

func (m *ContinuousQueryInfo) Reset()

func (*ContinuousQueryInfo) String 

func (m *ContinuousQueryInfo) String() string

func (*ContinuousQueryInfo) XXX_DiscardUnknown 

func (m *ContinuousQueryInfo) XXX_DiscardUnknown()

func (*ContinuousQueryInfo) XXX_Marshal 

func (m *ContinuousQueryInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContinuousQueryInfo) XXX_Merge 

func (m *ContinuousQueryInfo) XXX_Merge(src proto.Message)

func (*ContinuousQueryInfo) XXX_Size 

func (m *ContinuousQueryInfo) XXX_Size() int

func (*ContinuousQueryInfo) XXX_Unmarshal 

func (m *ContinuousQueryInfo) XXX_Unmarshal(b []byte) error

type ContinuousQueryReportCommand 

type ContinuousQueryReportCommand struct {
	CQStates             []*CQState `protobuf:"bytes,1,rep,name=CQStates" json:"CQStates,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*ContinuousQueryReportCommand) Descriptor 

func (*ContinuousQueryReportCommand) Descriptor() ([]byte, []int)

func (*ContinuousQueryReportCommand) GetCQStates 

func (m *ContinuousQueryReportCommand) GetCQStates() []*CQState

func (*ContinuousQueryReportCommand) ProtoMessage 

func (*ContinuousQueryReportCommand) ProtoMessage()

func (*ContinuousQueryReportCommand) Reset 

func (m *ContinuousQueryReportCommand) Reset()

func (*ContinuousQueryReportCommand) String 

func (m *ContinuousQueryReportCommand) String() string

func (*ContinuousQueryReportCommand) XXX_DiscardUnknown 

func (m *ContinuousQueryReportCommand) XXX_DiscardUnknown()

func (*ContinuousQueryReportCommand) XXX_Marshal 

func (m *ContinuousQueryReportCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContinuousQueryReportCommand) XXX_Merge 

func (m *ContinuousQueryReportCommand) XXX_Merge(src proto.Message)

func (*ContinuousQueryReportCommand) XXX_Size 

func (m *ContinuousQueryReportCommand) XXX_Size() int

func (*ContinuousQueryReportCommand) XXX_Unmarshal 

func (m *ContinuousQueryReportCommand) XXX_Unmarshal(b []byte) error

type CreateContinuousQueryCommand 

type CreateContinuousQueryCommand struct {
	Database             *string  `protobuf:"bytes,1,req,name=Database" json:"Database,omitempty"`
	Name                 *string  `protobuf:"bytes,2,req,name=Name" json:"Name,omitempty"`
	Query                *string  `protobuf:"bytes,3,req,name=Query" json:"Query,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateContinuousQueryCommand) Descriptor 

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

func (*CreateContinuousQueryCommand) GetDatabase 

func (m *CreateContinuousQueryCommand) GetDatabase() string

func (*CreateContinuousQueryCommand) GetName 

func (m *CreateContinuousQueryCommand) GetName() string

func (*CreateContinuousQueryCommand) GetQuery 

func (m *CreateContinuousQueryCommand) GetQuery() string

func (*CreateContinuousQueryCommand) ProtoMessage 

func (*CreateContinuousQueryCommand) ProtoMessage()

func (*CreateContinuousQueryCommand) Reset 

func (m *CreateContinuousQueryCommand) Reset()

func (*CreateContinuousQueryCommand) String 

func (m *CreateContinuousQueryCommand) String() string

func (*CreateContinuousQueryCommand) XXX_DiscardUnknown 

func (m *CreateContinuousQueryCommand) XXX_DiscardUnknown()

func (*CreateContinuousQueryCommand) XXX_Marshal 

func (m *CreateContinuousQueryCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateContinuousQueryCommand) XXX_Merge 

func (m *CreateContinuousQueryCommand) XXX_Merge(src proto.Message)

func (*CreateContinuousQueryCommand) XXX_Size 

func (m *CreateContinuousQueryCommand) XXX_Size() int

func (*CreateContinuousQueryCommand) XXX_Unmarshal 

func (m *CreateContinuousQueryCommand) XXX_Unmarshal(b []byte) error

type CreateDataNodeCommand 

type CreateDataNodeCommand struct {
	HTTPAddr             *string  `protobuf:"bytes,1,req,name=HTTPAddr" json:"HTTPAddr,omitempty"`
	TCPAddr              *string  `protobuf:"bytes,2,req,name=TCPAddr" json:"TCPAddr,omitempty"`
	Role                 *string  `protobuf:"bytes,10,opt,name=Role" json:"Role,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateDataNodeCommand) Descriptor 

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

func (*CreateDataNodeCommand) GetHTTPAddr 

func (m *CreateDataNodeCommand) GetHTTPAddr() string

func (*CreateDataNodeCommand) GetRole 

func (m *CreateDataNodeCommand) GetRole() string

func (*CreateDataNodeCommand) GetTCPAddr 

func (m *CreateDataNodeCommand) GetTCPAddr() string

func (*CreateDataNodeCommand) ProtoMessage 

func (*CreateDataNodeCommand) ProtoMessage()

func (*CreateDataNodeCommand) Reset 

func (m *CreateDataNodeCommand) Reset()

func (*CreateDataNodeCommand) String 

func (m *CreateDataNodeCommand) String() string

func (*CreateDataNodeCommand) XXX_DiscardUnknown 

func (m *CreateDataNodeCommand) XXX_DiscardUnknown()

func (*CreateDataNodeCommand) XXX_Marshal 

func (m *CreateDataNodeCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateDataNodeCommand) XXX_Merge 

func (m *CreateDataNodeCommand) XXX_Merge(src proto.Message)

func (*CreateDataNodeCommand) XXX_Size 

func (m *CreateDataNodeCommand) XXX_Size() int

func (*CreateDataNodeCommand) XXX_Unmarshal 

func (m *CreateDataNodeCommand) XXX_Unmarshal(b []byte) error

type CreateDatabaseCommand 

type CreateDatabaseCommand struct {
	Name                 *string              `protobuf:"bytes,1,req,name=Name" json:"Name,omitempty"`
	RetentionPolicy      *RetentionPolicyInfo `protobuf:"bytes,2,opt,name=RetentionPolicy" json:"RetentionPolicy,omitempty"`
	ReplicaNum           *uint32              `protobuf:"varint,3,opt,name=ReplicaNum" json:"ReplicaNum,omitempty"`
	Ski                  *ShardKeyInfo        `protobuf:"bytes,4,opt,name=Ski" json:"Ski,omitempty"`
	EnableTagArray       *bool                `protobuf:"varint,5,opt,name=EnableTagArray" json:"EnableTagArray,omitempty"`
	Options              *ObsOptions          `protobuf:"bytes,21,opt,name=Options" json:"Options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*CreateDatabaseCommand) Descriptor 

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

func (*CreateDatabaseCommand) GetEnableTagArray 

func (m *CreateDatabaseCommand) GetEnableTagArray() bool

func (*CreateDatabaseCommand) GetName 

func (m *CreateDatabaseCommand) GetName() string

func (*CreateDatabaseCommand) GetOptions 

func (m *CreateDatabaseCommand) GetOptions() *ObsOptions

func (*CreateDatabaseCommand) GetReplicaNum 

func (m *CreateDatabaseCommand) GetReplicaNum() uint32

func (*CreateDatabaseCommand) GetRetentionPolicy 

func (m *CreateDatabaseCommand) GetRetentionPolicy() *RetentionPolicyInfo

func (*CreateDatabaseCommand) GetSki 

func (m *CreateDatabaseCommand) GetSki() *ShardKeyInfo

func (*CreateDatabaseCommand) ProtoMessage 

func (*CreateDatabaseCommand) ProtoMessage()

func (*CreateDatabaseCommand) Reset 

func (m *CreateDatabaseCommand) Reset()

func (*CreateDatabaseCommand) String 

func (m *CreateDatabaseCommand) String() string

func (*CreateDatabaseCommand) XXX_DiscardUnknown 

func (m *CreateDatabaseCommand) XXX_DiscardUnknown()

func (*CreateDatabaseCommand) XXX_Marshal 

func (m *CreateDatabaseCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateDatabaseCommand) XXX_Merge 

func (m *CreateDatabaseCommand) XXX_Merge(src proto.Message)

func (*CreateDatabaseCommand) XXX_Size 

func (m *CreateDatabaseCommand) XXX_Size() int

func (*CreateDatabaseCommand) XXX_Unmarshal 

func (m *CreateDatabaseCommand) XXX_Unmarshal(b []byte) error

type CreateDbPtViewCommand 

type CreateDbPtViewCommand struct {
	DbName               *string  `protobuf:"bytes,1,req,name=DbName" json:"DbName,omitempty"`
	ReplicaNum           *uint32  `protobuf:"varint,2,opt,name=replicaNum" json:"replicaNum,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateDbPtViewCommand) Descriptor 

func (*CreateDbPtViewCommand) Descriptor() ([]byte, []int)

func (*CreateDbPtViewCommand) GetDbName 

func (m *CreateDbPtViewCommand) GetDbName() string

func (*CreateDbPtViewCommand) GetReplicaNum 

func (m *CreateDbPtViewCommand) GetReplicaNum() uint32

func (*CreateDbPtViewCommand) ProtoMessage 

func (*CreateDbPtViewCommand) ProtoMessage()

func (*CreateDbPtViewCommand) Reset 

func (m *CreateDbPtViewCommand) Reset()

func (*CreateDbPtViewCommand) String 

func (m *CreateDbPtViewCommand) String() string

func (*CreateDbPtViewCommand) XXX_DiscardUnknown 

func (m *CreateDbPtViewCommand) XXX_DiscardUnknown()

func (*CreateDbPtViewCommand) XXX_Marshal 

func (m *CreateDbPtViewCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateDbPtViewCommand) XXX_Merge 

func (m *CreateDbPtViewCommand) XXX_Merge(src proto.Message)

func (*CreateDbPtViewCommand) XXX_Size 

func (m *CreateDbPtViewCommand) XXX_Size() int

func (*CreateDbPtViewCommand) XXX_Unmarshal 

func (m *CreateDbPtViewCommand) XXX_Unmarshal(b []byte) error

type CreateDownSamplePolicyCommand 

type CreateDownSamplePolicyCommand struct {
	DownSamplePolicyInfo *DownSamplePolicyInfo `protobuf:"bytes,1,req,name=DownSamplePolicyInfo" json:"DownSamplePolicyInfo,omitempty"`
	Database             *string               `protobuf:"bytes,2,req,name=Database" json:"Database,omitempty"`
	Name                 *string               `protobuf:"bytes,3,req,name=name" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*CreateDownSamplePolicyCommand) Descriptor 

func (*CreateDownSamplePolicyCommand) Descriptor() ([]byte, []int)

func (*CreateDownSamplePolicyCommand) GetDatabase 

func (m *CreateDownSamplePolicyCommand) GetDatabase() string

func (*CreateDownSamplePolicyCommand) GetDownSamplePolicyInfo 

func (m *CreateDownSamplePolicyCommand) GetDownSamplePolicyInfo() *DownSamplePolicyInfo

func (*CreateDownSamplePolicyCommand) GetName 

func (m *CreateDownSamplePolicyCommand) GetName() string

func (*CreateDownSamplePolicyCommand) ProtoMessage 

func (*CreateDownSamplePolicyCommand) ProtoMessage()

func (*CreateDownSamplePolicyCommand) Reset 

func (m *CreateDownSamplePolicyCommand) Reset()

func (*CreateDownSamplePolicyCommand) String 

func (m *CreateDownSamplePolicyCommand) String() string

func (*CreateDownSamplePolicyCommand) XXX_DiscardUnknown 

func (m *CreateDownSamplePolicyCommand) XXX_DiscardUnknown()

func (*CreateDownSamplePolicyCommand) XXX_Marshal 

func (m *CreateDownSamplePolicyCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateDownSamplePolicyCommand) XXX_Merge 

func (m *CreateDownSamplePolicyCommand) XXX_Merge(src proto.Message)

func (*CreateDownSamplePolicyCommand) XXX_Size 

func (m *CreateDownSamplePolicyCommand) XXX_Size() int

func (*CreateDownSamplePolicyCommand) XXX_Unmarshal 

func (m *CreateDownSamplePolicyCommand) XXX_Unmarshal(b []byte) error

type CreateEventCommand 

type CreateEventCommand struct {
	EventInfo            *MigrateEventInfo `protobuf:"bytes,1,req,name=eventInfo" json:"eventInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*CreateEventCommand) Descriptor 

func (*CreateEventCommand) Descriptor() ([]byte, []int)

func (*CreateEventCommand) GetEventInfo 

func (m *CreateEventCommand) GetEventInfo() *MigrateEventInfo

func (*CreateEventCommand) ProtoMessage 

func (*CreateEventCommand) ProtoMessage()

func (*CreateEventCommand) Reset 

func (m *CreateEventCommand) Reset()

func (*CreateEventCommand) String 

func (m *CreateEventCommand) String() string

func (*CreateEventCommand) XXX_DiscardUnknown 

func (m *CreateEventCommand) XXX_DiscardUnknown()

func (*CreateEventCommand) XXX_Marshal 

func (m *CreateEventCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateEventCommand) XXX_Merge 

func (m *CreateEventCommand) XXX_Merge(src proto.Message)

func (*CreateEventCommand) XXX_Size 

func (m *CreateEventCommand) XXX_Size() int

func (*CreateEventCommand) XXX_Unmarshal 

func (m *CreateEventCommand) XXX_Unmarshal(b []byte) error

type CreateMeasurementCommand 

type CreateMeasurementCommand struct {
	DBName               *string        `protobuf:"bytes,1,req,name=DBName" json:"DBName,omitempty"`
	RpName               *string        `protobuf:"bytes,2,req,name=RpName" json:"RpName,omitempty"`
	Name                 *string        `protobuf:"bytes,3,req,name=Name" json:"Name,omitempty"`
	Ski                  *ShardKeyInfo  `protobuf:"bytes,4,opt,name=Ski" json:"Ski,omitempty"`
	IR                   *IndexRelation `protobuf:"bytes,5,opt,name=IR" json:"IR,omitempty"`
	EngineType           *uint32        `protobuf:"varint,6,opt,name=EngineType" json:"EngineType,omitempty"`
	ColStoreInfo         *ColStoreInfo  `protobuf:"bytes,7,opt,name=ColStoreInfo" json:"ColStoreInfo,omitempty"`
	SchemaInfo           []*FieldSchema `protobuf:"bytes,8,rep,name=SchemaInfo" json:"SchemaInfo,omitempty"`
	Options              *Options       `protobuf:"bytes,9,opt,name=Options" json:"Options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*CreateMeasurementCommand) Descriptor 

func (*CreateMeasurementCommand) Descriptor() ([]byte, []int)

func (*CreateMeasurementCommand) GetColStoreInfo 

func (m *CreateMeasurementCommand) GetColStoreInfo() *ColStoreInfo

func (*CreateMeasurementCommand) GetDBName 

func (m *CreateMeasurementCommand) GetDBName() string

func (*CreateMeasurementCommand) GetEngineType 

func (m *CreateMeasurementCommand) GetEngineType() uint32

func (*CreateMeasurementCommand) GetIR 

func (m *CreateMeasurementCommand) GetIR() *IndexRelation

func (*CreateMeasurementCommand) GetName 

func (m *CreateMeasurementCommand) GetName() string

func (*CreateMeasurementCommand) GetOptions 

func (m *CreateMeasurementCommand) GetOptions() *Options

func (*CreateMeasurementCommand) GetRpName 

func (m *CreateMeasurementCommand) GetRpName() string

func (*CreateMeasurementCommand) GetSchemaInfo 

func (m *CreateMeasurementCommand) GetSchemaInfo() []*FieldSchema

func (*CreateMeasurementCommand) GetSki 

func (m *CreateMeasurementCommand) GetSki() *ShardKeyInfo

func (*CreateMeasurementCommand) ProtoMessage 

func (*CreateMeasurementCommand) ProtoMessage()

func (*CreateMeasurementCommand) Reset 

func (m *CreateMeasurementCommand) Reset()

func (*CreateMeasurementCommand) String 

func (m *CreateMeasurementCommand) String() string

func (*CreateMeasurementCommand) XXX_DiscardUnknown 

func (m *CreateMeasurementCommand) XXX_DiscardUnknown()

func (*CreateMeasurementCommand) XXX_Marshal 

func (m *CreateMeasurementCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateMeasurementCommand) XXX_Merge 

func (m *CreateMeasurementCommand) XXX_Merge(src proto.Message)

func (*CreateMeasurementCommand) XXX_Size 

func (m *CreateMeasurementCommand) XXX_Size() int

func (*CreateMeasurementCommand) XXX_Unmarshal 

func (m *CreateMeasurementCommand) XXX_Unmarshal(b []byte) error

type CreateMetaNodeCommand 

type CreateMetaNodeCommand struct {
	HTTPAddr             *string  `protobuf:"bytes,1,req,name=HTTPAddr" json:"HTTPAddr,omitempty"`
	RPCAddr              *string  `protobuf:"bytes,4,req,name=RPCAddr" json:"RPCAddr,omitempty"`
	TCPAddr              *string  `protobuf:"bytes,2,req,name=TCPAddr" json:"TCPAddr,omitempty"`
	Rand                 *uint64  `protobuf:"varint,3,req,name=Rand" json:"Rand,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateMetaNodeCommand) Descriptor 

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

func (*CreateMetaNodeCommand) GetHTTPAddr 

func (m *CreateMetaNodeCommand) GetHTTPAddr() string

func (*CreateMetaNodeCommand) GetRPCAddr 

func (m *CreateMetaNodeCommand) GetRPCAddr() string

func (*CreateMetaNodeCommand) GetRand 

func (m *CreateMetaNodeCommand) GetRand() uint64

func (*CreateMetaNodeCommand) GetTCPAddr 

func (m *CreateMetaNodeCommand) GetTCPAddr() string

func (*CreateMetaNodeCommand) ProtoMessage 

func (*CreateMetaNodeCommand) ProtoMessage()

func (*CreateMetaNodeCommand) Reset 

func (m *CreateMetaNodeCommand) Reset()

func (*CreateMetaNodeCommand) String 

func (m *CreateMetaNodeCommand) String() string

func (*CreateMetaNodeCommand) XXX_DiscardUnknown 

func (m *CreateMetaNodeCommand) XXX_DiscardUnknown()

func (*CreateMetaNodeCommand) XXX_Marshal 

func (m *CreateMetaNodeCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateMetaNodeCommand) XXX_Merge 

func (m *CreateMetaNodeCommand) XXX_Merge(src proto.Message)

func (*CreateMetaNodeCommand) XXX_Size 

func (m *CreateMetaNodeCommand) XXX_Size() int

func (*CreateMetaNodeCommand) XXX_Unmarshal 

func (m *CreateMetaNodeCommand) XXX_Unmarshal(b []byte) error

type CreateRetentionPolicyCommand 

type CreateRetentionPolicyCommand struct {
	Database             *string              `protobuf:"bytes,1,req,name=Database" json:"Database,omitempty"`
	RetentionPolicy      *RetentionPolicyInfo `protobuf:"bytes,2,req,name=RetentionPolicy" json:"RetentionPolicy,omitempty"`
	DefaultRP            *bool                `protobuf:"varint,3,req,name=DefaultRP" json:"DefaultRP,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*CreateRetentionPolicyCommand) Descriptor 

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

func (*CreateRetentionPolicyCommand) GetDatabase 

func (m *CreateRetentionPolicyCommand) GetDatabase() string

func (*CreateRetentionPolicyCommand) GetDefaultRP 

func (m *CreateRetentionPolicyCommand) GetDefaultRP() bool

func (*CreateRetentionPolicyCommand) GetRetentionPolicy 

func (m *CreateRetentionPolicyCommand) GetRetentionPolicy() *RetentionPolicyInfo

func (*CreateRetentionPolicyCommand) ProtoMessage 

func (*CreateRetentionPolicyCommand) ProtoMessage()

func (*CreateRetentionPolicyCommand) Reset 

func (m *CreateRetentionPolicyCommand) Reset()

func (*CreateRetentionPolicyCommand) String 

func (m *CreateRetentionPolicyCommand) String() string

func (*CreateRetentionPolicyCommand) XXX_DiscardUnknown 

func (m *CreateRetentionPolicyCommand) XXX_DiscardUnknown()

func (*CreateRetentionPolicyCommand) XXX_Marshal 

func (m *CreateRetentionPolicyCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateRetentionPolicyCommand) XXX_Merge 

func (m *CreateRetentionPolicyCommand) XXX_Merge(src proto.Message)

func (*CreateRetentionPolicyCommand) XXX_Size 

func (m *CreateRetentionPolicyCommand) XXX_Size() int

func (*CreateRetentionPolicyCommand) XXX_Unmarshal 

func (m *CreateRetentionPolicyCommand) XXX_Unmarshal(b []byte) error

type CreateShardGroupCommand 

type CreateShardGroupCommand struct {
	Database             *string  `protobuf:"bytes,1,req,name=Database" json:"Database,omitempty"`
	Policy               *string  `protobuf:"bytes,2,req,name=Policy" json:"Policy,omitempty"`
	Timestamp            *int64   `protobuf:"varint,3,req,name=Timestamp" json:"Timestamp,omitempty"`
	ShardTier            *uint64  `protobuf:"varint,4,req,name=ShardTier" json:"ShardTier,omitempty"`
	EngineType           *uint32  `protobuf:"varint,5,opt,name=EngineType" json:"EngineType,omitempty"`
	Version              *uint32  `protobuf:"varint,11,opt,name=Version" json:"Version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateShardGroupCommand) Descriptor 

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

func (*CreateShardGroupCommand) GetDatabase 

func (m *CreateShardGroupCommand) GetDatabase() string

func (*CreateShardGroupCommand) GetEngineType 

func (m *CreateShardGroupCommand) GetEngineType() uint32

func (*CreateShardGroupCommand) GetPolicy 

func (m *CreateShardGroupCommand) GetPolicy() string

func (*CreateShardGroupCommand) GetShardTier 

func (m *CreateShardGroupCommand) GetShardTier() uint64

func (*CreateShardGroupCommand) GetTimestamp 

func (m *CreateShardGroupCommand) GetTimestamp() int64

func (*CreateShardGroupCommand) GetVersion 

func (m *CreateShardGroupCommand) GetVersion() uint32

func (*CreateShardGroupCommand) ProtoMessage 

func (*CreateShardGroupCommand) ProtoMessage()

func (*CreateShardGroupCommand) Reset 

func (m *CreateShardGroupCommand) Reset()

func (*CreateShardGroupCommand) String 

func (m *CreateShardGroupCommand) String() string

func (*CreateShardGroupCommand) XXX_DiscardUnknown 

func (m *CreateShardGroupCommand) XXX_DiscardUnknown()

func (*CreateShardGroupCommand) XXX_Marshal 

func (m *CreateShardGroupCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateShardGroupCommand) XXX_Merge 

func (m *CreateShardGroupCommand) XXX_Merge(src proto.Message)

func (*CreateShardGroupCommand) XXX_Size 

func (m *CreateShardGroupCommand) XXX_Size() int

func (*CreateShardGroupCommand) XXX_Unmarshal 

func (m *CreateShardGroupCommand) XXX_Unmarshal(b []byte) error

type CreateStreamCommand 

type CreateStreamCommand struct {
	StreamInfo           *StreamInfo `protobuf:"bytes,1,req,name=StreamInfo" json:"StreamInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*CreateStreamCommand) Descriptor 

func (*CreateStreamCommand) Descriptor() ([]byte, []int)

func (*CreateStreamCommand) GetStreamInfo 

func (m *CreateStreamCommand) GetStreamInfo() *StreamInfo

func (*CreateStreamCommand) ProtoMessage 

func (*CreateStreamCommand) ProtoMessage()

func (*CreateStreamCommand) Reset 

func (m *CreateStreamCommand) Reset()

func (*CreateStreamCommand) String 

func (m *CreateStreamCommand) String() string

func (*CreateStreamCommand) XXX_DiscardUnknown 

func (m *CreateStreamCommand) XXX_DiscardUnknown()

func (*CreateStreamCommand) XXX_Marshal 

func (m *CreateStreamCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateStreamCommand) XXX_Merge 

func (m *CreateStreamCommand) XXX_Merge(src proto.Message)

func (*CreateStreamCommand) XXX_Size 

func (m *CreateStreamCommand) XXX_Size() int

func (*CreateStreamCommand) XXX_Unmarshal 

func (m *CreateStreamCommand) XXX_Unmarshal(b []byte) error

type CreateSubscriptionCommand 

type CreateSubscriptionCommand struct {
	Name                 *string  `protobuf:"bytes,1,req,name=Name" json:"Name,omitempty"`
	Database             *string  `protobuf:"bytes,2,req,name=Database" json:"Database,omitempty"`
	RetentionPolicy      *string  `protobuf:"bytes,3,req,name=RetentionPolicy" json:"RetentionPolicy,omitempty"`
	Mode                 *string  `protobuf:"bytes,4,req,name=Mode" json:"Mode,omitempty"`
	Destinations         []string `protobuf:"bytes,5,rep,name=Destinations" json:"Destinations,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateSubscriptionCommand) Descriptor 

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

func (*CreateSubscriptionCommand) GetDatabase 

func (m *CreateSubscriptionCommand) GetDatabase() string

func (*CreateSubscriptionCommand) GetDestinations 

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

func (*CreateSubscriptionCommand) GetMode 

func (m *CreateSubscriptionCommand) GetMode() string

func (*CreateSubscriptionCommand) GetName 

func (m *CreateSubscriptionCommand) GetName() string

func (*CreateSubscriptionCommand) GetRetentionPolicy 

func (m *CreateSubscriptionCommand) GetRetentionPolicy() string

func (*CreateSubscriptionCommand) ProtoMessage 

func (*CreateSubscriptionCommand) ProtoMessage()

func (*CreateSubscriptionCommand) Reset 

func (m *CreateSubscriptionCommand) Reset()

func (*CreateSubscriptionCommand) String 

func (m *CreateSubscriptionCommand) String() string

func (*CreateSubscriptionCommand) XXX_DiscardUnknown 

func (m *CreateSubscriptionCommand) XXX_DiscardUnknown()

func (*CreateSubscriptionCommand) XXX_Marshal 

func (m *CreateSubscriptionCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateSubscriptionCommand) XXX_Merge 

func (m *CreateSubscriptionCommand) XXX_Merge(src proto.Message)

func (*CreateSubscriptionCommand) XXX_Size 

func (m *CreateSubscriptionCommand) XXX_Size() int

func (*CreateSubscriptionCommand) XXX_Unmarshal 

func (m *CreateSubscriptionCommand) XXX_Unmarshal(b []byte) error

type CreateUserCommand 

type CreateUserCommand struct {
	Name                 *string  `protobuf:"bytes,1,req,name=Name" json:"Name,omitempty"`
	Hash                 *string  `protobuf:"bytes,2,req,name=Hash" json:"Hash,omitempty"`
	Admin                *bool    `protobuf:"varint,3,req,name=Admin" json:"Admin,omitempty"`
	RwUser               *bool    `protobuf:"varint,4,opt,name=RwUser" json:"RwUser,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateUserCommand) Descriptor 

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

func (*CreateUserCommand) GetAdmin 

func (m *CreateUserCommand) GetAdmin() bool

func (*CreateUserCommand) GetHash 

func (m *CreateUserCommand) GetHash() string

func (*CreateUserCommand) GetName 

func (m *CreateUserCommand) GetName() string

func (*CreateUserCommand) GetRwUser 

func (m *CreateUserCommand) GetRwUser() bool

func (*CreateUserCommand) ProtoMessage 

func (*CreateUserCommand) ProtoMessage()

func (*CreateUserCommand) Reset 

func (m *CreateUserCommand) Reset()

func (*CreateUserCommand) String 

func (m *CreateUserCommand) String() string

func (*CreateUserCommand) XXX_DiscardUnknown 

func (m *CreateUserCommand) XXX_DiscardUnknown()

func (*CreateUserCommand) XXX_Marshal 

func (m *CreateUserCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateUserCommand) XXX_Merge 

func (m *CreateUserCommand) XXX_Merge(src proto.Message)

func (*CreateUserCommand) XXX_Size 

func (m *CreateUserCommand) XXX_Size() int

func (*CreateUserCommand) XXX_Unmarshal 

func (m *CreateUserCommand) XXX_Unmarshal(b []byte) error

type DBPtInfo 

type DBPtInfo struct {
	DbPt                 []*PtInfo `protobuf:"bytes,1,rep,name=DbPt" json:"DbPt,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*DBPtInfo) Descriptor 

func (*DBPtInfo) Descriptor() ([]byte, []int)

func (*DBPtInfo) GetDbPt 

func (m *DBPtInfo) GetDbPt() []*PtInfo

func (*DBPtInfo) ProtoMessage 

func (*DBPtInfo) ProtoMessage()

func (*DBPtInfo) Reset 

func (m *DBPtInfo) Reset()

func (*DBPtInfo) String 

func (m *DBPtInfo) String() string

func (*DBPtInfo) XXX_DiscardUnknown 

func (m *DBPtInfo) XXX_DiscardUnknown()

func (*DBPtInfo) XXX_Marshal 

func (m *DBPtInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DBPtInfo) XXX_Merge 

func (m *DBPtInfo) XXX_Merge(src proto.Message)

func (*DBPtInfo) XXX_Size 

func (m *DBPtInfo) XXX_Size() int

func (*DBPtInfo) XXX_Unmarshal 

func (m *DBPtInfo) XXX_Unmarshal(b []byte) error

type DBPtStatus 

type DBPtStatus struct {
	DB                   *string          `protobuf:"bytes,1,req,name=DB" json:"DB,omitempty"`
	PtID                 *uint32          `protobuf:"varint,2,req,name=PtID" json:"PtID,omitempty"`
	RpStats              []*RpShardStatus `protobuf:"bytes,3,rep,name=RpStats" json:"RpStats,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*DBPtStatus) Descriptor 

func (*DBPtStatus) Descriptor() ([]byte, []int)

func (*DBPtStatus) GetDB 

func (m *DBPtStatus) GetDB() string

func (*DBPtStatus) GetPtID 

func (m *DBPtStatus) GetPtID() uint32

func (*DBPtStatus) GetRpStats 

func (m *DBPtStatus) GetRpStats() []*RpShardStatus

func (*DBPtStatus) ProtoMessage 

func (*DBPtStatus) ProtoMessage()

func (*DBPtStatus) Reset 

func (m *DBPtStatus) Reset()

func (*DBPtStatus) String 

func (m *DBPtStatus) String() string

func (*DBPtStatus) XXX_DiscardUnknown 

func (m *DBPtStatus) XXX_DiscardUnknown()

func (*DBPtStatus) XXX_Marshal 

func (m *DBPtStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DBPtStatus) XXX_Merge 

func (m *DBPtStatus) XXX_Merge(src proto.Message)

func (*DBPtStatus) XXX_Size 

func (m *DBPtStatus) XXX_Size() int

func (*DBPtStatus) XXX_Unmarshal 

func (m *DBPtStatus) XXX_Unmarshal(b []byte) error

type Data 

type Data struct {
	Term                 *uint64                  `protobuf:"varint,1,req,name=Term" json:"Term,omitempty"`
	Index                *uint64                  `protobuf:"varint,2,req,name=Index" json:"Index,omitempty"`
	ClusterID            *uint64                  `protobuf:"varint,3,req,name=ClusterID" json:"ClusterID,omitempty"`
	Nodes                []*NodeInfo              `protobuf:"bytes,4,rep,name=Nodes" json:"Nodes,omitempty"`
	Databases            []*DatabaseInfo          `protobuf:"bytes,5,rep,name=Databases" json:"Databases,omitempty"`
	Users                []*UserInfo              `protobuf:"bytes,6,rep,name=Users" json:"Users,omitempty"`
	MaxNodeID            *uint64                  `protobuf:"varint,7,req,name=MaxNodeID" json:"MaxNodeID,omitempty"`
	MaxShardGroupID      *uint64                  `protobuf:"varint,8,req,name=MaxShardGroupID" json:"MaxShardGroupID,omitempty"`
	MaxShardID           *uint64                  `protobuf:"varint,9,req,name=MaxShardID" json:"MaxShardID,omitempty"`
	DataNodes            []*DataNode              `protobuf:"bytes,10,rep,name=DataNodes" json:"DataNodes,omitempty"`
	MetaNodes            []*NodeInfo              `protobuf:"bytes,11,rep,name=MetaNodes" json:"MetaNodes,omitempty"`
	ClusterPtNum         *uint32                  `protobuf:"varint,14,req,name=ClusterPtNum" json:"ClusterPtNum,omitempty"`
	PtView               map[string]*DBPtInfo     `` /* 133-byte string literal not displayed */
	PtNumPerNode         *uint32                  `protobuf:"varint,16,opt,name=PtNumPerNode" json:"PtNumPerNode,omitempty"`
	MaxIndexGroupID      *uint64                  `protobuf:"varint,17,req,name=MaxIndexGroupID" json:"MaxIndexGroupID,omitempty"`
	MaxIndexID           *uint64                  `protobuf:"varint,18,req,name=MaxIndexID" json:"MaxIndexID,omitempty"`
	MaxEventOpId         *uint64                  `protobuf:"varint,19,opt,name=MaxEventOpId" json:"MaxEventOpId,omitempty"`
	TakeOverEnabled      *bool                    `protobuf:"varint,20,opt,name=TakeOverEnabled" json:"TakeOverEnabled,omitempty"`
	MigrateEvents        []*MigrateEventInfo      `protobuf:"bytes,21,rep,name=MigrateEvents" json:"MigrateEvents,omitempty"`
	BalancerEnabled      *bool                    `protobuf:"varint,22,opt,name=BalancerEnabled" json:"BalancerEnabled,omitempty"`
	MaxDownSampleID      *uint64                  `protobuf:"varint,23,opt,name=MaxDownSampleID" json:"MaxDownSampleID,omitempty"`
	Streams              []*StreamInfo            `protobuf:"bytes,24,rep,name=Streams" json:"Streams,omitempty"`
	MaxStreamID          *uint64                  `protobuf:"varint,25,opt,name=MaxStreamID" json:"MaxStreamID,omitempty"`
	MaxConnId            *uint64                  `protobuf:"varint,26,opt,name=MaxConnId" json:"MaxConnId,omitempty"`
	QueryIDInit          map[string]uint64        `` /* 144-byte string literal not displayed */
	ReplicaGroups        map[string]*Replications `` /* 147-byte string literal not displayed */
	MaxSubscriptionID    *uint64                  `protobuf:"varint,29,opt,name=MaxSubscriptionID" json:"MaxSubscriptionID,omitempty"`
	MaxCQChangeID        *uint64                  `protobuf:"varint,30,opt,name=MaxCQChangeID" json:"MaxCQChangeID,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*Data) Descriptor 

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

func (*Data) GetBalancerEnabled 

func (m *Data) GetBalancerEnabled() bool

func (*Data) GetClusterID 

func (m *Data) GetClusterID() uint64

func (*Data) GetClusterPtNum 

func (m *Data) GetClusterPtNum() uint32

func (*Data) GetDataNodes 

func (m *Data) GetDataNodes() []*DataNode

func (*Data) GetDatabases 

func (m *Data) GetDatabases() []*DatabaseInfo

func (*Data) GetIndex 

func (m *Data) GetIndex() uint64

func (*Data) GetMaxCQChangeID 

func (m *Data) GetMaxCQChangeID() uint64

func (*Data) GetMaxConnId 

func (m *Data) GetMaxConnId() uint64

func (*Data) GetMaxDownSampleID 

func (m *Data) GetMaxDownSampleID() uint64

func (*Data) GetMaxEventOpId 

func (m *Data) GetMaxEventOpId() uint64

func (*Data) GetMaxIndexGroupID 

func (m *Data) GetMaxIndexGroupID() uint64

func (*Data) GetMaxIndexID 

func (m *Data) GetMaxIndexID() uint64

func (*Data) GetMaxNodeID 

func (m *Data) GetMaxNodeID() uint64

func (*Data) GetMaxShardGroupID 

func (m *Data) GetMaxShardGroupID() uint64

func (*Data) GetMaxShardID 

func (m *Data) GetMaxShardID() uint64

func (*Data) GetMaxStreamID 

func (m *Data) GetMaxStreamID() uint64

func (*Data) GetMaxSubscriptionID 

func (m *Data) GetMaxSubscriptionID() uint64

func (*Data) GetMetaNodes 

func (m *Data) GetMetaNodes() []*NodeInfo

func (*Data) GetMigrateEvents 

func (m *Data) GetMigrateEvents() []*MigrateEventInfo

func (*Data) GetNodes 

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

func (*Data) GetPtNumPerNode 

func (m *Data) GetPtNumPerNode() uint32

func (*Data) GetPtView 

func (m *Data) GetPtView() map[string]*DBPtInfo

func (*Data) GetQueryIDInit 

func (m *Data) GetQueryIDInit() map[string]uint64

func (*Data) GetReplicaGroups 

func (m *Data) GetReplicaGroups() map[string]*Replications

func (*Data) GetStreams 

func (m *Data) GetStreams() []*StreamInfo

func (*Data) GetTakeOverEnabled 

func (m *Data) GetTakeOverEnabled() bool

func (*Data) GetTerm 

func (m *Data) GetTerm() uint64

func (*Data) GetUsers 

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

func (*Data) ProtoMessage 

func (*Data) ProtoMessage()

func (*Data) Reset 

func (m *Data) Reset()

func (*Data) String 

func (m *Data) String() string

func (*Data) XXX_DiscardUnknown 

func (m *Data) XXX_DiscardUnknown()

func (*Data) XXX_Marshal 

func (m *Data) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Data) XXX_Merge 

func (m *Data) XXX_Merge(src proto.Message)

func (*Data) XXX_Size 

func (m *Data) XXX_Size() int

func (*Data) XXX_Unmarshal 

func (m *Data) XXX_Unmarshal(b []byte) error

type DataNode 

type DataNode struct {
	Ni                   *NodeInfo `protobuf:"bytes,1,req,name=Ni" json:"Ni,omitempty"`
	ConnID               *uint64   `protobuf:"varint,2,opt,name=ConnID" json:"ConnID,omitempty"`
	AliveConnID          *uint64   `protobuf:"varint,3,opt,name=AliveConnID" json:"AliveConnID,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*DataNode) Descriptor 

func (*DataNode) Descriptor() ([]byte, []int)

func (*DataNode) GetAliveConnID 

func (m *DataNode) GetAliveConnID() uint64

func (*DataNode) GetConnID 

func (m *DataNode) GetConnID() uint64

func (*DataNode) GetNi 

func (m *DataNode) GetNi() *NodeInfo

func (*DataNode) ProtoMessage 

func (*DataNode) ProtoMessage()

func (*DataNode) Reset 

func (m *DataNode) Reset()

func (*DataNode) String 

func (m *DataNode) String() string

func (*DataNode) XXX_DiscardUnknown 

func (m *DataNode) XXX_DiscardUnknown()

func (*DataNode) XXX_Marshal 

func (m *DataNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataNode) XXX_Merge 

func (m *DataNode) XXX_Merge(src proto.Message)

func (*DataNode) XXX_Size 

func (m *DataNode) XXX_Size() int

func (*DataNode) XXX_Unmarshal 

func (m *DataNode) XXX_Unmarshal(b []byte) error

type DataNodeEvent 

type DataNodeEvent struct {
	Host                 []byte   `protobuf:"bytes,1,req,name=Host" json:"Host,omitempty"`
	EventType            *int64   `protobuf:"varint,2,req,name=EventType" json:"EventType,omitempty"`
	LTime                *uint64  `protobuf:"varint,3,req,name=LTime" json:"LTime,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DataNodeEvent) Descriptor 

func (*DataNodeEvent) Descriptor() ([]byte, []int)

func (*DataNodeEvent) GetEventType 

func (m *DataNodeEvent) GetEventType() int64

func (*DataNodeEvent) GetHost 

func (m *DataNodeEvent) GetHost() []byte

func (*DataNodeEvent) GetLTime 

func (m *DataNodeEvent) GetLTime() uint64

func (*DataNodeEvent) ProtoMessage 

func (*DataNodeEvent) ProtoMessage()

func (*DataNodeEvent) Reset 

func (m *DataNodeEvent) Reset()

func (*DataNodeEvent) String 

func (m *DataNodeEvent) String() string

func (*DataNodeEvent) XXX_DiscardUnknown 

func (m *DataNodeEvent) XXX_DiscardUnknown()

func (*DataNodeEvent) XXX_Marshal 

func (m *DataNodeEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataNodeEvent) XXX_Merge 

func (m *DataNodeEvent) XXX_Merge(src proto.Message)

func (*DataNodeEvent) XXX_Size 

func (m *DataNodeEvent) XXX_Size() int

func (*DataNodeEvent) XXX_Unmarshal 

func (m *DataNodeEvent) XXX_Unmarshal(b []byte) error

type DatabaseBriefInfo 

type DatabaseBriefInfo struct {
	Name                 *string  `protobuf:"bytes,1,req,name=Name" json:"Name,omitempty"`
	EnableTagArray       *bool    `protobuf:"varint,2,req,name=EnableTagArray" json:"EnableTagArray,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DatabaseBriefInfo) Descriptor 

func (*DatabaseBriefInfo) Descriptor() ([]byte, []int)

func (*DatabaseBriefInfo) GetEnableTagArray 

func (m *DatabaseBriefInfo) GetEnableTagArray() bool

func (*DatabaseBriefInfo) GetName 

func (m *DatabaseBriefInfo) GetName() string

func (*DatabaseBriefInfo) ProtoMessage 

func (*DatabaseBriefInfo) ProtoMessage()

func (*DatabaseBriefInfo) Reset 

func (m *DatabaseBriefInfo) Reset()

func (*DatabaseBriefInfo) String 

func (m *DatabaseBriefInfo) String() string

func (*DatabaseBriefInfo) XXX_DiscardUnknown 

func (m *DatabaseBriefInfo) XXX_DiscardUnknown()

func (*DatabaseBriefInfo) XXX_Marshal 

func (m *DatabaseBriefInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DatabaseBriefInfo) XXX_Merge 

func (m *DatabaseBriefInfo) XXX_Merge(src proto.Message)

func (*DatabaseBriefInfo) XXX_Size 

func (m *DatabaseBriefInfo) XXX_Size() int

func (*DatabaseBriefInfo) XXX_Unmarshal 

func (m *DatabaseBriefInfo) XXX_Unmarshal(b []byte) error

type DatabaseInfo 

type DatabaseInfo struct {
	Name                   *string                `protobuf:"bytes,1,req,name=Name" json:"Name,omitempty"`
	DefaultRetentionPolicy *string                `protobuf:"bytes,2,req,name=DefaultRetentionPolicy" json:"DefaultRetentionPolicy,omitempty"`
	RetentionPolicies      []*RetentionPolicyInfo `protobuf:"bytes,3,rep,name=RetentionPolicies" json:"RetentionPolicies,omitempty"`
	ContinuousQueries      []*ContinuousQueryInfo `protobuf:"bytes,4,rep,name=ContinuousQueries" json:"ContinuousQueries,omitempty"`
	MarkDeleted            *bool                  `protobuf:"varint,5,opt,name=MarkDeleted" json:"MarkDeleted,omitempty"`
	ShardKey               *ShardKeyInfo          `protobuf:"bytes,6,opt,name=ShardKey" json:"ShardKey,omitempty"`
	EnableTagArray         *bool                  `protobuf:"varint,7,opt,name=EnableTagArray" json:"EnableTagArray,omitempty"`
	ReplicaN               *int64                 `protobuf:"varint,8,opt,name=ReplicaN" json:"ReplicaN,omitempty"`
	Options                *ObsOptions            `protobuf:"bytes,21,opt,name=Options" json:"Options,omitempty"`
	XXX_NoUnkeyedLiteral   struct{}               `json:"-"`
	XXX_unrecognized       []byte                 `json:"-"`
	XXX_sizecache          int32                  `json:"-"`
}

func (*DatabaseInfo) Descriptor 

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

func (*DatabaseInfo) GetContinuousQueries 

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

func (*DatabaseInfo) GetDefaultRetentionPolicy 

func (m *DatabaseInfo) GetDefaultRetentionPolicy() string

func (*DatabaseInfo) GetEnableTagArray 

func (m *DatabaseInfo) GetEnableTagArray() bool

func (*DatabaseInfo) GetMarkDeleted 

func (m *DatabaseInfo) GetMarkDeleted() bool

func (*DatabaseInfo) GetName 

func (m *DatabaseInfo) GetName() string

func (*DatabaseInfo) GetOptions 

func (m *DatabaseInfo) GetOptions() *ObsOptions

func (*DatabaseInfo) GetReplicaN 

func (m *DatabaseInfo) GetReplicaN() int64

func (*DatabaseInfo) GetRetentionPolicies 

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

func (*DatabaseInfo) GetShardKey 

func (m *DatabaseInfo) GetShardKey() *ShardKeyInfo

func (*DatabaseInfo) ProtoMessage 

func (*DatabaseInfo) ProtoMessage()

func (*DatabaseInfo) Reset 

func (m *DatabaseInfo) Reset()

func (*DatabaseInfo) String 

func (m *DatabaseInfo) String() string

func (*DatabaseInfo) XXX_DiscardUnknown 

func (m *DatabaseInfo) XXX_DiscardUnknown()

func (*DatabaseInfo) XXX_Marshal 

func (m *DatabaseInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DatabaseInfo) XXX_Merge 

func (m *DatabaseInfo) XXX_Merge(src proto.Message)

func (*DatabaseInfo) XXX_Size 

func (m *DatabaseInfo) XXX_Size() int

func (*DatabaseInfo) XXX_Unmarshal 

func (m *DatabaseInfo) XXX_Unmarshal(b []byte) error

type DbPt 

type DbPt struct {
	Db                   *string                       `protobuf:"bytes,1,req,name=Db" json:"Db,omitempty"`
	Pt                   *PtInfo                       `protobuf:"bytes,2,req,name=Pt" json:"Pt,omitempty"`
	Shards               map[uint64]*ShardDurationInfo `` /* 133-byte string literal not displayed */
	DBBriefInfo          *DatabaseBriefInfo            `protobuf:"bytes,4,opt,name=DBBriefInfo" json:"DBBriefInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                      `json:"-"`
	XXX_unrecognized     []byte                        `json:"-"`
	XXX_sizecache        int32                         `json:"-"`
}

func (*DbPt) Descriptor 

func (*DbPt) Descriptor() ([]byte, []int)

func (*DbPt) GetDBBriefInfo 

func (m *DbPt) GetDBBriefInfo() *DatabaseBriefInfo

func (*DbPt) GetDb 

func (m *DbPt) GetDb() string

func (*DbPt) GetPt 

func (m *DbPt) GetPt() *PtInfo

func (*DbPt) GetShards 

func (m *DbPt) GetShards() map[uint64]*ShardDurationInfo

func (*DbPt) ProtoMessage 

func (*DbPt) ProtoMessage()

func (*DbPt) Reset 

func (m *DbPt) Reset()

func (*DbPt) String 

func (m *DbPt) String() string

func (*DbPt) XXX_DiscardUnknown 

func (m *DbPt) XXX_DiscardUnknown()

func (*DbPt) XXX_Marshal 

func (m *DbPt) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DbPt) XXX_Merge 

func (m *DbPt) XXX_Merge(src proto.Message)

func (*DbPt) XXX_Size 

func (m *DbPt) XXX_Size() int

func (*DbPt) XXX_Unmarshal 

func (m *DbPt) XXX_Unmarshal(b []byte) error

type DeleteDataNodeCommand 

type DeleteDataNodeCommand struct {
	ID                   *uint64  `protobuf:"varint,1,req,name=ID" json:"ID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteDataNodeCommand) Descriptor 

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

func (*DeleteDataNodeCommand) GetID 

func (m *DeleteDataNodeCommand) GetID() uint64

func (*DeleteDataNodeCommand) ProtoMessage 

func (*DeleteDataNodeCommand) ProtoMessage()

func (*DeleteDataNodeCommand) Reset 

func (m *DeleteDataNodeCommand) Reset()

func (*DeleteDataNodeCommand) String 

func (m *DeleteDataNodeCommand) String() string

func (*DeleteDataNodeCommand) XXX_DiscardUnknown 

func (m *DeleteDataNodeCommand) XXX_DiscardUnknown()

func (*DeleteDataNodeCommand) XXX_Marshal 

func (m *DeleteDataNodeCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteDataNodeCommand) XXX_Merge 

func (m *DeleteDataNodeCommand) XXX_Merge(src proto.Message)

func (*DeleteDataNodeCommand) XXX_Size 

func (m *DeleteDataNodeCommand) XXX_Size() int

func (*DeleteDataNodeCommand) XXX_Unmarshal 

func (m *DeleteDataNodeCommand) XXX_Unmarshal(b []byte) error

type DeleteIndexGroupCommand 

type DeleteIndexGroupCommand struct {
	Database             *string  `protobuf:"bytes,1,req,name=Database" json:"Database,omitempty"`
	Policy               *string  `protobuf:"bytes,2,req,name=Policy" json:"Policy,omitempty"`
	IndexGroupID         *uint64  `protobuf:"varint,3,req,name=IndexGroupID" json:"IndexGroupID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteIndexGroupCommand) Descriptor 

func (*DeleteIndexGroupCommand) Descriptor() ([]byte, []int)

func (*DeleteIndexGroupCommand) GetDatabase 

func (m *DeleteIndexGroupCommand) GetDatabase() string

func (*DeleteIndexGroupCommand) GetIndexGroupID 

func (m *DeleteIndexGroupCommand) GetIndexGroupID() uint64

func (*DeleteIndexGroupCommand) GetPolicy 

func (m *DeleteIndexGroupCommand) GetPolicy() string

func (*DeleteIndexGroupCommand) ProtoMessage 

func (*DeleteIndexGroupCommand) ProtoMessage()

func (*DeleteIndexGroupCommand) Reset 

func (m *DeleteIndexGroupCommand) Reset()

func (*DeleteIndexGroupCommand) String 

func (m *DeleteIndexGroupCommand) String() string

func (*DeleteIndexGroupCommand) XXX_DiscardUnknown 

func (m *DeleteIndexGroupCommand) XXX_DiscardUnknown()

func (*DeleteIndexGroupCommand) XXX_Marshal 

func (m *DeleteIndexGroupCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteIndexGroupCommand) XXX_Merge 

func (m *DeleteIndexGroupCommand) XXX_Merge(src proto.Message)

func (*DeleteIndexGroupCommand) XXX_Size 

func (m *DeleteIndexGroupCommand) XXX_Size() int

func (*DeleteIndexGroupCommand) XXX_Unmarshal 

func (m *DeleteIndexGroupCommand) XXX_Unmarshal(b []byte) error

type DeleteMetaNodeCommand 

type DeleteMetaNodeCommand struct {
	ID                   *uint64  `protobuf:"varint,1,req,name=ID" json:"ID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteMetaNodeCommand) Descriptor 

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

func (*DeleteMetaNodeCommand) GetID 

func (m *DeleteMetaNodeCommand) GetID() uint64

func (*DeleteMetaNodeCommand) ProtoMessage 

func (*DeleteMetaNodeCommand) ProtoMessage()

func (*DeleteMetaNodeCommand) Reset 

func (m *DeleteMetaNodeCommand) Reset()

func (*DeleteMetaNodeCommand) String 

func (m *DeleteMetaNodeCommand) String() string

func (*DeleteMetaNodeCommand) XXX_DiscardUnknown 

func (m *DeleteMetaNodeCommand) XXX_DiscardUnknown()

func (*DeleteMetaNodeCommand) XXX_Marshal 

func (m *DeleteMetaNodeCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteMetaNodeCommand) XXX_Merge 

func (m *DeleteMetaNodeCommand) XXX_Merge(src proto.Message)

func (*DeleteMetaNodeCommand) XXX_Size 

func (m *DeleteMetaNodeCommand) XXX_Size() int

func (*DeleteMetaNodeCommand) XXX_Unmarshal 

func (m *DeleteMetaNodeCommand) XXX_Unmarshal(b []byte) error

type DeleteShardGroupCommand 

type DeleteShardGroupCommand struct {
	Database             *string  `protobuf:"bytes,1,req,name=Database" json:"Database,omitempty"`
	Policy               *string  `protobuf:"bytes,2,req,name=Policy" json:"Policy,omitempty"`
	ShardGroupID         *uint64  `protobuf:"varint,3,req,name=ShardGroupID" json:"ShardGroupID,omitempty"`
	DeletedAt            *int64   `protobuf:"varint,6,opt,name=DeletedAt" json:"DeletedAt,omitempty"`
	DeleteType           *int32   `protobuf:"varint,7,opt,name=DeleteType" json:"DeleteType,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteShardGroupCommand) Descriptor 

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

func (*DeleteShardGroupCommand) GetDatabase 

func (m *DeleteShardGroupCommand) GetDatabase() string

func (*DeleteShardGroupCommand) GetDeleteType 

func (m *DeleteShardGroupCommand) GetDeleteType() int32

func (*DeleteShardGroupCommand) GetDeletedAt 

func (m *DeleteShardGroupCommand) GetDeletedAt() int64

func (*DeleteShardGroupCommand) GetPolicy 

func (m *DeleteShardGroupCommand) GetPolicy() string

func (*DeleteShardGroupCommand) GetShardGroupID 

func (m *DeleteShardGroupCommand) GetShardGroupID() uint64

func (*DeleteShardGroupCommand) ProtoMessage 

func (*DeleteShardGroupCommand) ProtoMessage()

func (*DeleteShardGroupCommand) Reset 

func (m *DeleteShardGroupCommand) Reset()

func (*DeleteShardGroupCommand) String 

func (m *DeleteShardGroupCommand) String() string

func (*DeleteShardGroupCommand) XXX_DiscardUnknown 

func (m *DeleteShardGroupCommand) XXX_DiscardUnknown()

func (*DeleteShardGroupCommand) XXX_Marshal 

func (m *DeleteShardGroupCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteShardGroupCommand) XXX_Merge 

func (m *DeleteShardGroupCommand) XXX_Merge(src proto.Message)

func (*DeleteShardGroupCommand) XXX_Size 

func (m *DeleteShardGroupCommand) XXX_Size() int

func (*DeleteShardGroupCommand) XXX_Unmarshal 

func (m *DeleteShardGroupCommand) XXX_Unmarshal(b []byte) error

type DownSampleOperators 

type DownSampleOperators struct {
	AggOps               []string `protobuf:"bytes,1,rep,name=AggOps" json:"AggOps,omitempty"`
	DataType             *int64   `protobuf:"varint,2,req,name=DataType" json:"DataType,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DownSampleOperators) Descriptor 

func (*DownSampleOperators) Descriptor() ([]byte, []int)

func (*DownSampleOperators) GetAggOps 

func (m *DownSampleOperators) GetAggOps() []string

func (*DownSampleOperators) GetDataType 

func (m *DownSampleOperators) GetDataType() int64

func (*DownSampleOperators) ProtoMessage 

func (*DownSampleOperators) ProtoMessage()

func (*DownSampleOperators) Reset 

func (m *DownSampleOperators) Reset()

func (*DownSampleOperators) String 

func (m *DownSampleOperators) String() string

func (*DownSampleOperators) XXX_DiscardUnknown 

func (m *DownSampleOperators) XXX_DiscardUnknown()

func (*DownSampleOperators) XXX_Marshal 

func (m *DownSampleOperators) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DownSampleOperators) XXX_Merge 

func (m *DownSampleOperators) XXX_Merge(src proto.Message)

func (*DownSampleOperators) XXX_Size 

func (m *DownSampleOperators) XXX_Size() int

func (*DownSampleOperators) XXX_Unmarshal 

func (m *DownSampleOperators) XXX_Unmarshal(b []byte) error

type DownSamplePoliciesInfoWithDbRp 

type DownSamplePoliciesInfoWithDbRp struct {
	Infos                []*DownSamplePolicyInfoWithDbRp `protobuf:"bytes,1,rep,name=Infos" json:"Infos,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*DownSamplePoliciesInfoWithDbRp) Descriptor 

func (*DownSamplePoliciesInfoWithDbRp) Descriptor() ([]byte, []int)

func (*DownSamplePoliciesInfoWithDbRp) GetInfos 

func (m *DownSamplePoliciesInfoWithDbRp) GetInfos() []*DownSamplePolicyInfoWithDbRp

func (*DownSamplePoliciesInfoWithDbRp) ProtoMessage 

func (*DownSamplePoliciesInfoWithDbRp) ProtoMessage()

func (*DownSamplePoliciesInfoWithDbRp) Reset 

func (m *DownSamplePoliciesInfoWithDbRp) Reset()

func (*DownSamplePoliciesInfoWithDbRp) String 

func (m *DownSamplePoliciesInfoWithDbRp) String() string

func (*DownSamplePoliciesInfoWithDbRp) XXX_DiscardUnknown 

func (m *DownSamplePoliciesInfoWithDbRp) XXX_DiscardUnknown()

func (*DownSamplePoliciesInfoWithDbRp) XXX_Marshal 

func (m *DownSamplePoliciesInfoWithDbRp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DownSamplePoliciesInfoWithDbRp) XXX_Merge 

func (m *DownSamplePoliciesInfoWithDbRp) XXX_Merge(src proto.Message)

func (*DownSamplePoliciesInfoWithDbRp) XXX_Size 

func (m *DownSamplePoliciesInfoWithDbRp) XXX_Size() int

func (*DownSamplePoliciesInfoWithDbRp) XXX_Unmarshal 

func (m *DownSamplePoliciesInfoWithDbRp) XXX_Unmarshal(b []byte) error

type DownSamplePolicy 

type DownSamplePolicy struct {
	SampleInterval       *int64   `protobuf:"varint,1,req,name=SampleInterval" json:"SampleInterval,omitempty"`
	TimeInterval         *int64   `protobuf:"varint,2,req,name=TimeInterval" json:"TimeInterval,omitempty"`
	WaterMark            *int64   `protobuf:"varint,3,req,name=WaterMark" json:"WaterMark,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DownSamplePolicy) Descriptor 

func (*DownSamplePolicy) Descriptor() ([]byte, []int)

func (*DownSamplePolicy) GetSampleInterval 

func (m *DownSamplePolicy) GetSampleInterval() int64

func (*DownSamplePolicy) GetTimeInterval 

func (m *DownSamplePolicy) GetTimeInterval() int64

func (*DownSamplePolicy) GetWaterMark 

func (m *DownSamplePolicy) GetWaterMark() int64

func (*DownSamplePolicy) ProtoMessage 

func (*DownSamplePolicy) ProtoMessage()

func (*DownSamplePolicy) Reset 

func (m *DownSamplePolicy) Reset()

func (*DownSamplePolicy) String 

func (m *DownSamplePolicy) String() string

func (*DownSamplePolicy) XXX_DiscardUnknown 

func (m *DownSamplePolicy) XXX_DiscardUnknown()

func (*DownSamplePolicy) XXX_Marshal 

func (m *DownSamplePolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DownSamplePolicy) XXX_Merge 

func (m *DownSamplePolicy) XXX_Merge(src proto.Message)

func (*DownSamplePolicy) XXX_Size 

func (m *DownSamplePolicy) XXX_Size() int

func (*DownSamplePolicy) XXX_Unmarshal 

func (m *DownSamplePolicy) XXX_Unmarshal(b []byte) error

type DownSamplePolicyInfo 

type DownSamplePolicyInfo struct {
	Calls                []*DownSampleOperators `protobuf:"bytes,1,rep,name=Calls" json:"Calls,omitempty"`
	DownSamplePolicies   []*DownSamplePolicy    `protobuf:"bytes,2,rep,name=DownSamplePolicies" json:"DownSamplePolicies,omitempty"`
	Duration             *int64                 `protobuf:"varint,3,req,name=Duration" json:"Duration,omitempty"`
	TaskID               *uint64                `protobuf:"varint,4,opt,name=TaskID" json:"TaskID,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*DownSamplePolicyInfo) Descriptor 

func (*DownSamplePolicyInfo) Descriptor() ([]byte, []int)

func (*DownSamplePolicyInfo) GetCalls 

func (m *DownSamplePolicyInfo) GetCalls() []*DownSampleOperators

func (*DownSamplePolicyInfo) GetDownSamplePolicies 

func (m *DownSamplePolicyInfo) GetDownSamplePolicies() []*DownSamplePolicy

func (*DownSamplePolicyInfo) GetDuration 

func (m *DownSamplePolicyInfo) GetDuration() int64

func (*DownSamplePolicyInfo) GetTaskID 

func (m *DownSamplePolicyInfo) GetTaskID() uint64

func (*DownSamplePolicyInfo) ProtoMessage 

func (*DownSamplePolicyInfo) ProtoMessage()

func (*DownSamplePolicyInfo) Reset 

func (m *DownSamplePolicyInfo) Reset()

func (*DownSamplePolicyInfo) String 

func (m *DownSamplePolicyInfo) String() string

func (*DownSamplePolicyInfo) XXX_DiscardUnknown 

func (m *DownSamplePolicyInfo) XXX_DiscardUnknown()

func (*DownSamplePolicyInfo) XXX_Marshal 

func (m *DownSamplePolicyInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DownSamplePolicyInfo) XXX_Merge 

func (m *DownSamplePolicyInfo) XXX_Merge(src proto.Message)

func (*DownSamplePolicyInfo) XXX_Size 

func (m *DownSamplePolicyInfo) XXX_Size() int

func (*DownSamplePolicyInfo) XXX_Unmarshal 

func (m *DownSamplePolicyInfo) XXX_Unmarshal(b []byte) error

type DownSamplePolicyInfoWithDbRp 

type DownSamplePolicyInfoWithDbRp struct {
	Info                 *DownSamplePolicyInfo `protobuf:"bytes,1,req,name=Info" json:"Info,omitempty"`
	DbName               *string               `protobuf:"bytes,2,req,name=DbName" json:"DbName,omitempty"`
	RpName               *string               `protobuf:"bytes,3,req,name=RpName" json:"RpName,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*DownSamplePolicyInfoWithDbRp) Descriptor 

func (*DownSamplePolicyInfoWithDbRp) Descriptor() ([]byte, []int)

func (*DownSamplePolicyInfoWithDbRp) GetDbName 

func (m *DownSamplePolicyInfoWithDbRp) GetDbName() string

func (*DownSamplePolicyInfoWithDbRp) GetInfo 

func (m *DownSamplePolicyInfoWithDbRp) GetInfo() *DownSamplePolicyInfo

func (*DownSamplePolicyInfoWithDbRp) GetRpName 

func (m *DownSamplePolicyInfoWithDbRp) GetRpName() string

func (*DownSamplePolicyInfoWithDbRp) ProtoMessage 

func (*DownSamplePolicyInfoWithDbRp) ProtoMessage()

func (*DownSamplePolicyInfoWithDbRp) Reset 

func (m *DownSamplePolicyInfoWithDbRp) Reset()

func (*DownSamplePolicyInfoWithDbRp) String 

func (m *DownSamplePolicyInfoWithDbRp) String() string

func (*DownSamplePolicyInfoWithDbRp) XXX_DiscardUnknown 

func (m *DownSamplePolicyInfoWithDbRp) XXX_DiscardUnknown()

func (*DownSamplePolicyInfoWithDbRp) XXX_Marshal 

func (m *DownSamplePolicyInfoWithDbRp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DownSamplePolicyInfoWithDbRp) XXX_Merge 

func (m *DownSamplePolicyInfoWithDbRp) XXX_Merge(src proto.Message)

func (*DownSamplePolicyInfoWithDbRp) XXX_Size 

func (m *DownSamplePolicyInfoWithDbRp) XXX_Size() int

func (*DownSamplePolicyInfoWithDbRp) XXX_Unmarshal 

func (m *DownSamplePolicyInfoWithDbRp) XXX_Unmarshal(b []byte) error

type DropContinuousQueryCommand 

type DropContinuousQueryCommand struct {
	Name                 *string  `protobuf:"bytes,1,req,name=Name" json:"Name,omitempty"`
	Database             *string  `protobuf:"bytes,2,req,name=Database" json:"Database,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DropContinuousQueryCommand) Descriptor 

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

func (*DropContinuousQueryCommand) GetDatabase 

func (m *DropContinuousQueryCommand) GetDatabase() string

func (*DropContinuousQueryCommand) GetName 

func (m *DropContinuousQueryCommand) GetName() string

func (*DropContinuousQueryCommand) ProtoMessage 

func (*DropContinuousQueryCommand) ProtoMessage()

func (*DropContinuousQueryCommand) Reset 

func (m *DropContinuousQueryCommand) Reset()

func (*DropContinuousQueryCommand) String 

func (m *DropContinuousQueryCommand) String() string

func (*DropContinuousQueryCommand) XXX_DiscardUnknown 

func (m *DropContinuousQueryCommand) XXX_DiscardUnknown()

func (*DropContinuousQueryCommand) XXX_Marshal 

func (m *DropContinuousQueryCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DropContinuousQueryCommand) XXX_Merge 

func (m *DropContinuousQueryCommand) XXX_Merge(src proto.Message)

func (*DropContinuousQueryCommand) XXX_Size 

func (m *DropContinuousQueryCommand) XXX_Size() int

func (*DropContinuousQueryCommand) XXX_Unmarshal 

func (m *DropContinuousQueryCommand) XXX_Unmarshal(b []byte) error

type DropDatabaseCommand 

type DropDatabaseCommand struct {
	Name                 *string  `protobuf:"bytes,1,req,name=Name" json:"Name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DropDatabaseCommand) Descriptor 

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

func (*DropDatabaseCommand) GetName 

func (m *DropDatabaseCommand) GetName() string

func (*DropDatabaseCommand) ProtoMessage 

func (*DropDatabaseCommand) ProtoMessage()

func (*DropDatabaseCommand) Reset 

func (m *DropDatabaseCommand) Reset()

func (*DropDatabaseCommand) String 

func (m *DropDatabaseCommand) String() string

func (*DropDatabaseCommand) XXX_DiscardUnknown 

func (m *DropDatabaseCommand) XXX_DiscardUnknown()

func (*DropDatabaseCommand) XXX_Marshal 

func (m *DropDatabaseCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DropDatabaseCommand) XXX_Merge 

func (m *DropDatabaseCommand) XXX_Merge(src proto.Message)

func (*DropDatabaseCommand) XXX_Size 

func (m *DropDatabaseCommand) XXX_Size() int

func (*DropDatabaseCommand) XXX_Unmarshal 

func (m *DropDatabaseCommand) XXX_Unmarshal(b []byte) error
type DropDownSamplePolicyCommand struct {
	Database             *string  `protobuf:"bytes,1,req,name=Database" json:"Database,omitempty"`
	RpName               *string  `protobuf:"bytes,2,req,name=rpName" json:"rpName,omitempty"`
	DropAll              *bool    `protobuf:"varint,3,opt,name=dropAll" json:"dropAll,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}
func (*DropDownSamplePolicyCommand) Descriptor() ([]byte, []int)
func (m *DropDownSamplePolicyCommand) GetDatabase() string
func (m *DropDownSamplePolicyCommand) GetDropAll() bool
func (m *DropDownSamplePolicyCommand) GetRpName() string
func (*DropDownSamplePolicyCommand) ProtoMessage()
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 

type DropMeasurementCommand struct {
	Database             *string  `protobuf:"bytes,1,req,name=Database" json:"Database,omitempty"`
	Policy               *string  `protobuf:"bytes,2,req,name=Policy" json:"Policy,omitempty"`
	Measurement          *string  `protobuf:"bytes,3,req,name=Measurement" json:"Measurement,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DropMeasurementCommand) Descriptor 

func (*DropMeasurementCommand) Descriptor() ([]byte, []int)

func (*DropMeasurementCommand) GetDatabase 

func (m *DropMeasurementCommand) GetDatabase() string

func (*DropMeasurementCommand) GetMeasurement 

func (m *DropMeasurementCommand) GetMeasurement() string

func (*DropMeasurementCommand) GetPolicy 

func (m *DropMeasurementCommand) GetPolicy() string

func (*DropMeasurementCommand) ProtoMessage 

func (*DropMeasurementCommand) ProtoMessage()

func (*DropMeasurementCommand) Reset 

func (m *DropMeasurementCommand) Reset()

func (*DropMeasurementCommand) String 

func (m *DropMeasurementCommand) String() string

func (*DropMeasurementCommand) XXX_DiscardUnknown 

func (m *DropMeasurementCommand) XXX_DiscardUnknown()

func (*DropMeasurementCommand) XXX_Marshal 

func (m *DropMeasurementCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DropMeasurementCommand) XXX_Merge 

func (m *DropMeasurementCommand) XXX_Merge(src proto.Message)

func (*DropMeasurementCommand) XXX_Size 

func (m *DropMeasurementCommand) XXX_Size() int

func (*DropMeasurementCommand) XXX_Unmarshal 

func (m *DropMeasurementCommand) XXX_Unmarshal(b []byte) error

type DropRetentionPolicyCommand 

type DropRetentionPolicyCommand struct {
	Database             *string  `protobuf:"bytes,1,req,name=Database" json:"Database,omitempty"`
	Name                 *string  `protobuf:"bytes,2,req,name=Name" json:"Name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DropRetentionPolicyCommand) Descriptor 

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

func (*DropRetentionPolicyCommand) GetDatabase 

func (m *DropRetentionPolicyCommand) GetDatabase() string

func (*DropRetentionPolicyCommand) GetName 

func (m *DropRetentionPolicyCommand) GetName() string

func (*DropRetentionPolicyCommand) ProtoMessage 

func (*DropRetentionPolicyCommand) ProtoMessage()

func (*DropRetentionPolicyCommand) Reset 

func (m *DropRetentionPolicyCommand) Reset()

func (*DropRetentionPolicyCommand) String 

func (m *DropRetentionPolicyCommand) String() string

func (*DropRetentionPolicyCommand) XXX_DiscardUnknown 

func (m *DropRetentionPolicyCommand) XXX_DiscardUnknown()

func (*DropRetentionPolicyCommand) XXX_Marshal 

func (m *DropRetentionPolicyCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DropRetentionPolicyCommand) XXX_Merge 

func (m *DropRetentionPolicyCommand) XXX_Merge(src proto.Message)

func (*DropRetentionPolicyCommand) XXX_Size 

func (m *DropRetentionPolicyCommand) XXX_Size() int

func (*DropRetentionPolicyCommand) XXX_Unmarshal 

func (m *DropRetentionPolicyCommand) XXX_Unmarshal(b []byte) error

type DropShardCommand 

type DropShardCommand struct {
	ID                   *uint64  `protobuf:"varint,1,req,name=ID" json:"ID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DropShardCommand) Descriptor 

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

func (*DropShardCommand) GetID 

func (m *DropShardCommand) GetID() uint64

func (*DropShardCommand) ProtoMessage 

func (*DropShardCommand) ProtoMessage()

func (*DropShardCommand) Reset 

func (m *DropShardCommand) Reset()

func (*DropShardCommand) String 

func (m *DropShardCommand) String() string

func (*DropShardCommand) XXX_DiscardUnknown 

func (m *DropShardCommand) XXX_DiscardUnknown()

func (*DropShardCommand) XXX_Marshal 

func (m *DropShardCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DropShardCommand) XXX_Merge 

func (m *DropShardCommand) XXX_Merge(src proto.Message)

func (*DropShardCommand) XXX_Size 

func (m *DropShardCommand) XXX_Size() int

func (*DropShardCommand) XXX_Unmarshal 

func (m *DropShardCommand) XXX_Unmarshal(b []byte) error

type DropStreamCommand 

type DropStreamCommand struct {
	Name                 *string  `protobuf:"bytes,1,req,name=Name" json:"Name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DropStreamCommand) Descriptor 

func (*DropStreamCommand) Descriptor() ([]byte, []int)

func (*DropStreamCommand) GetName 

func (m *DropStreamCommand) GetName() string

func (*DropStreamCommand) ProtoMessage 

func (*DropStreamCommand) ProtoMessage()

func (*DropStreamCommand) Reset 

func (m *DropStreamCommand) Reset()

func (*DropStreamCommand) String 

func (m *DropStreamCommand) String() string

func (*DropStreamCommand) XXX_DiscardUnknown 

func (m *DropStreamCommand) XXX_DiscardUnknown()

func (*DropStreamCommand) XXX_Marshal 

func (m *DropStreamCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DropStreamCommand) XXX_Merge 

func (m *DropStreamCommand) XXX_Merge(src proto.Message)

func (*DropStreamCommand) XXX_Size 

func (m *DropStreamCommand) XXX_Size() int

func (*DropStreamCommand) XXX_Unmarshal 

func (m *DropStreamCommand) XXX_Unmarshal(b []byte) error

type DropSubscriptionCommand 

type DropSubscriptionCommand struct {
	Name                 *string  `protobuf:"bytes,1,req,name=Name" json:"Name,omitempty"`
	Database             *string  `protobuf:"bytes,2,req,name=Database" json:"Database,omitempty"`
	RetentionPolicy      *string  `protobuf:"bytes,3,req,name=RetentionPolicy" json:"RetentionPolicy,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DropSubscriptionCommand) Descriptor 

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

func (*DropSubscriptionCommand) GetDatabase 

func (m *DropSubscriptionCommand) GetDatabase() string

func (*DropSubscriptionCommand) GetName 

func (m *DropSubscriptionCommand) GetName() string

func (*DropSubscriptionCommand) GetRetentionPolicy 

func (m *DropSubscriptionCommand) GetRetentionPolicy() string

func (*DropSubscriptionCommand) ProtoMessage 

func (*DropSubscriptionCommand) ProtoMessage()

func (*DropSubscriptionCommand) Reset 

func (m *DropSubscriptionCommand) Reset()

func (*DropSubscriptionCommand) String 

func (m *DropSubscriptionCommand) String() string

func (*DropSubscriptionCommand) XXX_DiscardUnknown 

func (m *DropSubscriptionCommand) XXX_DiscardUnknown()

func (*DropSubscriptionCommand) XXX_Marshal 

func (m *DropSubscriptionCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DropSubscriptionCommand) XXX_Merge 

func (m *DropSubscriptionCommand) XXX_Merge(src proto.Message)

func (*DropSubscriptionCommand) XXX_Size 

func (m *DropSubscriptionCommand) XXX_Size() int

func (*DropSubscriptionCommand) XXX_Unmarshal 

func (m *DropSubscriptionCommand) XXX_Unmarshal(b []byte) error

type DropUserCommand 

type DropUserCommand struct {
	Name                 *string  `protobuf:"bytes,1,req,name=Name" json:"Name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DropUserCommand) Descriptor 

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

func (*DropUserCommand) GetName 

func (m *DropUserCommand) GetName() string

func (*DropUserCommand) ProtoMessage 

func (*DropUserCommand) ProtoMessage()

func (*DropUserCommand) Reset 

func (m *DropUserCommand) Reset()

func (*DropUserCommand) String 

func (m *DropUserCommand) String() string

func (*DropUserCommand) XXX_DiscardUnknown 

func (m *DropUserCommand) XXX_DiscardUnknown()

func (*DropUserCommand) XXX_Marshal 

func (m *DropUserCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DropUserCommand) XXX_Merge 

func (m *DropUserCommand) XXX_Merge(src proto.Message)

func (*DropUserCommand) XXX_Size 

func (m *DropUserCommand) XXX_Size() int

func (*DropUserCommand) XXX_Unmarshal 

func (m *DropUserCommand) XXX_Unmarshal(b []byte) error

type DurationDescriptor 

type DurationDescriptor struct {
	TierType             *uint64  `protobuf:"varint,1,req,name=TierType" json:"TierType,omitempty"`
	TierDuration         *int64   `protobuf:"varint,2,req,name=TierDuration" json:"TierDuration,omitempty"`
	Duration             *int64   `protobuf:"varint,3,req,name=Duration" json:"Duration,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DurationDescriptor) Descriptor 

func (*DurationDescriptor) Descriptor() ([]byte, []int)

func (*DurationDescriptor) GetDuration 

func (m *DurationDescriptor) GetDuration() int64

func (*DurationDescriptor) GetTierDuration 

func (m *DurationDescriptor) GetTierDuration() int64

func (*DurationDescriptor) GetTierType 

func (m *DurationDescriptor) GetTierType() uint64

func (*DurationDescriptor) ProtoMessage 

func (*DurationDescriptor) ProtoMessage()

func (*DurationDescriptor) Reset 

func (m *DurationDescriptor) Reset()

func (*DurationDescriptor) String 

func (m *DurationDescriptor) String() string

func (*DurationDescriptor) XXX_DiscardUnknown 

func (m *DurationDescriptor) XXX_DiscardUnknown()

func (*DurationDescriptor) XXX_Marshal 

func (m *DurationDescriptor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DurationDescriptor) XXX_Merge 

func (m *DurationDescriptor) XXX_Merge(src proto.Message)

func (*DurationDescriptor) XXX_Size 

func (m *DurationDescriptor) XXX_Size() int

func (*DurationDescriptor) XXX_Unmarshal 

func (m *DurationDescriptor) XXX_Unmarshal(b []byte) error

type ExpandGroupsCommand 

type ExpandGroupsCommand struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExpandGroupsCommand) Descriptor 

func (*ExpandGroupsCommand) Descriptor() ([]byte, []int)

func (*ExpandGroupsCommand) ProtoMessage 

func (*ExpandGroupsCommand) ProtoMessage()

func (*ExpandGroupsCommand) Reset 

func (m *ExpandGroupsCommand) Reset()

func (*ExpandGroupsCommand) String 

func (m *ExpandGroupsCommand) String() string

func (*ExpandGroupsCommand) XXX_DiscardUnknown 

func (m *ExpandGroupsCommand) XXX_DiscardUnknown()

func (*ExpandGroupsCommand) XXX_Marshal 

func (m *ExpandGroupsCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExpandGroupsCommand) XXX_Merge 

func (m *ExpandGroupsCommand) XXX_Merge(src proto.Message)

func (*ExpandGroupsCommand) XXX_Size 

func (m *ExpandGroupsCommand) XXX_Size() int

func (*ExpandGroupsCommand) XXX_Unmarshal 

func (m *ExpandGroupsCommand) XXX_Unmarshal(b []byte) error

type FieldSchema 

type FieldSchema struct {
	FieldName            *string  `protobuf:"bytes,1,req,name=FieldName" json:"FieldName,omitempty"`
	FieldType            *int32   `protobuf:"varint,2,req,name=FieldType" json:"FieldType,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FieldSchema) Descriptor 

func (*FieldSchema) Descriptor() ([]byte, []int)

func (*FieldSchema) GetFieldName 

func (m *FieldSchema) GetFieldName() string

func (*FieldSchema) GetFieldType 

func (m *FieldSchema) GetFieldType() int32

func (*FieldSchema) ProtoMessage 

func (*FieldSchema) ProtoMessage()

func (*FieldSchema) Reset 

func (m *FieldSchema) Reset()

func (*FieldSchema) String 

func (m *FieldSchema) String() string

func (*FieldSchema) XXX_DiscardUnknown 

func (m *FieldSchema) XXX_DiscardUnknown()

func (*FieldSchema) XXX_Marshal 

func (m *FieldSchema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FieldSchema) XXX_Merge 

func (m *FieldSchema) XXX_Merge(src proto.Message)

func (*FieldSchema) XXX_Size 

func (m *FieldSchema) XXX_Size() int

func (*FieldSchema) XXX_Unmarshal 

func (m *FieldSchema) XXX_Unmarshal(b []byte) error

type GetContinuousQueryLeaseCommand 

type GetContinuousQueryLeaseCommand struct {
	Host                 *string  `protobuf:"bytes,1,req,name=Host" json:"Host,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetContinuousQueryLeaseCommand) Descriptor 

func (*GetContinuousQueryLeaseCommand) Descriptor() ([]byte, []int)

func (*GetContinuousQueryLeaseCommand) GetHost 

func (m *GetContinuousQueryLeaseCommand) GetHost() string

func (*GetContinuousQueryLeaseCommand) ProtoMessage 

func (*GetContinuousQueryLeaseCommand) ProtoMessage()

func (*GetContinuousQueryLeaseCommand) Reset 

func (m *GetContinuousQueryLeaseCommand) Reset()

func (*GetContinuousQueryLeaseCommand) String 

func (m *GetContinuousQueryLeaseCommand) String() string

func (*GetContinuousQueryLeaseCommand) XXX_DiscardUnknown 

func (m *GetContinuousQueryLeaseCommand) XXX_DiscardUnknown()

func (*GetContinuousQueryLeaseCommand) XXX_Marshal 

func (m *GetContinuousQueryLeaseCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetContinuousQueryLeaseCommand) XXX_Merge 

func (m *GetContinuousQueryLeaseCommand) XXX_Merge(src proto.Message)

func (*GetContinuousQueryLeaseCommand) XXX_Size 

func (m *GetContinuousQueryLeaseCommand) XXX_Size() int

func (*GetContinuousQueryLeaseCommand) XXX_Unmarshal 

func (m *GetContinuousQueryLeaseCommand) XXX_Unmarshal(b []byte) error

type GetDownSamplePolicyCommand 

type GetDownSamplePolicyCommand struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetDownSamplePolicyCommand) Descriptor 

func (*GetDownSamplePolicyCommand) Descriptor() ([]byte, []int)

func (*GetDownSamplePolicyCommand) ProtoMessage 

func (*GetDownSamplePolicyCommand) ProtoMessage()

func (*GetDownSamplePolicyCommand) Reset 

func (m *GetDownSamplePolicyCommand) Reset()

func (*GetDownSamplePolicyCommand) String 

func (m *GetDownSamplePolicyCommand) String() string

func (*GetDownSamplePolicyCommand) XXX_DiscardUnknown 

func (m *GetDownSamplePolicyCommand) XXX_DiscardUnknown()

func (*GetDownSamplePolicyCommand) XXX_Marshal 

func (m *GetDownSamplePolicyCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetDownSamplePolicyCommand) XXX_Merge 

func (m *GetDownSamplePolicyCommand) XXX_Merge(src proto.Message)

func (*GetDownSamplePolicyCommand) XXX_Size 

func (m *GetDownSamplePolicyCommand) XXX_Size() int

func (*GetDownSamplePolicyCommand) XXX_Unmarshal 

func (m *GetDownSamplePolicyCommand) XXX_Unmarshal(b []byte) error

type GetMeasurementInfoStoreCommand 

type GetMeasurementInfoStoreCommand struct {
	DbName               *string  `protobuf:"bytes,1,req,name=DbName" json:"DbName,omitempty"`
	RpName               *string  `protobuf:"bytes,2,req,name=RpName" json:"RpName,omitempty"`
	MstName              *string  `protobuf:"bytes,3,req,name=MstName" json:"MstName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetMeasurementInfoStoreCommand) Descriptor 

func (*GetMeasurementInfoStoreCommand) Descriptor() ([]byte, []int)

func (*GetMeasurementInfoStoreCommand) GetDbName 

func (m *GetMeasurementInfoStoreCommand) GetDbName() string

func (*GetMeasurementInfoStoreCommand) GetMstName 

func (m *GetMeasurementInfoStoreCommand) GetMstName() string

func (*GetMeasurementInfoStoreCommand) GetRpName 

func (m *GetMeasurementInfoStoreCommand) GetRpName() string

func (*GetMeasurementInfoStoreCommand) ProtoMessage 

func (*GetMeasurementInfoStoreCommand) ProtoMessage()

func (*GetMeasurementInfoStoreCommand) Reset 

func (m *GetMeasurementInfoStoreCommand) Reset()

func (*GetMeasurementInfoStoreCommand) String 

func (m *GetMeasurementInfoStoreCommand) String() string

func (*GetMeasurementInfoStoreCommand) XXX_DiscardUnknown 

func (m *GetMeasurementInfoStoreCommand) XXX_DiscardUnknown()

func (*GetMeasurementInfoStoreCommand) XXX_Marshal 

func (m *GetMeasurementInfoStoreCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetMeasurementInfoStoreCommand) XXX_Merge 

func (m *GetMeasurementInfoStoreCommand) XXX_Merge(src proto.Message)

func (*GetMeasurementInfoStoreCommand) XXX_Size 

func (m *GetMeasurementInfoStoreCommand) XXX_Size() int

func (*GetMeasurementInfoStoreCommand) XXX_Unmarshal 

func (m *GetMeasurementInfoStoreCommand) XXX_Unmarshal(b []byte) error

type GetMeasurementInfoWithinSameRpCommand 

type GetMeasurementInfoWithinSameRpCommand struct {
	DbName               *string  `protobuf:"bytes,1,req,name=DbName" json:"DbName,omitempty"`
	RpName               *string  `protobuf:"bytes,2,req,name=RpName" json:"RpName,omitempty"`
	DataTypes            []int64  `protobuf:"varint,3,rep,name=DataTypes" json:"DataTypes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetMeasurementInfoWithinSameRpCommand) Descriptor 

func (*GetMeasurementInfoWithinSameRpCommand) Descriptor() ([]byte, []int)

func (*GetMeasurementInfoWithinSameRpCommand) GetDataTypes 

func (m *GetMeasurementInfoWithinSameRpCommand) GetDataTypes() []int64

func (*GetMeasurementInfoWithinSameRpCommand) GetDbName 

func (m *GetMeasurementInfoWithinSameRpCommand) GetDbName() string

func (*GetMeasurementInfoWithinSameRpCommand) GetRpName 

func (m *GetMeasurementInfoWithinSameRpCommand) GetRpName() string

func (*GetMeasurementInfoWithinSameRpCommand) ProtoMessage 

func (*GetMeasurementInfoWithinSameRpCommand) ProtoMessage()

func (*GetMeasurementInfoWithinSameRpCommand) Reset 

func (m *GetMeasurementInfoWithinSameRpCommand) Reset()

func (*GetMeasurementInfoWithinSameRpCommand) String 

func (m *GetMeasurementInfoWithinSameRpCommand) String() string

func (*GetMeasurementInfoWithinSameRpCommand) XXX_DiscardUnknown 

func (m *GetMeasurementInfoWithinSameRpCommand) XXX_DiscardUnknown()

func (*GetMeasurementInfoWithinSameRpCommand) XXX_Marshal 

func (m *GetMeasurementInfoWithinSameRpCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetMeasurementInfoWithinSameRpCommand) XXX_Merge 

func (m *GetMeasurementInfoWithinSameRpCommand) XXX_Merge(src proto.Message)

func (*GetMeasurementInfoWithinSameRpCommand) XXX_Size 

func (m *GetMeasurementInfoWithinSameRpCommand) XXX_Size() int

func (*GetMeasurementInfoWithinSameRpCommand) XXX_Unmarshal 

func (m *GetMeasurementInfoWithinSameRpCommand) XXX_Unmarshal(b []byte) error

type GetMeasurementsInfoCommand 

type GetMeasurementsInfoCommand struct {
	DbName               *string  `protobuf:"bytes,1,req,name=DbName" json:"DbName,omitempty"`
	RpName               *string  `protobuf:"bytes,2,req,name=RpName" json:"RpName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetMeasurementsInfoCommand) Descriptor 

func (*GetMeasurementsInfoCommand) Descriptor() ([]byte, []int)

func (*GetMeasurementsInfoCommand) GetDbName 

func (m *GetMeasurementsInfoCommand) GetDbName() string

func (*GetMeasurementsInfoCommand) GetRpName 

func (m *GetMeasurementsInfoCommand) GetRpName() string

func (*GetMeasurementsInfoCommand) ProtoMessage 

func (*GetMeasurementsInfoCommand) ProtoMessage()

func (*GetMeasurementsInfoCommand) Reset 

func (m *GetMeasurementsInfoCommand) Reset()

func (*GetMeasurementsInfoCommand) String 

func (m *GetMeasurementsInfoCommand) String() string

func (*GetMeasurementsInfoCommand) XXX_DiscardUnknown 

func (m *GetMeasurementsInfoCommand) XXX_DiscardUnknown()

func (*GetMeasurementsInfoCommand) XXX_Marshal 

func (m *GetMeasurementsInfoCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetMeasurementsInfoCommand) XXX_Merge 

func (m *GetMeasurementsInfoCommand) XXX_Merge(src proto.Message)

func (*GetMeasurementsInfoCommand) XXX_Size 

func (m *GetMeasurementsInfoCommand) XXX_Size() int

func (*GetMeasurementsInfoCommand) XXX_Unmarshal 

func (m *GetMeasurementsInfoCommand) XXX_Unmarshal(b []byte) error

type IndexDescriptor 

type IndexDescriptor struct {
	IndexID              *uint64        `protobuf:"varint,1,req,name=IndexID" json:"IndexID,omitempty"`
	IndexGroupID         *uint64        `protobuf:"varint,2,req,name=IndexGroupID" json:"IndexGroupID,omitempty"`
	TimeRange            *TimeRangeInfo `protobuf:"bytes,3,req,name=TimeRange" json:"TimeRange,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*IndexDescriptor) Descriptor 

func (*IndexDescriptor) Descriptor() ([]byte, []int)

func (*IndexDescriptor) GetIndexGroupID 

func (m *IndexDescriptor) GetIndexGroupID() uint64

func (*IndexDescriptor) GetIndexID 

func (m *IndexDescriptor) GetIndexID() uint64

func (*IndexDescriptor) GetTimeRange 

func (m *IndexDescriptor) GetTimeRange() *TimeRangeInfo

func (*IndexDescriptor) ProtoMessage 

func (*IndexDescriptor) ProtoMessage()

func (*IndexDescriptor) Reset 

func (m *IndexDescriptor) Reset()

func (*IndexDescriptor) String 

func (m *IndexDescriptor) String() string

func (*IndexDescriptor) XXX_DiscardUnknown 

func (m *IndexDescriptor) XXX_DiscardUnknown()

func (*IndexDescriptor) XXX_Marshal 

func (m *IndexDescriptor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IndexDescriptor) XXX_Merge 

func (m *IndexDescriptor) XXX_Merge(src proto.Message)

func (*IndexDescriptor) XXX_Size 

func (m *IndexDescriptor) XXX_Size() int

func (*IndexDescriptor) XXX_Unmarshal 

func (m *IndexDescriptor) XXX_Unmarshal(b []byte) error

type IndexGroupInfo 

type IndexGroupInfo struct {
	ID                   *uint64      `protobuf:"varint,1,req,name=ID" json:"ID,omitempty"`
	StartTime            *int64       `protobuf:"varint,2,req,name=StartTime" json:"StartTime,omitempty"`
	EndTime              *int64       `protobuf:"varint,3,req,name=EndTime" json:"EndTime,omitempty"`
	DeletedAt            *int64       `protobuf:"varint,4,req,name=DeletedAt" json:"DeletedAt,omitempty"`
	Indexes              []*IndexInfo `protobuf:"bytes,5,rep,name=Indexes" json:"Indexes,omitempty"`
	EngineType           *uint32      `protobuf:"varint,6,opt,name=EngineType" json:"EngineType,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*IndexGroupInfo) Descriptor 

func (*IndexGroupInfo) Descriptor() ([]byte, []int)

func (*IndexGroupInfo) GetDeletedAt 

func (m *IndexGroupInfo) GetDeletedAt() int64

func (*IndexGroupInfo) GetEndTime 

func (m *IndexGroupInfo) GetEndTime() int64

func (*IndexGroupInfo) GetEngineType 

func (m *IndexGroupInfo) GetEngineType() uint32

func (*IndexGroupInfo) GetID 

func (m *IndexGroupInfo) GetID() uint64

func (*IndexGroupInfo) GetIndexes 

func (m *IndexGroupInfo) GetIndexes() []*IndexInfo

func (*IndexGroupInfo) GetStartTime 

func (m *IndexGroupInfo) GetStartTime() int64

func (*IndexGroupInfo) ProtoMessage 

func (*IndexGroupInfo) ProtoMessage()

func (*IndexGroupInfo) Reset 

func (m *IndexGroupInfo) Reset()

func (*IndexGroupInfo) String 

func (m *IndexGroupInfo) String() string

func (*IndexGroupInfo) XXX_DiscardUnknown 

func (m *IndexGroupInfo) XXX_DiscardUnknown()

func (*IndexGroupInfo) XXX_Marshal 

func (m *IndexGroupInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IndexGroupInfo) XXX_Merge 

func (m *IndexGroupInfo) XXX_Merge(src proto.Message)

func (*IndexGroupInfo) XXX_Size 

func (m *IndexGroupInfo) XXX_Size() int

func (*IndexGroupInfo) XXX_Unmarshal 

func (m *IndexGroupInfo) XXX_Unmarshal(b []byte) error

type IndexInfo 

type IndexInfo struct {
	ID                   *uint64  `protobuf:"varint,1,req,name=ID" json:"ID,omitempty"`
	OwnerIDs             []uint32 `protobuf:"varint,2,rep,name=OwnerIDs" json:"OwnerIDs,omitempty"`
	MarkDelete           *bool    `protobuf:"varint,3,opt,name=MarkDelete" json:"MarkDelete,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IndexInfo) Descriptor 

func (*IndexInfo) Descriptor() ([]byte, []int)

func (*IndexInfo) GetID 

func (m *IndexInfo) GetID() uint64

func (*IndexInfo) GetMarkDelete 

func (m *IndexInfo) GetMarkDelete() bool

func (*IndexInfo) GetOwnerIDs 

func (m *IndexInfo) GetOwnerIDs() []uint32

func (*IndexInfo) ProtoMessage 

func (*IndexInfo) ProtoMessage()

func (*IndexInfo) Reset 

func (m *IndexInfo) Reset()

func (*IndexInfo) String 

func (m *IndexInfo) String() string

func (*IndexInfo) XXX_DiscardUnknown 

func (m *IndexInfo) XXX_DiscardUnknown()

func (*IndexInfo) XXX_Marshal 

func (m *IndexInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IndexInfo) XXX_Merge 

func (m *IndexInfo) XXX_Merge(src proto.Message)

func (*IndexInfo) XXX_Size 

func (m *IndexInfo) XXX_Size() int

func (*IndexInfo) XXX_Unmarshal 

func (m *IndexInfo) XXX_Unmarshal(b []byte) error

type IndexList 

type IndexList struct {
	IList                []string `protobuf:"bytes,1,rep,name=IList" json:"IList,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IndexList) Descriptor 

func (*IndexList) Descriptor() ([]byte, []int)

func (*IndexList) GetIList 

func (m *IndexList) GetIList() []string

func (*IndexList) ProtoMessage 

func (*IndexList) ProtoMessage()

func (*IndexList) Reset 

func (m *IndexList) Reset()

func (*IndexList) String 

func (m *IndexList) String() string

func (*IndexList) XXX_DiscardUnknown 

func (m *IndexList) XXX_DiscardUnknown()

func (*IndexList) XXX_Marshal 

func (m *IndexList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IndexList) XXX_Merge 

func (m *IndexList) XXX_Merge(src proto.Message)

func (*IndexList) XXX_Size 

func (m *IndexList) XXX_Size() int

func (*IndexList) XXX_Unmarshal 

func (m *IndexList) XXX_Unmarshal(b []byte) error

type IndexOption 

type IndexOption struct {
	Tokens               *string  `protobuf:"bytes,1,opt,name=Tokens" json:"Tokens,omitempty"`
	Tokenizers           *string  `protobuf:"bytes,2,opt,name=Tokenizers" json:"Tokenizers,omitempty"`
	TimeClusterDuration  *int64   `protobuf:"varint,3,opt,name=TimeClusterDuration" json:"TimeClusterDuration,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IndexOption) Descriptor 

func (*IndexOption) Descriptor() ([]byte, []int)

func (*IndexOption) GetTimeClusterDuration 

func (m *IndexOption) GetTimeClusterDuration() int64

func (*IndexOption) GetTokenizers 

func (m *IndexOption) GetTokenizers() string

func (*IndexOption) GetTokens 

func (m *IndexOption) GetTokens() string

func (*IndexOption) ProtoMessage 

func (*IndexOption) ProtoMessage()

func (*IndexOption) Reset 

func (m *IndexOption) Reset()

func (*IndexOption) String 

func (m *IndexOption) String() string

func (*IndexOption) XXX_DiscardUnknown 

func (m *IndexOption) XXX_DiscardUnknown()

func (*IndexOption) XXX_Marshal 

func (m *IndexOption) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IndexOption) XXX_Merge 

func (m *IndexOption) XXX_Merge(src proto.Message)

func (*IndexOption) XXX_Size 

func (m *IndexOption) XXX_Size() int

func (*IndexOption) XXX_Unmarshal 

func (m *IndexOption) XXX_Unmarshal(b []byte) error

type IndexOptions 

type IndexOptions struct {
	Infos                []*IndexOption `protobuf:"bytes,1,rep,name=Infos" json:"Infos,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*IndexOptions) Descriptor 

func (*IndexOptions) Descriptor() ([]byte, []int)

func (*IndexOptions) GetInfos 

func (m *IndexOptions) GetInfos() []*IndexOption

func (*IndexOptions) ProtoMessage 

func (*IndexOptions) ProtoMessage()

func (*IndexOptions) Reset 

func (m *IndexOptions) Reset()

func (*IndexOptions) String 

func (m *IndexOptions) String() string

func (*IndexOptions) XXX_DiscardUnknown 

func (m *IndexOptions) XXX_DiscardUnknown()

func (*IndexOptions) XXX_Marshal 

func (m *IndexOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IndexOptions) XXX_Merge 

func (m *IndexOptions) XXX_Merge(src proto.Message)

func (*IndexOptions) XXX_Size 

func (m *IndexOptions) XXX_Size() int

func (*IndexOptions) XXX_Unmarshal 

func (m *IndexOptions) XXX_Unmarshal(b []byte) error

type IndexRelation 

type IndexRelation struct {
	Rid                  *uint32         `protobuf:"varint,1,req,name=Rid" json:"Rid,omitempty"`
	Oid                  []uint32        `protobuf:"varint,2,rep,name=Oid" json:"Oid,omitempty"`
	IndexName            []string        `protobuf:"bytes,3,rep,name=IndexName" json:"IndexName,omitempty"`
	IndexLists           []*IndexList    `protobuf:"bytes,4,rep,name=IndexLists" json:"IndexLists,omitempty"`
	IndexOptions         []*IndexOptions `protobuf:"bytes,5,rep,name=IndexOptions" json:"IndexOptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*IndexRelation) Descriptor 

func (*IndexRelation) Descriptor() ([]byte, []int)

func (*IndexRelation) GetIndexLists 

func (m *IndexRelation) GetIndexLists() []*IndexList

func (*IndexRelation) GetIndexName 

func (m *IndexRelation) GetIndexName() []string

func (*IndexRelation) GetIndexOptions 

func (m *IndexRelation) GetIndexOptions() []*IndexOptions

func (*IndexRelation) GetOid 

func (m *IndexRelation) GetOid() []uint32

func (*IndexRelation) GetRid 

func (m *IndexRelation) GetRid() uint32

func (*IndexRelation) ProtoMessage 

func (*IndexRelation) ProtoMessage()

func (*IndexRelation) Reset 

func (m *IndexRelation) Reset()

func (*IndexRelation) String 

func (m *IndexRelation) String() string

func (*IndexRelation) XXX_DiscardUnknown 

func (m *IndexRelation) XXX_DiscardUnknown()

func (*IndexRelation) XXX_Marshal 

func (m *IndexRelation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IndexRelation) XXX_Merge 

func (m *IndexRelation) XXX_Merge(src proto.Message)

func (*IndexRelation) XXX_Size 

func (m *IndexRelation) XXX_Size() int

func (*IndexRelation) XXX_Unmarshal 

func (m *IndexRelation) XXX_Unmarshal(b []byte) error

type MarkBalancerCommand 

type MarkBalancerCommand struct {
	Enable               *bool    `protobuf:"varint,1,req,name=enable" json:"enable,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MarkBalancerCommand) Descriptor 

func (*MarkBalancerCommand) Descriptor() ([]byte, []int)

func (*MarkBalancerCommand) GetEnable 

func (m *MarkBalancerCommand) GetEnable() bool

func (*MarkBalancerCommand) ProtoMessage 

func (*MarkBalancerCommand) ProtoMessage()

func (*MarkBalancerCommand) Reset 

func (m *MarkBalancerCommand) Reset()

func (*MarkBalancerCommand) String 

func (m *MarkBalancerCommand) String() string

func (*MarkBalancerCommand) XXX_DiscardUnknown 

func (m *MarkBalancerCommand) XXX_DiscardUnknown()

func (*MarkBalancerCommand) XXX_Marshal 

func (m *MarkBalancerCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MarkBalancerCommand) XXX_Merge 

func (m *MarkBalancerCommand) XXX_Merge(src proto.Message)

func (*MarkBalancerCommand) XXX_Size 

func (m *MarkBalancerCommand) XXX_Size() int

func (*MarkBalancerCommand) XXX_Unmarshal 

func (m *MarkBalancerCommand) XXX_Unmarshal(b []byte) error

type MarkDatabaseDeleteCommand 

type MarkDatabaseDeleteCommand struct {
	Name                 *string  `protobuf:"bytes,1,req,name=Name" json:"Name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MarkDatabaseDeleteCommand) Descriptor 

func (*MarkDatabaseDeleteCommand) Descriptor() ([]byte, []int)

func (*MarkDatabaseDeleteCommand) GetName 

func (m *MarkDatabaseDeleteCommand) GetName() string

func (*MarkDatabaseDeleteCommand) ProtoMessage 

func (*MarkDatabaseDeleteCommand) ProtoMessage()

func (*MarkDatabaseDeleteCommand) Reset 

func (m *MarkDatabaseDeleteCommand) Reset()

func (*MarkDatabaseDeleteCommand) String 

func (m *MarkDatabaseDeleteCommand) String() string

func (*MarkDatabaseDeleteCommand) XXX_DiscardUnknown 

func (m *MarkDatabaseDeleteCommand) XXX_DiscardUnknown()

func (*MarkDatabaseDeleteCommand) XXX_Marshal 

func (m *MarkDatabaseDeleteCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MarkDatabaseDeleteCommand) XXX_Merge 

func (m *MarkDatabaseDeleteCommand) XXX_Merge(src proto.Message)

func (*MarkDatabaseDeleteCommand) XXX_Size 

func (m *MarkDatabaseDeleteCommand) XXX_Size() int

func (*MarkDatabaseDeleteCommand) XXX_Unmarshal 

func (m *MarkDatabaseDeleteCommand) XXX_Unmarshal(b []byte) error

type MarkMeasurementDeleteCommand 

type MarkMeasurementDeleteCommand struct {
	Database             *string  `protobuf:"bytes,1,req,name=Database" json:"Database,omitempty"`
	Policy               *string  `protobuf:"bytes,2,req,name=Policy" json:"Policy,omitempty"`
	Measurement          *string  `protobuf:"bytes,3,req,name=Measurement" json:"Measurement,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MarkMeasurementDeleteCommand) Descriptor 

func (*MarkMeasurementDeleteCommand) Descriptor() ([]byte, []int)

func (*MarkMeasurementDeleteCommand) GetDatabase 

func (m *MarkMeasurementDeleteCommand) GetDatabase() string

func (*MarkMeasurementDeleteCommand) GetMeasurement 

func (m *MarkMeasurementDeleteCommand) GetMeasurement() string

func (*MarkMeasurementDeleteCommand) GetPolicy 

func (m *MarkMeasurementDeleteCommand) GetPolicy() string

func (*MarkMeasurementDeleteCommand) ProtoMessage 

func (*MarkMeasurementDeleteCommand) ProtoMessage()

func (*MarkMeasurementDeleteCommand) Reset 

func (m *MarkMeasurementDeleteCommand) Reset()

func (*MarkMeasurementDeleteCommand) String 

func (m *MarkMeasurementDeleteCommand) String() string

func (*MarkMeasurementDeleteCommand) XXX_DiscardUnknown 

func (m *MarkMeasurementDeleteCommand) XXX_DiscardUnknown()

func (*MarkMeasurementDeleteCommand) XXX_Marshal 

func (m *MarkMeasurementDeleteCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MarkMeasurementDeleteCommand) XXX_Merge 

func (m *MarkMeasurementDeleteCommand) XXX_Merge(src proto.Message)

func (*MarkMeasurementDeleteCommand) XXX_Size 

func (m *MarkMeasurementDeleteCommand) XXX_Size() int

func (*MarkMeasurementDeleteCommand) XXX_Unmarshal 

func (m *MarkMeasurementDeleteCommand) XXX_Unmarshal(b []byte) error

type MarkRetentionPolicyDeleteCommand 

type MarkRetentionPolicyDeleteCommand struct {
	Database             *string  `protobuf:"bytes,1,req,name=Database" json:"Database,omitempty"`
	Name                 *string  `protobuf:"bytes,2,req,name=Name" json:"Name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MarkRetentionPolicyDeleteCommand) Descriptor 

func (*MarkRetentionPolicyDeleteCommand) Descriptor() ([]byte, []int)

func (*MarkRetentionPolicyDeleteCommand) GetDatabase 

func (m *MarkRetentionPolicyDeleteCommand) GetDatabase() string

func (*MarkRetentionPolicyDeleteCommand) GetName 

func (m *MarkRetentionPolicyDeleteCommand) GetName() string

func (*MarkRetentionPolicyDeleteCommand) ProtoMessage 

func (*MarkRetentionPolicyDeleteCommand) ProtoMessage()

func (*MarkRetentionPolicyDeleteCommand) Reset 

func (m *MarkRetentionPolicyDeleteCommand) Reset()

func (*MarkRetentionPolicyDeleteCommand) String 

func (m *MarkRetentionPolicyDeleteCommand) String() string

func (*MarkRetentionPolicyDeleteCommand) XXX_DiscardUnknown 

func (m *MarkRetentionPolicyDeleteCommand) XXX_DiscardUnknown()

func (*MarkRetentionPolicyDeleteCommand) XXX_Marshal 

func (m *MarkRetentionPolicyDeleteCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MarkRetentionPolicyDeleteCommand) XXX_Merge 

func (m *MarkRetentionPolicyDeleteCommand) XXX_Merge(src proto.Message)

func (*MarkRetentionPolicyDeleteCommand) XXX_Size 

func (m *MarkRetentionPolicyDeleteCommand) XXX_Size() int

func (*MarkRetentionPolicyDeleteCommand) XXX_Unmarshal 

func (m *MarkRetentionPolicyDeleteCommand) XXX_Unmarshal(b []byte) error

type MarkTakeoverCommand 

type MarkTakeoverCommand struct {
	Enable               *bool    `protobuf:"varint,1,req,name=enable" json:"enable,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MarkTakeoverCommand) Descriptor 

func (*MarkTakeoverCommand) Descriptor() ([]byte, []int)

func (*MarkTakeoverCommand) GetEnable 

func (m *MarkTakeoverCommand) GetEnable() bool

func (*MarkTakeoverCommand) ProtoMessage 

func (*MarkTakeoverCommand) ProtoMessage()

func (*MarkTakeoverCommand) Reset 

func (m *MarkTakeoverCommand) Reset()

func (*MarkTakeoverCommand) String 

func (m *MarkTakeoverCommand) String() string

func (*MarkTakeoverCommand) XXX_DiscardUnknown 

func (m *MarkTakeoverCommand) XXX_DiscardUnknown()

func (*MarkTakeoverCommand) XXX_Marshal 

func (m *MarkTakeoverCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MarkTakeoverCommand) XXX_Merge 

func (m *MarkTakeoverCommand) XXX_Merge(src proto.Message)

func (*MarkTakeoverCommand) XXX_Size 

func (m *MarkTakeoverCommand) XXX_Size() int

func (*MarkTakeoverCommand) XXX_Unmarshal 

func (m *MarkTakeoverCommand) XXX_Unmarshal(b []byte) error

type MeasurementCardinalityInfo 

type MeasurementCardinalityInfo struct {
	Name                 *string            `protobuf:"bytes,1,req,name=Name" json:"Name,omitempty"`
	Cardinality          []*CardinalityInfo `protobuf:"bytes,2,rep,name=Cardinality" json:"Cardinality,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*MeasurementCardinalityInfo) Descriptor 

func (*MeasurementCardinalityInfo) Descriptor() ([]byte, []int)

func (*MeasurementCardinalityInfo) GetCardinality 

func (m *MeasurementCardinalityInfo) GetCardinality() []*CardinalityInfo

func (*MeasurementCardinalityInfo) GetName 

func (m *MeasurementCardinalityInfo) GetName() string

func (*MeasurementCardinalityInfo) ProtoMessage 

func (*MeasurementCardinalityInfo) ProtoMessage()

func (*MeasurementCardinalityInfo) Reset 

func (m *MeasurementCardinalityInfo) Reset()

func (*MeasurementCardinalityInfo) String 

func (m *MeasurementCardinalityInfo) String() string

func (*MeasurementCardinalityInfo) XXX_DiscardUnknown 

func (m *MeasurementCardinalityInfo) XXX_DiscardUnknown()

func (*MeasurementCardinalityInfo) XXX_Marshal 

func (m *MeasurementCardinalityInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MeasurementCardinalityInfo) XXX_Merge 

func (m *MeasurementCardinalityInfo) XXX_Merge(src proto.Message)

func (*MeasurementCardinalityInfo) XXX_Size 

func (m *MeasurementCardinalityInfo) XXX_Size() int

func (*MeasurementCardinalityInfo) XXX_Unmarshal 

func (m *MeasurementCardinalityInfo) XXX_Unmarshal(b []byte) error

type MeasurementFieldsInfo 

type MeasurementFieldsInfo struct {
	MstName              *string                  `protobuf:"bytes,1,req,name=MstName" json:"MstName,omitempty"`
	TypeFields           []*MeasurementTypeFields `protobuf:"bytes,2,rep,name=TypeFields" json:"TypeFields,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*MeasurementFieldsInfo) Descriptor 

func (*MeasurementFieldsInfo) Descriptor() ([]byte, []int)

func (*MeasurementFieldsInfo) GetMstName 

func (m *MeasurementFieldsInfo) GetMstName() string

func (*MeasurementFieldsInfo) GetTypeFields 

func (m *MeasurementFieldsInfo) GetTypeFields() []*MeasurementTypeFields

func (*MeasurementFieldsInfo) ProtoMessage 

func (*MeasurementFieldsInfo) ProtoMessage()

func (*MeasurementFieldsInfo) Reset 

func (m *MeasurementFieldsInfo) Reset()

func (*MeasurementFieldsInfo) String 

func (m *MeasurementFieldsInfo) String() string

func (*MeasurementFieldsInfo) XXX_DiscardUnknown 

func (m *MeasurementFieldsInfo) XXX_DiscardUnknown()

func (*MeasurementFieldsInfo) XXX_Marshal 

func (m *MeasurementFieldsInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MeasurementFieldsInfo) XXX_Merge 

func (m *MeasurementFieldsInfo) XXX_Merge(src proto.Message)

func (*MeasurementFieldsInfo) XXX_Size 

func (m *MeasurementFieldsInfo) XXX_Size() int

func (*MeasurementFieldsInfo) XXX_Unmarshal 

func (m *MeasurementFieldsInfo) XXX_Unmarshal(b []byte) error

type MeasurementInfo 

type MeasurementInfo struct {
	Name                 *string          `protobuf:"bytes,1,req,name=Name" json:"Name,omitempty"`
	ShardKeys            []*ShardKeyInfo  `protobuf:"bytes,2,rep,name=ShardKeys" json:"ShardKeys,omitempty"`
	Schema               map[string]int32 `` /* 133-byte string literal not displayed */
	MarkDeleted          *bool            `protobuf:"varint,4,opt,name=MarkDeleted" json:"MarkDeleted,omitempty"`
	IndexRelation        *IndexRelation   `protobuf:"bytes,5,opt,name=indexRelation" json:"indexRelation,omitempty"`
	EngineType           *uint32          `protobuf:"varint,6,opt,name=EngineType" json:"EngineType,omitempty"`
	ColStoreInfo         *ColStoreInfo    `protobuf:"bytes,7,opt,name=ColStoreInfo" json:"ColStoreInfo,omitempty"`
	ObsOptions           *ObsOptions      `protobuf:"bytes,8,opt,name=ObsOptions" json:"ObsOptions,omitempty"`
	Options              *Options         `protobuf:"bytes,21,opt,name=Options" json:"Options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*MeasurementInfo) Descriptor 

func (*MeasurementInfo) Descriptor() ([]byte, []int)

func (*MeasurementInfo) GetColStoreInfo 

func (m *MeasurementInfo) GetColStoreInfo() *ColStoreInfo

func (*MeasurementInfo) GetEngineType 

func (m *MeasurementInfo) GetEngineType() uint32

func (*MeasurementInfo) GetIndexRelation 

func (m *MeasurementInfo) GetIndexRelation() *IndexRelation

func (*MeasurementInfo) GetMarkDeleted 

func (m *MeasurementInfo) GetMarkDeleted() bool

func (*MeasurementInfo) GetName 

func (m *MeasurementInfo) GetName() string

func (*MeasurementInfo) GetObsOptions 

func (m *MeasurementInfo) GetObsOptions() *ObsOptions

func (*MeasurementInfo) GetOptions 

func (m *MeasurementInfo) GetOptions() *Options

func (*MeasurementInfo) GetSchema 

func (m *MeasurementInfo) GetSchema() map[string]int32

func (*MeasurementInfo) GetShardKeys 

func (m *MeasurementInfo) GetShardKeys() []*ShardKeyInfo

func (*MeasurementInfo) ProtoMessage 

func (*MeasurementInfo) ProtoMessage()

func (*MeasurementInfo) Reset 

func (m *MeasurementInfo) Reset()

func (*MeasurementInfo) String 

func (m *MeasurementInfo) String() string

func (*MeasurementInfo) XXX_DiscardUnknown 

func (m *MeasurementInfo) XXX_DiscardUnknown()

func (*MeasurementInfo) XXX_Marshal 

func (m *MeasurementInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MeasurementInfo) XXX_Merge 

func (m *MeasurementInfo) XXX_Merge(src proto.Message)

func (*MeasurementInfo) XXX_Size 

func (m *MeasurementInfo) XXX_Size() int

func (*MeasurementInfo) XXX_Unmarshal 

func (m *MeasurementInfo) XXX_Unmarshal(b []byte) error

type MeasurementTypeFields 

type MeasurementTypeFields struct {
	Fields               []string `protobuf:"bytes,1,rep,name=Fields" json:"Fields,omitempty"`
	Type                 *int64   `protobuf:"varint,2,req,name=Type" json:"Type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MeasurementTypeFields) Descriptor 

func (*MeasurementTypeFields) Descriptor() ([]byte, []int)

func (*MeasurementTypeFields) GetFields 

func (m *MeasurementTypeFields) GetFields() []string

func (*MeasurementTypeFields) GetType 

func (m *MeasurementTypeFields) GetType() int64

func (*MeasurementTypeFields) ProtoMessage 

func (*MeasurementTypeFields) ProtoMessage()

func (*MeasurementTypeFields) Reset 

func (m *MeasurementTypeFields) Reset()

func (*MeasurementTypeFields) String 

func (m *MeasurementTypeFields) String() string

func (*MeasurementTypeFields) XXX_DiscardUnknown 

func (m *MeasurementTypeFields) XXX_DiscardUnknown()

func (*MeasurementTypeFields) XXX_Marshal 

func (m *MeasurementTypeFields) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MeasurementTypeFields) XXX_Merge 

func (m *MeasurementTypeFields) XXX_Merge(src proto.Message)

func (*MeasurementTypeFields) XXX_Size 

func (m *MeasurementTypeFields) XXX_Size() int

func (*MeasurementTypeFields) XXX_Unmarshal 

func (m *MeasurementTypeFields) XXX_Unmarshal(b []byte) error

type MeasurementsInfo 

type MeasurementsInfo struct {
	MeasurementsInfo     []*MeasurementInfo `protobuf:"bytes,1,rep,name=MeasurementsInfo" json:"MeasurementsInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*MeasurementsInfo) Descriptor 

func (*MeasurementsInfo) Descriptor() ([]byte, []int)

func (*MeasurementsInfo) GetMeasurementsInfo 

func (m *MeasurementsInfo) GetMeasurementsInfo() []*MeasurementInfo

func (*MeasurementsInfo) ProtoMessage 

func (*MeasurementsInfo) ProtoMessage()

func (*MeasurementsInfo) Reset 

func (m *MeasurementsInfo) Reset()

func (*MeasurementsInfo) String 

func (m *MeasurementsInfo) String() string

func (*MeasurementsInfo) XXX_DiscardUnknown 

func (m *MeasurementsInfo) XXX_DiscardUnknown()

func (*MeasurementsInfo) XXX_Marshal 

func (m *MeasurementsInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MeasurementsInfo) XXX_Merge 

func (m *MeasurementsInfo) XXX_Merge(src proto.Message)

func (*MeasurementsInfo) XXX_Size 

func (m *MeasurementsInfo) XXX_Size() int

func (*MeasurementsInfo) XXX_Unmarshal 

func (m *MeasurementsInfo) XXX_Unmarshal(b []byte) error

type MigrateEventInfo 

type MigrateEventInfo struct {
	EventId              *string  `protobuf:"bytes,1,opt,name=eventId" json:"eventId,omitempty"`
	EventType            *int32   `protobuf:"varint,2,opt,name=eventType" json:"eventType,omitempty"`
	OpId                 *uint64  `protobuf:"varint,3,opt,name=opId" json:"opId,omitempty"`
	Pti                  *DbPt    `protobuf:"bytes,4,opt,name=pti" json:"pti,omitempty"`
	CurrState            *int32   `protobuf:"varint,5,opt,name=currState" json:"currState,omitempty"`
	PreState             *int32   `protobuf:"varint,6,opt,name=preState" json:"preState,omitempty"`
	Src                  *uint64  `protobuf:"varint,7,opt,name=src" json:"src,omitempty"`
	Dest                 *uint64  `protobuf:"varint,8,opt,name=dest" json:"dest,omitempty"`
	CheckConflict        *bool    `protobuf:"varint,9,opt,name=checkConflict" json:"checkConflict,omitempty"`
	AliveConnId          *uint64  `protobuf:"varint,10,opt,name=aliveConnId" json:"aliveConnId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MigrateEventInfo) Descriptor 

func (*MigrateEventInfo) Descriptor() ([]byte, []int)

func (*MigrateEventInfo) GetAliveConnId 

func (m *MigrateEventInfo) GetAliveConnId() uint64

func (*MigrateEventInfo) GetCheckConflict 

func (m *MigrateEventInfo) GetCheckConflict() bool

func (*MigrateEventInfo) GetCurrState 

func (m *MigrateEventInfo) GetCurrState() int32

func (*MigrateEventInfo) GetDest 

func (m *MigrateEventInfo) GetDest() uint64

func (*MigrateEventInfo) GetEventId 

func (m *MigrateEventInfo) GetEventId() string

func (*MigrateEventInfo) GetEventType 

func (m *MigrateEventInfo) GetEventType() int32

func (*MigrateEventInfo) GetOpId 

func (m *MigrateEventInfo) GetOpId() uint64

func (*MigrateEventInfo) GetPreState 

func (m *MigrateEventInfo) GetPreState() int32

func (*MigrateEventInfo) GetPti 

func (m *MigrateEventInfo) GetPti() *DbPt

func (*MigrateEventInfo) GetSrc 

func (m *MigrateEventInfo) GetSrc() uint64

func (*MigrateEventInfo) ProtoMessage 

func (*MigrateEventInfo) ProtoMessage()

func (*MigrateEventInfo) Reset 

func (m *MigrateEventInfo) Reset()

func (*MigrateEventInfo) String 

func (m *MigrateEventInfo) String() string

func (*MigrateEventInfo) XXX_DiscardUnknown 

func (m *MigrateEventInfo) XXX_DiscardUnknown()

func (*MigrateEventInfo) XXX_Marshal 

func (m *MigrateEventInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MigrateEventInfo) XXX_Merge 

func (m *MigrateEventInfo) XXX_Merge(src proto.Message)

func (*MigrateEventInfo) XXX_Size 

func (m *MigrateEventInfo) XXX_Size() int

func (*MigrateEventInfo) XXX_Unmarshal 

func (m *MigrateEventInfo) XXX_Unmarshal(b []byte) error

type NodeInfo 

type NodeInfo struct {
	ID                   *uint64  `protobuf:"varint,1,req,name=ID" json:"ID,omitempty"`
	Host                 *string  `protobuf:"bytes,2,req,name=Host" json:"Host,omitempty"`
	RPCAddr              *string  `protobuf:"bytes,5,opt,name=RPCAddr" json:"RPCAddr,omitempty"`
	TCPHost              *string  `protobuf:"bytes,3,opt,name=TCPHost" json:"TCPHost,omitempty"`
	Status               *int64   `protobuf:"varint,4,req,name=Status" json:"Status,omitempty"`
	LTime                *uint64  `protobuf:"varint,6,req,name=LTime" json:"LTime,omitempty"`
	GossipAddr           *string  `protobuf:"bytes,7,req,name=GossipAddr" json:"GossipAddr,omitempty"`
	SegregateStatus      *uint64  `protobuf:"varint,8,opt,name=SegregateStatus" json:"SegregateStatus,omitempty"`
	Role                 *string  `protobuf:"bytes,10,opt,name=Role" json:"Role,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeInfo) Descriptor 

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

func (*NodeInfo) GetGossipAddr 

func (m *NodeInfo) GetGossipAddr() string

func (*NodeInfo) GetHost 

func (m *NodeInfo) GetHost() string

func (*NodeInfo) GetID 

func (m *NodeInfo) GetID() uint64

func (*NodeInfo) GetLTime 

func (m *NodeInfo) GetLTime() uint64

func (*NodeInfo) GetRPCAddr 

func (m *NodeInfo) GetRPCAddr() string

func (*NodeInfo) GetRole 

func (m *NodeInfo) GetRole() string

func (*NodeInfo) GetSegregateStatus 

func (m *NodeInfo) GetSegregateStatus() uint64

func (*NodeInfo) GetStatus 

func (m *NodeInfo) GetStatus() int64

func (*NodeInfo) GetTCPHost 

func (m *NodeInfo) GetTCPHost() string

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) Reset 

func (m *NodeInfo) Reset()

func (*NodeInfo) String 

func (m *NodeInfo) String() string

func (*NodeInfo) XXX_DiscardUnknown 

func (m *NodeInfo) XXX_DiscardUnknown()

func (*NodeInfo) XXX_Marshal 

func (m *NodeInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeInfo) XXX_Merge 

func (m *NodeInfo) XXX_Merge(src proto.Message)

func (*NodeInfo) XXX_Size 

func (m *NodeInfo) XXX_Size() int

func (*NodeInfo) XXX_Unmarshal 

func (m *NodeInfo) XXX_Unmarshal(b []byte) error

type NodeStartInfo 

type NodeStartInfo struct {
	DataIndex            *uint64              `protobuf:"varint,1,req,name=DataIndex" json:"DataIndex,omitempty"`
	NodeID               *uint64              `protobuf:"varint,2,req,name=NodeID" json:"NodeID,omitempty"`
	PtIds                []uint32             `protobuf:"varint,3,rep,name=PtIds" json:"PtIds,omitempty"`
	Durations            []*ShardDurationInfo `protobuf:"bytes,4,rep,name=Durations" json:"Durations,omitempty"`
	LTime                *uint64              `protobuf:"varint,5,req,name=LTime" json:"LTime,omitempty"`
	DBBriefInfo          []*DatabaseBriefInfo `protobuf:"bytes,6,rep,name=DBBriefInfo" json:"DBBriefInfo,omitempty"`
	ConnId               *uint64              `protobuf:"varint,7,opt,name=connId" json:"connId,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*NodeStartInfo) Descriptor 

func (*NodeStartInfo) Descriptor() ([]byte, []int)

func (*NodeStartInfo) GetConnId 

func (m *NodeStartInfo) GetConnId() uint64

func (*NodeStartInfo) GetDBBriefInfo 

func (m *NodeStartInfo) GetDBBriefInfo() []*DatabaseBriefInfo

func (*NodeStartInfo) GetDataIndex 

func (m *NodeStartInfo) GetDataIndex() uint64

func (*NodeStartInfo) GetDurations 

func (m *NodeStartInfo) GetDurations() []*ShardDurationInfo

func (*NodeStartInfo) GetLTime 

func (m *NodeStartInfo) GetLTime() uint64

func (*NodeStartInfo) GetNodeID 

func (m *NodeStartInfo) GetNodeID() uint64

func (*NodeStartInfo) GetPtIds 

func (m *NodeStartInfo) GetPtIds() []uint32

func (*NodeStartInfo) ProtoMessage 

func (*NodeStartInfo) ProtoMessage()

func (*NodeStartInfo) Reset 

func (m *NodeStartInfo) Reset()

func (*NodeStartInfo) String 

func (m *NodeStartInfo) String() string

func (*NodeStartInfo) XXX_DiscardUnknown 

func (m *NodeStartInfo) XXX_DiscardUnknown()

func (*NodeStartInfo) XXX_Marshal 

func (m *NodeStartInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeStartInfo) XXX_Merge 

func (m *NodeStartInfo) XXX_Merge(src proto.Message)

func (*NodeStartInfo) XXX_Size 

func (m *NodeStartInfo) XXX_Size() int

func (*NodeStartInfo) XXX_Unmarshal 

func (m *NodeStartInfo) XXX_Unmarshal(b []byte) error

type NotifyCQLeaseChangedCommand 

type NotifyCQLeaseChangedCommand struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NotifyCQLeaseChangedCommand) Descriptor 

func (*NotifyCQLeaseChangedCommand) Descriptor() ([]byte, []int)

func (*NotifyCQLeaseChangedCommand) ProtoMessage 

func (*NotifyCQLeaseChangedCommand) ProtoMessage()

func (*NotifyCQLeaseChangedCommand) Reset 

func (m *NotifyCQLeaseChangedCommand) Reset()

func (*NotifyCQLeaseChangedCommand) String 

func (m *NotifyCQLeaseChangedCommand) String() string

func (*NotifyCQLeaseChangedCommand) XXX_DiscardUnknown 

func (m *NotifyCQLeaseChangedCommand) XXX_DiscardUnknown()

func (*NotifyCQLeaseChangedCommand) XXX_Marshal 

func (m *NotifyCQLeaseChangedCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NotifyCQLeaseChangedCommand) XXX_Merge 

func (m *NotifyCQLeaseChangedCommand) XXX_Merge(src proto.Message)

func (*NotifyCQLeaseChangedCommand) XXX_Size 

func (m *NotifyCQLeaseChangedCommand) XXX_Size() int

func (*NotifyCQLeaseChangedCommand) XXX_Unmarshal 

func (m *NotifyCQLeaseChangedCommand) XXX_Unmarshal(b []byte) error

type ObsOptions 

type ObsOptions struct {
	Enabled              *bool    `protobuf:"varint,1,opt,name=Enabled" json:"Enabled,omitempty"`
	BucketName           *string  `protobuf:"bytes,2,opt,name=BucketName" json:"BucketName,omitempty"`
	Ak                   *string  `protobuf:"bytes,3,opt,name=Ak" json:"Ak,omitempty"`
	Sk                   *string  `protobuf:"bytes,4,opt,name=Sk" json:"Sk,omitempty"`
	Endpoint             *string  `protobuf:"bytes,5,opt,name=Endpoint" json:"Endpoint,omitempty"`
	BasePath             *string  `protobuf:"bytes,6,opt,name=BasePath" json:"BasePath,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ObsOptions) Descriptor 

func (*ObsOptions) Descriptor() ([]byte, []int)

func (*ObsOptions) GetAk 

func (m *ObsOptions) GetAk() string

func (*ObsOptions) GetBasePath 

func (m *ObsOptions) GetBasePath() string

func (*ObsOptions) GetBucketName 

func (m *ObsOptions) GetBucketName() string

func (*ObsOptions) GetEnabled 

func (m *ObsOptions) GetEnabled() bool

func (*ObsOptions) GetEndpoint 

func (m *ObsOptions) GetEndpoint() string

func (*ObsOptions) GetSk 

func (m *ObsOptions) GetSk() string

func (*ObsOptions) ProtoMessage 

func (*ObsOptions) ProtoMessage()

func (*ObsOptions) Reset 

func (m *ObsOptions) Reset()

func (*ObsOptions) String 

func (m *ObsOptions) String() string

func (*ObsOptions) XXX_DiscardUnknown 

func (m *ObsOptions) XXX_DiscardUnknown()

func (*ObsOptions) XXX_Marshal 

func (m *ObsOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ObsOptions) XXX_Merge 

func (m *ObsOptions) XXX_Merge(src proto.Message)

func (*ObsOptions) XXX_Size 

func (m *ObsOptions) XXX_Size() int

func (*ObsOptions) XXX_Unmarshal 

func (m *ObsOptions) XXX_Unmarshal(b []byte) error

type Options 

type Options struct {
	CaseInSensitive      *bool    `protobuf:"varint,1,opt,name=CaseInSensitive" json:"CaseInSensitive,omitempty"`
	AppendMeta           *bool    `protobuf:"varint,2,opt,name=AppendMeta" json:"AppendMeta,omitempty"`
	WriteThreshold       *int32   `protobuf:"varint,3,opt,name=WriteThreshold" json:"WriteThreshold,omitempty"`
	ReadThreshold        *int32   `protobuf:"varint,4,opt,name=ReadThreshold" json:"ReadThreshold,omitempty"`
	StorageCapacity      *int32   `protobuf:"varint,5,opt,name=StorageCapacity" json:"StorageCapacity,omitempty"`
	SplitChar            *string  `protobuf:"bytes,6,opt,name=SplitChar" json:"SplitChar,omitempty"`
	Ttl                  *int64   `protobuf:"varint,7,opt,name=Ttl" json:"Ttl,omitempty"`
	TagsSplit            *string  `protobuf:"bytes,10,opt,name=TagsSplit" json:"TagsSplit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Options) Descriptor 

func (*Options) Descriptor() ([]byte, []int)

func (*Options) GetAppendMeta 

func (m *Options) GetAppendMeta() bool

func (*Options) GetCaseInSensitive 

func (m *Options) GetCaseInSensitive() bool

func (*Options) GetReadThreshold 

func (m *Options) GetReadThreshold() int32

func (*Options) GetSplitChar 

func (m *Options) GetSplitChar() string

func (*Options) GetStorageCapacity 

func (m *Options) GetStorageCapacity() int32

func (*Options) GetTagsSplit 

func (m *Options) GetTagsSplit() string

func (*Options) GetTtl 

func (m *Options) GetTtl() int64

func (*Options) GetWriteThreshold 

func (m *Options) GetWriteThreshold() int32

func (*Options) ProtoMessage 

func (*Options) ProtoMessage()

func (*Options) Reset 

func (m *Options) Reset()

func (*Options) String 

func (m *Options) String() string

func (*Options) XXX_DiscardUnknown 

func (m *Options) XXX_DiscardUnknown()

func (*Options) XXX_Marshal 

func (m *Options) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Options) XXX_Merge 

func (m *Options) XXX_Merge(src proto.Message)

func (*Options) XXX_Size 

func (m *Options) XXX_Size() int

func (*Options) XXX_Unmarshal 

func (m *Options) XXX_Unmarshal(b []byte) error

type Peer 

type Peer struct {
	ID                   *uint32  `protobuf:"varint,1,req,name=ID" json:"ID,omitempty"`
	Role                 *uint32  `protobuf:"varint,2,req,name=Role" json:"Role,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Peer) Descriptor 

func (*Peer) Descriptor() ([]byte, []int)

func (*Peer) GetID 

func (m *Peer) GetID() uint32

func (*Peer) GetRole 

func (m *Peer) GetRole() uint32

func (*Peer) ProtoMessage 

func (*Peer) ProtoMessage()

func (*Peer) Reset 

func (m *Peer) Reset()

func (*Peer) String 

func (m *Peer) String() string

func (*Peer) XXX_DiscardUnknown 

func (m *Peer) XXX_DiscardUnknown()

func (*Peer) XXX_Marshal 

func (m *Peer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Peer) XXX_Merge 

func (m *Peer) XXX_Merge(src proto.Message)

func (*Peer) XXX_Size 

func (m *Peer) XXX_Size() int

func (*Peer) XXX_Unmarshal 

func (m *Peer) XXX_Unmarshal(b []byte) error

type PruneGroupsCommand 

type PruneGroupsCommand struct {
	ShardGroup           *bool    `protobuf:"varint,1,req,name=ShardGroup" json:"ShardGroup,omitempty"`
	ID                   *uint64  `protobuf:"varint,2,opt,name=ID" json:"ID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PruneGroupsCommand) Descriptor 

func (*PruneGroupsCommand) Descriptor() ([]byte, []int)

func (*PruneGroupsCommand) GetID 

func (m *PruneGroupsCommand) GetID() uint64

func (*PruneGroupsCommand) GetShardGroup 

func (m *PruneGroupsCommand) GetShardGroup() bool

func (*PruneGroupsCommand) ProtoMessage 

func (*PruneGroupsCommand) ProtoMessage()

func (*PruneGroupsCommand) Reset 

func (m *PruneGroupsCommand) Reset()

func (*PruneGroupsCommand) String 

func (m *PruneGroupsCommand) String() string

func (*PruneGroupsCommand) XXX_DiscardUnknown 

func (m *PruneGroupsCommand) XXX_DiscardUnknown()

func (*PruneGroupsCommand) XXX_Marshal 

func (m *PruneGroupsCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PruneGroupsCommand) XXX_Merge 

func (m *PruneGroupsCommand) XXX_Merge(src proto.Message)

func (*PruneGroupsCommand) XXX_Size 

func (m *PruneGroupsCommand) XXX_Size() int

func (*PruneGroupsCommand) XXX_Unmarshal 

func (m *PruneGroupsCommand) XXX_Unmarshal(b []byte) error

type PtInfo 

type PtInfo struct {
	Owner                *PtOwner `protobuf:"bytes,1,req,name=Owner" json:"Owner,omitempty"`
	Status               *uint32  `protobuf:"varint,2,req,name=Status" json:"Status,omitempty"`
	PtId                 *uint32  `protobuf:"varint,3,req,name=PtId" json:"PtId,omitempty"`
	Ver                  *uint64  `protobuf:"varint,4,opt,name=Ver" json:"Ver,omitempty"`
	RGID                 *uint32  `protobuf:"varint,5,opt,name=RGID" json:"RGID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PtInfo) Descriptor 

func (*PtInfo) Descriptor() ([]byte, []int)

func (*PtInfo) GetOwner 

func (m *PtInfo) GetOwner() *PtOwner

func (*PtInfo) GetPtId 

func (m *PtInfo) GetPtId() uint32

func (*PtInfo) GetRGID 

func (m *PtInfo) GetRGID() uint32

func (*PtInfo) GetStatus 

func (m *PtInfo) GetStatus() uint32

func (*PtInfo) GetVer 

func (m *PtInfo) GetVer() uint64

func (*PtInfo) ProtoMessage 

func (*PtInfo) ProtoMessage()

func (*PtInfo) Reset 

func (m *PtInfo) Reset()

func (*PtInfo) String 

func (m *PtInfo) String() string

func (*PtInfo) XXX_DiscardUnknown 

func (m *PtInfo) XXX_DiscardUnknown()

func (*PtInfo) XXX_Marshal 

func (m *PtInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PtInfo) XXX_Merge 

func (m *PtInfo) XXX_Merge(src proto.Message)

func (*PtInfo) XXX_Size 

func (m *PtInfo) XXX_Size() int

func (*PtInfo) XXX_Unmarshal 

func (m *PtInfo) XXX_Unmarshal(b []byte) error

type PtOwner 

type PtOwner struct {
	NodeID               *uint64  `protobuf:"varint,1,req,name=NodeID" json:"NodeID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PtOwner) Descriptor 

func (*PtOwner) Descriptor() ([]byte, []int)

func (*PtOwner) GetNodeID 

func (m *PtOwner) GetNodeID() uint64

func (*PtOwner) ProtoMessage 

func (*PtOwner) ProtoMessage()

func (*PtOwner) Reset 

func (m *PtOwner) Reset()

func (*PtOwner) String 

func (m *PtOwner) String() string

func (*PtOwner) XXX_DiscardUnknown 

func (m *PtOwner) XXX_DiscardUnknown()

func (*PtOwner) XXX_Marshal 

func (m *PtOwner) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PtOwner) XXX_Merge 

func (m *PtOwner) XXX_Merge(src proto.Message)

func (*PtOwner) XXX_Size 

func (m *PtOwner) XXX_Size() int

func (*PtOwner) XXX_Unmarshal 

func (m *PtOwner) XXX_Unmarshal(b []byte) error

type ReShardingCommand 

type ReShardingCommand struct {
	Database             *string  `protobuf:"bytes,1,req,name=Database" json:"Database,omitempty"`
	RpName               *string  `protobuf:"bytes,2,req,name=RpName" json:"RpName,omitempty"`
	ShardGroupID         *uint64  `protobuf:"varint,3,req,name=ShardGroupID" json:"ShardGroupID,omitempty"`
	SplitTime            *int64   `protobuf:"varint,4,req,name=SplitTime" json:"SplitTime,omitempty"`
	ShardBounds          []string `protobuf:"bytes,5,rep,name=ShardBounds" json:"ShardBounds,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReShardingCommand) Descriptor 

func (*ReShardingCommand) Descriptor() ([]byte, []int)

func (*ReShardingCommand) GetDatabase 

func (m *ReShardingCommand) GetDatabase() string

func (*ReShardingCommand) GetRpName 

func (m *ReShardingCommand) GetRpName() string

func (*ReShardingCommand) GetShardBounds 

func (m *ReShardingCommand) GetShardBounds() []string

func (*ReShardingCommand) GetShardGroupID 

func (m *ReShardingCommand) GetShardGroupID() uint64

func (*ReShardingCommand) GetSplitTime 

func (m *ReShardingCommand) GetSplitTime() int64

func (*ReShardingCommand) ProtoMessage 

func (*ReShardingCommand) ProtoMessage()

func (*ReShardingCommand) Reset 

func (m *ReShardingCommand) Reset()

func (*ReShardingCommand) String 

func (m *ReShardingCommand) String() string

func (*ReShardingCommand) XXX_DiscardUnknown 

func (m *ReShardingCommand) XXX_DiscardUnknown()

func (*ReShardingCommand) XXX_Marshal 

func (m *ReShardingCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReShardingCommand) XXX_Merge 

func (m *ReShardingCommand) XXX_Merge(src proto.Message)

func (*ReShardingCommand) XXX_Size 

func (m *ReShardingCommand) XXX_Size() int

func (*ReShardingCommand) XXX_Unmarshal 

func (m *ReShardingCommand) XXX_Unmarshal(b []byte) error

type RegisterQueryIDOffsetCommand 

type RegisterQueryIDOffsetCommand struct {
	Host                 *string  `protobuf:"bytes,1,req,name=Host" json:"Host,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegisterQueryIDOffsetCommand) Descriptor 

func (*RegisterQueryIDOffsetCommand) Descriptor() ([]byte, []int)

func (*RegisterQueryIDOffsetCommand) GetHost 

func (m *RegisterQueryIDOffsetCommand) GetHost() string

func (*RegisterQueryIDOffsetCommand) ProtoMessage 

func (*RegisterQueryIDOffsetCommand) ProtoMessage()

func (*RegisterQueryIDOffsetCommand) Reset 

func (m *RegisterQueryIDOffsetCommand) Reset()

func (*RegisterQueryIDOffsetCommand) String 

func (m *RegisterQueryIDOffsetCommand) String() string

func (*RegisterQueryIDOffsetCommand) XXX_DiscardUnknown 

func (m *RegisterQueryIDOffsetCommand) XXX_DiscardUnknown()

func (*RegisterQueryIDOffsetCommand) XXX_Marshal 

func (m *RegisterQueryIDOffsetCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterQueryIDOffsetCommand) XXX_Merge 

func (m *RegisterQueryIDOffsetCommand) XXX_Merge(src proto.Message)

func (*RegisterQueryIDOffsetCommand) XXX_Size 

func (m *RegisterQueryIDOffsetCommand) XXX_Size() int

func (*RegisterQueryIDOffsetCommand) XXX_Unmarshal 

func (m *RegisterQueryIDOffsetCommand) XXX_Unmarshal(b []byte) error

type RemoveEventCommand 

type RemoveEventCommand struct {
	EventId              *string  `protobuf:"bytes,1,req,name=eventId" json:"eventId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveEventCommand) Descriptor 

func (*RemoveEventCommand) Descriptor() ([]byte, []int)

func (*RemoveEventCommand) GetEventId 

func (m *RemoveEventCommand) GetEventId() string

func (*RemoveEventCommand) ProtoMessage 

func (*RemoveEventCommand) ProtoMessage()

func (*RemoveEventCommand) Reset 

func (m *RemoveEventCommand) Reset()

func (*RemoveEventCommand) String 

func (m *RemoveEventCommand) String() string

func (*RemoveEventCommand) XXX_DiscardUnknown 

func (m *RemoveEventCommand) XXX_DiscardUnknown()

func (*RemoveEventCommand) XXX_Marshal 

func (m *RemoveEventCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveEventCommand) XXX_Merge 

func (m *RemoveEventCommand) XXX_Merge(src proto.Message)

func (*RemoveEventCommand) XXX_Size 

func (m *RemoveEventCommand) XXX_Size() int

func (*RemoveEventCommand) XXX_Unmarshal 

func (m *RemoveEventCommand) XXX_Unmarshal(b []byte) error

type RemoveNodeCommand 

type RemoveNodeCommand struct {
	NodeIds              []uint64 `protobuf:"varint,1,rep,name=nodeIds" json:"nodeIds,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveNodeCommand) Descriptor 

func (*RemoveNodeCommand) Descriptor() ([]byte, []int)

func (*RemoveNodeCommand) GetNodeIds 

func (m *RemoveNodeCommand) GetNodeIds() []uint64

func (*RemoveNodeCommand) ProtoMessage 

func (*RemoveNodeCommand) ProtoMessage()

func (*RemoveNodeCommand) Reset 

func (m *RemoveNodeCommand) Reset()

func (*RemoveNodeCommand) String 

func (m *RemoveNodeCommand) String() string

func (*RemoveNodeCommand) XXX_DiscardUnknown 

func (m *RemoveNodeCommand) XXX_DiscardUnknown()

func (*RemoveNodeCommand) XXX_Marshal 

func (m *RemoveNodeCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveNodeCommand) XXX_Merge 

func (m *RemoveNodeCommand) XXX_Merge(src proto.Message)

func (*RemoveNodeCommand) XXX_Size 

func (m *RemoveNodeCommand) XXX_Size() int

func (*RemoveNodeCommand) XXX_Unmarshal 

func (m *RemoveNodeCommand) XXX_Unmarshal(b []byte) error

type ReplicaGroup 

type ReplicaGroup struct {
	ID                   *uint32  `protobuf:"varint,1,req,name=ID" json:"ID,omitempty"`
	MasterID             *uint32  `protobuf:"varint,2,req,name=MasterID" json:"MasterID,omitempty"`
	Peers                []*Peer  `protobuf:"bytes,3,rep,name=Peers" json:"Peers,omitempty"`
	Status               *uint32  `protobuf:"varint,4,req,name=Status" json:"Status,omitempty"`
	Term                 *uint64  `protobuf:"varint,5,req,name=Term" json:"Term,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReplicaGroup) Descriptor 

func (*ReplicaGroup) Descriptor() ([]byte, []int)

func (*ReplicaGroup) GetID 

func (m *ReplicaGroup) GetID() uint32

func (*ReplicaGroup) GetMasterID 

func (m *ReplicaGroup) GetMasterID() uint32

func (*ReplicaGroup) GetPeers 

func (m *ReplicaGroup) GetPeers() []*Peer

func (*ReplicaGroup) GetStatus 

func (m *ReplicaGroup) GetStatus() uint32

func (*ReplicaGroup) GetTerm 

func (m *ReplicaGroup) GetTerm() uint64

func (*ReplicaGroup) ProtoMessage 

func (*ReplicaGroup) ProtoMessage()

func (*ReplicaGroup) Reset 

func (m *ReplicaGroup) Reset()

func (*ReplicaGroup) String 

func (m *ReplicaGroup) String() string

func (*ReplicaGroup) XXX_DiscardUnknown 

func (m *ReplicaGroup) XXX_DiscardUnknown()

func (*ReplicaGroup) XXX_Marshal 

func (m *ReplicaGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicaGroup) XXX_Merge 

func (m *ReplicaGroup) XXX_Merge(src proto.Message)

func (*ReplicaGroup) XXX_Size 

func (m *ReplicaGroup) XXX_Size() int

func (*ReplicaGroup) XXX_Unmarshal 

func (m *ReplicaGroup) XXX_Unmarshal(b []byte) error

type Replications 

type Replications struct {
	Groups               []*ReplicaGroup `protobuf:"bytes,1,rep,name=Groups" json:"Groups,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Replications) Descriptor 

func (*Replications) Descriptor() ([]byte, []int)

func (*Replications) GetGroups 

func (m *Replications) GetGroups() []*ReplicaGroup

func (*Replications) ProtoMessage 

func (*Replications) ProtoMessage()

func (*Replications) Reset 

func (m *Replications) Reset()

func (*Replications) String 

func (m *Replications) String() string

func (*Replications) XXX_DiscardUnknown 

func (m *Replications) XXX_DiscardUnknown()

func (*Replications) XXX_Marshal 

func (m *Replications) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Replications) XXX_Merge 

func (m *Replications) XXX_Merge(src proto.Message)

func (*Replications) XXX_Size 

func (m *Replications) XXX_Size() int

func (*Replications) XXX_Unmarshal 

func (m *Replications) XXX_Unmarshal(b []byte) error

type ReportShardsLoadCommand 

type ReportShardsLoadCommand struct {
	DBPTStat             []*DBPtStatus `protobuf:"bytes,1,rep,name=DBPTStat" json:"DBPTStat,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ReportShardsLoadCommand) Descriptor 

func (*ReportShardsLoadCommand) Descriptor() ([]byte, []int)

func (*ReportShardsLoadCommand) GetDBPTStat 

func (m *ReportShardsLoadCommand) GetDBPTStat() []*DBPtStatus

func (*ReportShardsLoadCommand) ProtoMessage 

func (*ReportShardsLoadCommand) ProtoMessage()

func (*ReportShardsLoadCommand) Reset 

func (m *ReportShardsLoadCommand) Reset()

func (*ReportShardsLoadCommand) String 

func (m *ReportShardsLoadCommand) String() string

func (*ReportShardsLoadCommand) XXX_DiscardUnknown 

func (m *ReportShardsLoadCommand) XXX_DiscardUnknown()

func (*ReportShardsLoadCommand) XXX_Marshal 

func (m *ReportShardsLoadCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReportShardsLoadCommand) XXX_Merge 

func (m *ReportShardsLoadCommand) XXX_Merge(src proto.Message)

func (*ReportShardsLoadCommand) XXX_Size 

func (m *ReportShardsLoadCommand) XXX_Size() int

func (*ReportShardsLoadCommand) XXX_Unmarshal 

func (m *ReportShardsLoadCommand) XXX_Unmarshal(b []byte) error

type Response 

type Response struct {
	OK                   *bool    `protobuf:"varint,1,req,name=OK" json:"OK,omitempty"`
	Error                *string  `protobuf:"bytes,2,opt,name=Error" json:"Error,omitempty"`
	Index                *uint64  `protobuf:"varint,3,opt,name=Index" json:"Index,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Response) Descriptor 

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

func (*Response) GetError 

func (m *Response) GetError() string

func (*Response) GetIndex 

func (m *Response) GetIndex() uint64

func (*Response) GetOK 

func (m *Response) GetOK() bool

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) String 

func (m *Response) String() string

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Response) XXX_Merge 

func (m *Response) XXX_Merge(src proto.Message)

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

func (m *Response) XXX_Unmarshal(b []byte) error

type RetentionPolicyInfo 

type RetentionPolicyInfo struct {
	Name                 *string               `protobuf:"bytes,1,req,name=Name" json:"Name,omitempty"`
	Duration             *int64                `protobuf:"varint,2,req,name=Duration" json:"Duration,omitempty"`
	ShardGroupDuration   *int64                `protobuf:"varint,3,req,name=ShardGroupDuration" json:"ShardGroupDuration,omitempty"`
	ReplicaN             *uint32               `protobuf:"varint,4,req,name=ReplicaN" json:"ReplicaN,omitempty"`
	Measurements         []*MeasurementInfo    `protobuf:"bytes,5,rep,name=Measurements" json:"Measurements,omitempty"`
	MstVersions          map[string]uint32     `` /* 144-byte string literal not displayed */
	ShardGroups          []*ShardGroupInfo     `protobuf:"bytes,6,rep,name=ShardGroups" json:"ShardGroups,omitempty"`
	Subscriptions        []*SubscriptionInfo   `protobuf:"bytes,7,rep,name=Subscriptions" json:"Subscriptions,omitempty"`
	MarkDeleted          *bool                 `protobuf:"varint,8,opt,name=MarkDeleted" json:"MarkDeleted,omitempty"`
	HotDuration          *int64                `protobuf:"varint,9,req,name=HotDuration" json:"HotDuration,omitempty"`
	WarmDuration         *int64                `protobuf:"varint,10,req,name=WarmDuration" json:"WarmDuration,omitempty"`
	IndexGroupDuration   *int64                `protobuf:"varint,11,req,name=IndexGroupDuration" json:"IndexGroupDuration,omitempty"`
	IndexGroups          []*IndexGroupInfo     `protobuf:"bytes,12,rep,name=IndexGroups" json:"IndexGroups,omitempty"`
	DownSamplePolicyInfo *DownSamplePolicyInfo `protobuf:"bytes,13,opt,name=DownSamplePolicyInfo" json:"DownSamplePolicyInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*RetentionPolicyInfo) Descriptor 

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

func (*RetentionPolicyInfo) GetDownSamplePolicyInfo 

func (m *RetentionPolicyInfo) GetDownSamplePolicyInfo() *DownSamplePolicyInfo

func (*RetentionPolicyInfo) GetDuration 

func (m *RetentionPolicyInfo) GetDuration() int64

func (*RetentionPolicyInfo) GetHotDuration 

func (m *RetentionPolicyInfo) GetHotDuration() int64

func (*RetentionPolicyInfo) GetIndexGroupDuration 

func (m *RetentionPolicyInfo) GetIndexGroupDuration() int64

func (*RetentionPolicyInfo) GetIndexGroups 

func (m *RetentionPolicyInfo) GetIndexGroups() []*IndexGroupInfo

func (*RetentionPolicyInfo) GetMarkDeleted 

func (m *RetentionPolicyInfo) GetMarkDeleted() bool

func (*RetentionPolicyInfo) GetMeasurements 

func (m *RetentionPolicyInfo) GetMeasurements() []*MeasurementInfo

func (*RetentionPolicyInfo) GetMstVersions 

func (m *RetentionPolicyInfo) GetMstVersions() map[string]uint32

func (*RetentionPolicyInfo) GetName 

func (m *RetentionPolicyInfo) GetName() string

func (*RetentionPolicyInfo) GetReplicaN 

func (m *RetentionPolicyInfo) GetReplicaN() uint32

func (*RetentionPolicyInfo) GetShardGroupDuration 

func (m *RetentionPolicyInfo) GetShardGroupDuration() int64

func (*RetentionPolicyInfo) GetShardGroups 

func (m *RetentionPolicyInfo) GetShardGroups() []*ShardGroupInfo

func (*RetentionPolicyInfo) GetSubscriptions 

func (m *RetentionPolicyInfo) GetSubscriptions() []*SubscriptionInfo

func (*RetentionPolicyInfo) GetWarmDuration 

func (m *RetentionPolicyInfo) GetWarmDuration() int64

func (*RetentionPolicyInfo) ProtoMessage 

func (*RetentionPolicyInfo) ProtoMessage()

func (*RetentionPolicyInfo) Reset 

func (m *RetentionPolicyInfo) Reset()

func (*RetentionPolicyInfo) String 

func (m *RetentionPolicyInfo) String() string

func (*RetentionPolicyInfo) XXX_DiscardUnknown 

func (m *RetentionPolicyInfo) XXX_DiscardUnknown()

func (*RetentionPolicyInfo) XXX_Marshal 

func (m *RetentionPolicyInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RetentionPolicyInfo) XXX_Merge 

func (m *RetentionPolicyInfo) XXX_Merge(src proto.Message)

func (*RetentionPolicyInfo) XXX_Size 

func (m *RetentionPolicyInfo) XXX_Size() int

func (*RetentionPolicyInfo) XXX_Unmarshal 

func (m *RetentionPolicyInfo) XXX_Unmarshal(b []byte) error

type RetentionPolicySpec 

type RetentionPolicySpec struct {
	Name                 *string  `protobuf:"bytes,1,opt,name=Name" json:"Name,omitempty"`
	Duration             *int64   `protobuf:"varint,2,opt,name=Duration" json:"Duration,omitempty"`
	ShardGroupDuration   *int64   `protobuf:"varint,3,opt,name=ShardGroupDuration" json:"ShardGroupDuration,omitempty"`
	ReplicaN             *uint32  `protobuf:"varint,4,opt,name=ReplicaN" json:"ReplicaN,omitempty"`
	WarmDuration         *int64   `protobuf:"varint,5,opt,name=WarmDuration" json:"WarmDuration,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RetentionPolicySpec) Descriptor 

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

func (*RetentionPolicySpec) GetDuration 

func (m *RetentionPolicySpec) GetDuration() int64

func (*RetentionPolicySpec) GetName 

func (m *RetentionPolicySpec) GetName() string

func (*RetentionPolicySpec) GetReplicaN 

func (m *RetentionPolicySpec) GetReplicaN() uint32

func (*RetentionPolicySpec) GetShardGroupDuration 

func (m *RetentionPolicySpec) GetShardGroupDuration() int64

func (*RetentionPolicySpec) GetWarmDuration 

func (m *RetentionPolicySpec) GetWarmDuration() int64

func (*RetentionPolicySpec) ProtoMessage 

func (*RetentionPolicySpec) ProtoMessage()

func (*RetentionPolicySpec) Reset 

func (m *RetentionPolicySpec) Reset()

func (*RetentionPolicySpec) String 

func (m *RetentionPolicySpec) String() string

func (*RetentionPolicySpec) XXX_DiscardUnknown 

func (m *RetentionPolicySpec) XXX_DiscardUnknown()

func (*RetentionPolicySpec) XXX_Marshal 

func (m *RetentionPolicySpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RetentionPolicySpec) XXX_Merge 

func (m *RetentionPolicySpec) XXX_Merge(src proto.Message)

func (*RetentionPolicySpec) XXX_Size 

func (m *RetentionPolicySpec) XXX_Size() int

func (*RetentionPolicySpec) XXX_Unmarshal 

func (m *RetentionPolicySpec) XXX_Unmarshal(b []byte) error

type RpMeasurementsFieldsInfo 

type RpMeasurementsFieldsInfo struct {
	MeasurementInfos     []*MeasurementFieldsInfo `protobuf:"bytes,1,rep,name=MeasurementInfos" json:"MeasurementInfos,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*RpMeasurementsFieldsInfo) Descriptor 

func (*RpMeasurementsFieldsInfo) Descriptor() ([]byte, []int)

func (*RpMeasurementsFieldsInfo) GetMeasurementInfos 

func (m *RpMeasurementsFieldsInfo) GetMeasurementInfos() []*MeasurementFieldsInfo

func (*RpMeasurementsFieldsInfo) ProtoMessage 

func (*RpMeasurementsFieldsInfo) ProtoMessage()

func (*RpMeasurementsFieldsInfo) Reset 

func (m *RpMeasurementsFieldsInfo) Reset()

func (*RpMeasurementsFieldsInfo) String 

func (m *RpMeasurementsFieldsInfo) String() string

func (*RpMeasurementsFieldsInfo) XXX_DiscardUnknown 

func (m *RpMeasurementsFieldsInfo) XXX_DiscardUnknown()

func (*RpMeasurementsFieldsInfo) XXX_Marshal 

func (m *RpMeasurementsFieldsInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RpMeasurementsFieldsInfo) XXX_Merge 

func (m *RpMeasurementsFieldsInfo) XXX_Merge(src proto.Message)

func (*RpMeasurementsFieldsInfo) XXX_Size 

func (m *RpMeasurementsFieldsInfo) XXX_Size() int

func (*RpMeasurementsFieldsInfo) XXX_Unmarshal 

func (m *RpMeasurementsFieldsInfo) XXX_Unmarshal(b []byte) error

type RpShardStatus 

type RpShardStatus struct {
	RpName               *string      `protobuf:"bytes,1,req,name=RpName" json:"RpName,omitempty"`
	ShardStats           *ShardStatus `protobuf:"bytes,2,req,name=ShardStats" json:"ShardStats,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*RpShardStatus) Descriptor 

func (*RpShardStatus) Descriptor() ([]byte, []int)

func (*RpShardStatus) GetRpName 

func (m *RpShardStatus) GetRpName() string

func (*RpShardStatus) GetShardStats 

func (m *RpShardStatus) GetShardStats() *ShardStatus

func (*RpShardStatus) ProtoMessage 

func (*RpShardStatus) ProtoMessage()

func (*RpShardStatus) Reset 

func (m *RpShardStatus) Reset()

func (*RpShardStatus) String 

func (m *RpShardStatus) String() string

func (*RpShardStatus) XXX_DiscardUnknown 

func (m *RpShardStatus) XXX_DiscardUnknown()

func (*RpShardStatus) XXX_Marshal 

func (m *RpShardStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RpShardStatus) XXX_Merge 

func (m *RpShardStatus) XXX_Merge(src proto.Message)

func (*RpShardStatus) XXX_Size 

func (m *RpShardStatus) XXX_Size() int

func (*RpShardStatus) XXX_Unmarshal 

func (m *RpShardStatus) XXX_Unmarshal(b []byte) error

type SetAdminPrivilegeCommand 

type SetAdminPrivilegeCommand struct {
	Username             *string  `protobuf:"bytes,1,req,name=Username" json:"Username,omitempty"`
	Admin                *bool    `protobuf:"varint,2,req,name=Admin" json:"Admin,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetAdminPrivilegeCommand) Descriptor 

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

func (*SetAdminPrivilegeCommand) GetAdmin 

func (m *SetAdminPrivilegeCommand) GetAdmin() bool

func (*SetAdminPrivilegeCommand) GetUsername 

func (m *SetAdminPrivilegeCommand) GetUsername() string

func (*SetAdminPrivilegeCommand) ProtoMessage 

func (*SetAdminPrivilegeCommand) ProtoMessage()

func (*SetAdminPrivilegeCommand) Reset 

func (m *SetAdminPrivilegeCommand) Reset()

func (*SetAdminPrivilegeCommand) String 

func (m *SetAdminPrivilegeCommand) String() string

func (*SetAdminPrivilegeCommand) XXX_DiscardUnknown 

func (m *SetAdminPrivilegeCommand) XXX_DiscardUnknown()

func (*SetAdminPrivilegeCommand) XXX_Marshal 

func (m *SetAdminPrivilegeCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetAdminPrivilegeCommand) XXX_Merge 

func (m *SetAdminPrivilegeCommand) XXX_Merge(src proto.Message)

func (*SetAdminPrivilegeCommand) XXX_Size 

func (m *SetAdminPrivilegeCommand) XXX_Size() int

func (*SetAdminPrivilegeCommand) XXX_Unmarshal 

func (m *SetAdminPrivilegeCommand) XXX_Unmarshal(b []byte) error

type SetDataCommand 

type SetDataCommand struct {
	Data                 *Data    `protobuf:"bytes,1,req,name=Data" json:"Data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetDataCommand) Descriptor 

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

func (*SetDataCommand) GetData 

func (m *SetDataCommand) GetData() *Data

func (*SetDataCommand) ProtoMessage 

func (*SetDataCommand) ProtoMessage()

func (*SetDataCommand) Reset 

func (m *SetDataCommand) Reset()

func (*SetDataCommand) String 

func (m *SetDataCommand) String() string

func (*SetDataCommand) XXX_DiscardUnknown 

func (m *SetDataCommand) XXX_DiscardUnknown()

func (*SetDataCommand) XXX_Marshal 

func (m *SetDataCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetDataCommand) XXX_Merge 

func (m *SetDataCommand) XXX_Merge(src proto.Message)

func (*SetDataCommand) XXX_Size 

func (m *SetDataCommand) XXX_Size() int

func (*SetDataCommand) XXX_Unmarshal 

func (m *SetDataCommand) XXX_Unmarshal(b []byte) error

type SetDefaultRetentionPolicyCommand 

type SetDefaultRetentionPolicyCommand struct {
	Database             *string  `protobuf:"bytes,1,req,name=Database" json:"Database,omitempty"`
	Name                 *string  `protobuf:"bytes,2,req,name=Name" json:"Name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetDefaultRetentionPolicyCommand) Descriptor 

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

func (*SetDefaultRetentionPolicyCommand) GetDatabase 

func (m *SetDefaultRetentionPolicyCommand) GetDatabase() string

func (*SetDefaultRetentionPolicyCommand) GetName 

func (m *SetDefaultRetentionPolicyCommand) GetName() string

func (*SetDefaultRetentionPolicyCommand) ProtoMessage 

func (*SetDefaultRetentionPolicyCommand) ProtoMessage()

func (*SetDefaultRetentionPolicyCommand) Reset 

func (m *SetDefaultRetentionPolicyCommand) Reset()

func (*SetDefaultRetentionPolicyCommand) String 

func (m *SetDefaultRetentionPolicyCommand) String() string

func (*SetDefaultRetentionPolicyCommand) XXX_DiscardUnknown 

func (m *SetDefaultRetentionPolicyCommand) XXX_DiscardUnknown()

func (*SetDefaultRetentionPolicyCommand) XXX_Marshal 

func (m *SetDefaultRetentionPolicyCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetDefaultRetentionPolicyCommand) XXX_Merge 

func (m *SetDefaultRetentionPolicyCommand) XXX_Merge(src proto.Message)

func (*SetDefaultRetentionPolicyCommand) XXX_Size 

func (m *SetDefaultRetentionPolicyCommand) XXX_Size() int

func (*SetDefaultRetentionPolicyCommand) XXX_Unmarshal 

func (m *SetDefaultRetentionPolicyCommand) XXX_Unmarshal(b []byte) error

type SetMetaNodeCommand 

type SetMetaNodeCommand struct {
	HTTPAddr             *string  `protobuf:"bytes,1,req,name=HTTPAddr" json:"HTTPAddr,omitempty"`
	RPCAddr              *string  `protobuf:"bytes,4,req,name=RPCAddr" json:"RPCAddr,omitempty"`
	TCPAddr              *string  `protobuf:"bytes,2,req,name=TCPAddr" json:"TCPAddr,omitempty"`
	Rand                 *uint64  `protobuf:"varint,3,req,name=Rand" json:"Rand,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

SetMetaNodeCommand is for the initial metanode in a cluster or if the single host restarts and its hostname changes, this will update it

func (*SetMetaNodeCommand) Descriptor 

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

func (*SetMetaNodeCommand) GetHTTPAddr 

func (m *SetMetaNodeCommand) GetHTTPAddr() string

func (*SetMetaNodeCommand) GetRPCAddr 

func (m *SetMetaNodeCommand) GetRPCAddr() string

func (*SetMetaNodeCommand) GetRand 

func (m *SetMetaNodeCommand) GetRand() uint64

func (*SetMetaNodeCommand) GetTCPAddr 

func (m *SetMetaNodeCommand) GetTCPAddr() string

func (*SetMetaNodeCommand) ProtoMessage 

func (*SetMetaNodeCommand) ProtoMessage()

func (*SetMetaNodeCommand) Reset 

func (m *SetMetaNodeCommand) Reset()

func (*SetMetaNodeCommand) String 

func (m *SetMetaNodeCommand) String() string

func (*SetMetaNodeCommand) XXX_DiscardUnknown 

func (m *SetMetaNodeCommand) XXX_DiscardUnknown()

func (*SetMetaNodeCommand) XXX_Marshal 

func (m *SetMetaNodeCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetMetaNodeCommand) XXX_Merge 

func (m *SetMetaNodeCommand) XXX_Merge(src proto.Message)

func (*SetMetaNodeCommand) XXX_Size 

func (m *SetMetaNodeCommand) XXX_Size() int

func (*SetMetaNodeCommand) XXX_Unmarshal 

func (m *SetMetaNodeCommand) XXX_Unmarshal(b []byte) error

type SetNodeSegregateStatusCommand 

type SetNodeSegregateStatusCommand struct {
	Status               []uint64 `protobuf:"varint,1,rep,name=status" json:"status,omitempty"`
	NodeIds              []uint64 `protobuf:"varint,2,rep,name=nodeIds" json:"nodeIds,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetNodeSegregateStatusCommand) Descriptor 

func (*SetNodeSegregateStatusCommand) Descriptor() ([]byte, []int)

func (*SetNodeSegregateStatusCommand) GetNodeIds 

func (m *SetNodeSegregateStatusCommand) GetNodeIds() []uint64

func (*SetNodeSegregateStatusCommand) GetStatus 

func (m *SetNodeSegregateStatusCommand) GetStatus() []uint64

func (*SetNodeSegregateStatusCommand) ProtoMessage 

func (*SetNodeSegregateStatusCommand) ProtoMessage()

func (*SetNodeSegregateStatusCommand) Reset 

func (m *SetNodeSegregateStatusCommand) Reset()

func (*SetNodeSegregateStatusCommand) String 

func (m *SetNodeSegregateStatusCommand) String() string

func (*SetNodeSegregateStatusCommand) XXX_DiscardUnknown 

func (m *SetNodeSegregateStatusCommand) XXX_DiscardUnknown()

func (*SetNodeSegregateStatusCommand) XXX_Marshal 

func (m *SetNodeSegregateStatusCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetNodeSegregateStatusCommand) XXX_Merge 

func (m *SetNodeSegregateStatusCommand) XXX_Merge(src proto.Message)

func (*SetNodeSegregateStatusCommand) XXX_Size 

func (m *SetNodeSegregateStatusCommand) XXX_Size() int

func (*SetNodeSegregateStatusCommand) XXX_Unmarshal 

func (m *SetNodeSegregateStatusCommand) XXX_Unmarshal(b []byte) error

type SetPrivilegeCommand 

type SetPrivilegeCommand struct {
	Username             *string  `protobuf:"bytes,1,req,name=Username" json:"Username,omitempty"`
	Database             *string  `protobuf:"bytes,2,req,name=Database" json:"Database,omitempty"`
	Privilege            *int32   `protobuf:"varint,3,req,name=Privilege" json:"Privilege,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetPrivilegeCommand) Descriptor 

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

func (*SetPrivilegeCommand) GetDatabase 

func (m *SetPrivilegeCommand) GetDatabase() string

func (*SetPrivilegeCommand) GetPrivilege 

func (m *SetPrivilegeCommand) GetPrivilege() int32

func (*SetPrivilegeCommand) GetUsername 

func (m *SetPrivilegeCommand) GetUsername() string

func (*SetPrivilegeCommand) ProtoMessage 

func (*SetPrivilegeCommand) ProtoMessage()

func (*SetPrivilegeCommand) Reset 

func (m *SetPrivilegeCommand) Reset()

func (*SetPrivilegeCommand) String 

func (m *SetPrivilegeCommand) String() string

func (*SetPrivilegeCommand) XXX_DiscardUnknown 

func (m *SetPrivilegeCommand) XXX_DiscardUnknown()

func (*SetPrivilegeCommand) XXX_Marshal 

func (m *SetPrivilegeCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetPrivilegeCommand) XXX_Merge 

func (m *SetPrivilegeCommand) XXX_Merge(src proto.Message)

func (*SetPrivilegeCommand) XXX_Size 

func (m *SetPrivilegeCommand) XXX_Size() int

func (*SetPrivilegeCommand) XXX_Unmarshal 

func (m *SetPrivilegeCommand) XXX_Unmarshal(b []byte) error

type ShardDownSampleUpdateInfo 

type ShardDownSampleUpdateInfo struct {
	Ident                *ShardIdentifier `protobuf:"bytes,1,req,name=Ident" json:"Ident,omitempty"`
	DownSampleLvl        *int64           `protobuf:"varint,2,req,name=DownSampleLvl" json:"DownSampleLvl,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ShardDownSampleUpdateInfo) Descriptor 

func (*ShardDownSampleUpdateInfo) Descriptor() ([]byte, []int)

func (*ShardDownSampleUpdateInfo) GetDownSampleLvl 

func (m *ShardDownSampleUpdateInfo) GetDownSampleLvl() int64

func (*ShardDownSampleUpdateInfo) GetIdent 

func (m *ShardDownSampleUpdateInfo) GetIdent() *ShardIdentifier

func (*ShardDownSampleUpdateInfo) ProtoMessage 

func (*ShardDownSampleUpdateInfo) ProtoMessage()

func (*ShardDownSampleUpdateInfo) Reset 

func (m *ShardDownSampleUpdateInfo) Reset()

func (*ShardDownSampleUpdateInfo) String 

func (m *ShardDownSampleUpdateInfo) String() string

func (*ShardDownSampleUpdateInfo) XXX_DiscardUnknown 

func (m *ShardDownSampleUpdateInfo) XXX_DiscardUnknown()

func (*ShardDownSampleUpdateInfo) XXX_Marshal 

func (m *ShardDownSampleUpdateInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShardDownSampleUpdateInfo) XXX_Merge 

func (m *ShardDownSampleUpdateInfo) XXX_Merge(src proto.Message)

func (*ShardDownSampleUpdateInfo) XXX_Size 

func (m *ShardDownSampleUpdateInfo) XXX_Size() int

func (*ShardDownSampleUpdateInfo) XXX_Unmarshal 

func (m *ShardDownSampleUpdateInfo) XXX_Unmarshal(b []byte) error

type ShardDownSampleUpdateInfos 

type ShardDownSampleUpdateInfos struct {
	Infos                []*ShardDownSampleUpdateInfo `protobuf:"bytes,1,rep,name=Infos" json:"Infos,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*ShardDownSampleUpdateInfos) Descriptor 

func (*ShardDownSampleUpdateInfos) Descriptor() ([]byte, []int)

func (*ShardDownSampleUpdateInfos) GetInfos 

func (m *ShardDownSampleUpdateInfos) GetInfos() []*ShardDownSampleUpdateInfo

func (*ShardDownSampleUpdateInfos) ProtoMessage 

func (*ShardDownSampleUpdateInfos) ProtoMessage()

func (*ShardDownSampleUpdateInfos) Reset 

func (m *ShardDownSampleUpdateInfos) Reset()

func (*ShardDownSampleUpdateInfos) String 

func (m *ShardDownSampleUpdateInfos) String() string

func (*ShardDownSampleUpdateInfos) XXX_DiscardUnknown 

func (m *ShardDownSampleUpdateInfos) XXX_DiscardUnknown()

func (*ShardDownSampleUpdateInfos) XXX_Marshal 

func (m *ShardDownSampleUpdateInfos) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShardDownSampleUpdateInfos) XXX_Merge 

func (m *ShardDownSampleUpdateInfos) XXX_Merge(src proto.Message)

func (*ShardDownSampleUpdateInfos) XXX_Size 

func (m *ShardDownSampleUpdateInfos) XXX_Size() int

func (*ShardDownSampleUpdateInfos) XXX_Unmarshal 

func (m *ShardDownSampleUpdateInfos) XXX_Unmarshal(b []byte) error

type ShardDurationCommand 

type ShardDurationCommand struct {
	Index                *uint64  `protobuf:"varint,1,req,name=Index" json:"Index,omitempty"`
	Pts                  []uint32 `protobuf:"varint,2,rep,name=Pts" json:"Pts,omitempty"`
	NodeId               *uint64  `protobuf:"varint,3,opt,name=nodeId" json:"nodeId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ShardDurationCommand) Descriptor 

func (*ShardDurationCommand) Descriptor() ([]byte, []int)

func (*ShardDurationCommand) GetIndex 

func (m *ShardDurationCommand) GetIndex() uint64

func (*ShardDurationCommand) GetNodeId 

func (m *ShardDurationCommand) GetNodeId() uint64

func (*ShardDurationCommand) GetPts 

func (m *ShardDurationCommand) GetPts() []uint32

func (*ShardDurationCommand) ProtoMessage 

func (*ShardDurationCommand) ProtoMessage()

func (*ShardDurationCommand) Reset 

func (m *ShardDurationCommand) Reset()

func (*ShardDurationCommand) String 

func (m *ShardDurationCommand) String() string

func (*ShardDurationCommand) XXX_DiscardUnknown 

func (m *ShardDurationCommand) XXX_DiscardUnknown()

func (*ShardDurationCommand) XXX_Marshal 

func (m *ShardDurationCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShardDurationCommand) XXX_Merge 

func (m *ShardDurationCommand) XXX_Merge(src proto.Message)

func (*ShardDurationCommand) XXX_Size 

func (m *ShardDurationCommand) XXX_Size() int

func (*ShardDurationCommand) XXX_Unmarshal 

func (m *ShardDurationCommand) XXX_Unmarshal(b []byte) error

type ShardDurationInfo 

type ShardDurationInfo struct {
	Ident                *ShardIdentifier    `protobuf:"bytes,1,opt,name=Ident" json:"Ident,omitempty"`
	DurationInfo         *DurationDescriptor `protobuf:"bytes,2,req,name=DurationInfo" json:"DurationInfo,omitempty"`
	MeasurementInfo      []*MeasurementInfo  `protobuf:"bytes,3,rep,name=MeasurementInfo" json:"MeasurementInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*ShardDurationInfo) Descriptor 

func (*ShardDurationInfo) Descriptor() ([]byte, []int)

func (*ShardDurationInfo) GetDurationInfo 

func (m *ShardDurationInfo) GetDurationInfo() *DurationDescriptor

func (*ShardDurationInfo) GetIdent 

func (m *ShardDurationInfo) GetIdent() *ShardIdentifier

func (*ShardDurationInfo) GetMeasurementInfo 

func (m *ShardDurationInfo) GetMeasurementInfo() []*MeasurementInfo

func (*ShardDurationInfo) ProtoMessage 

func (*ShardDurationInfo) ProtoMessage()

func (*ShardDurationInfo) Reset 

func (m *ShardDurationInfo) Reset()

func (*ShardDurationInfo) String 

func (m *ShardDurationInfo) String() string

func (*ShardDurationInfo) XXX_DiscardUnknown 

func (m *ShardDurationInfo) XXX_DiscardUnknown()

func (*ShardDurationInfo) XXX_Marshal 

func (m *ShardDurationInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShardDurationInfo) XXX_Merge 

func (m *ShardDurationInfo) XXX_Merge(src proto.Message)

func (*ShardDurationInfo) XXX_Size 

func (m *ShardDurationInfo) XXX_Size() int

func (*ShardDurationInfo) XXX_Unmarshal 

func (m *ShardDurationInfo) XXX_Unmarshal(b []byte) error

type ShardDurationResponse 

type ShardDurationResponse struct {
	DataIndex            *uint64              `protobuf:"varint,1,req,name=DataIndex" json:"DataIndex,omitempty"`
	Durations            []*ShardDurationInfo `protobuf:"bytes,2,rep,name=Durations" json:"Durations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ShardDurationResponse) Descriptor 

func (*ShardDurationResponse) Descriptor() ([]byte, []int)

func (*ShardDurationResponse) GetDataIndex 

func (m *ShardDurationResponse) GetDataIndex() uint64

func (*ShardDurationResponse) GetDurations 

func (m *ShardDurationResponse) GetDurations() []*ShardDurationInfo

func (*ShardDurationResponse) ProtoMessage 

func (*ShardDurationResponse) ProtoMessage()

func (*ShardDurationResponse) Reset 

func (m *ShardDurationResponse) Reset()

func (*ShardDurationResponse) String 

func (m *ShardDurationResponse) String() string

func (*ShardDurationResponse) XXX_DiscardUnknown 

func (m *ShardDurationResponse) XXX_DiscardUnknown()

func (*ShardDurationResponse) XXX_Marshal 

func (m *ShardDurationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShardDurationResponse) XXX_Merge 

func (m *ShardDurationResponse) XXX_Merge(src proto.Message)

func (*ShardDurationResponse) XXX_Size 

func (m *ShardDurationResponse) XXX_Size() int

func (*ShardDurationResponse) XXX_Unmarshal 

func (m *ShardDurationResponse) XXX_Unmarshal(b []byte) error

type ShardGroupInfo 

type ShardGroupInfo struct {
	ID                   *uint64      `protobuf:"varint,1,req,name=ID" json:"ID,omitempty"`
	StartTime            *int64       `protobuf:"varint,2,req,name=StartTime" json:"StartTime,omitempty"`
	EndTime              *int64       `protobuf:"varint,3,req,name=EndTime" json:"EndTime,omitempty"`
	DeletedAt            *int64       `protobuf:"varint,4,req,name=DeletedAt" json:"DeletedAt,omitempty"`
	Shards               []*ShardInfo `protobuf:"bytes,5,rep,name=Shards" json:"Shards,omitempty"`
	TruncatedAt          *int64       `protobuf:"varint,6,opt,name=TruncatedAt" json:"TruncatedAt,omitempty"`
	EngineType           *uint32      `protobuf:"varint,7,opt,name=EngineType" json:"EngineType,omitempty"`
	Version              *uint32      `protobuf:"varint,12,opt,name=version" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ShardGroupInfo) Descriptor 

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

func (*ShardGroupInfo) GetDeletedAt 

func (m *ShardGroupInfo) GetDeletedAt() int64

func (*ShardGroupInfo) GetEndTime 

func (m *ShardGroupInfo) GetEndTime() int64

func (*ShardGroupInfo) GetEngineType 

func (m *ShardGroupInfo) GetEngineType() uint32

func (*ShardGroupInfo) GetID 

func (m *ShardGroupInfo) GetID() uint64

func (*ShardGroupInfo) GetShards 

func (m *ShardGroupInfo) GetShards() []*ShardInfo

func (*ShardGroupInfo) GetStartTime 

func (m *ShardGroupInfo) GetStartTime() int64

func (*ShardGroupInfo) GetTruncatedAt 

func (m *ShardGroupInfo) GetTruncatedAt() int64

func (*ShardGroupInfo) GetVersion 

func (m *ShardGroupInfo) GetVersion() uint32

func (*ShardGroupInfo) ProtoMessage 

func (*ShardGroupInfo) ProtoMessage()

func (*ShardGroupInfo) Reset 

func (m *ShardGroupInfo) Reset()

func (*ShardGroupInfo) String 

func (m *ShardGroupInfo) String() string

func (*ShardGroupInfo) XXX_DiscardUnknown 

func (m *ShardGroupInfo) XXX_DiscardUnknown()

func (*ShardGroupInfo) XXX_Marshal 

func (m *ShardGroupInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShardGroupInfo) XXX_Merge 

func (m *ShardGroupInfo) XXX_Merge(src proto.Message)

func (*ShardGroupInfo) XXX_Size 

func (m *ShardGroupInfo) XXX_Size() int

func (*ShardGroupInfo) XXX_Unmarshal 

func (m *ShardGroupInfo) XXX_Unmarshal(b []byte) error

type ShardIdentifier 

type ShardIdentifier struct {
	ShardID              *uint64  `protobuf:"varint,1,req,name=ShardID" json:"ShardID,omitempty"`
	ShardGroupID         *uint64  `protobuf:"varint,2,req,name=ShardGroupID" json:"ShardGroupID,omitempty"`
	OwnerDb              *string  `protobuf:"bytes,3,req,name=OwnerDb" json:"OwnerDb,omitempty"`
	OwnerPt              *uint32  `protobuf:"varint,4,req,name=OwnerPt" json:"OwnerPt,omitempty"`
	Policy               *string  `protobuf:"bytes,5,req,name=Policy" json:"Policy,omitempty"`
	ShardType            *string  `protobuf:"bytes,6,req,name=ShardType" json:"ShardType,omitempty"`
	DownSampleLevel      *int64   `protobuf:"varint,7,opt,name=DownSampleLevel" json:"DownSampleLevel,omitempty"`
	DownSampleID         *uint64  `protobuf:"varint,8,opt,name=DownSampleID" json:"DownSampleID,omitempty"`
	ReadOnly             *bool    `protobuf:"varint,9,opt,name=ReadOnly" json:"ReadOnly,omitempty"`
	EngineType           *uint32  `protobuf:"varint,10,opt,name=EngineType" json:"EngineType,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ShardIdentifier) Descriptor 

func (*ShardIdentifier) Descriptor() ([]byte, []int)

func (*ShardIdentifier) GetDownSampleID 

func (m *ShardIdentifier) GetDownSampleID() uint64

func (*ShardIdentifier) GetDownSampleLevel 

func (m *ShardIdentifier) GetDownSampleLevel() int64

func (*ShardIdentifier) GetEngineType 

func (m *ShardIdentifier) GetEngineType() uint32

func (*ShardIdentifier) GetOwnerDb 

func (m *ShardIdentifier) GetOwnerDb() string

func (*ShardIdentifier) GetOwnerPt 

func (m *ShardIdentifier) GetOwnerPt() uint32

func (*ShardIdentifier) GetPolicy 

func (m *ShardIdentifier) GetPolicy() string

func (*ShardIdentifier) GetReadOnly 

func (m *ShardIdentifier) GetReadOnly() bool

func (*ShardIdentifier) GetShardGroupID 

func (m *ShardIdentifier) GetShardGroupID() uint64

func (*ShardIdentifier) GetShardID 

func (m *ShardIdentifier) GetShardID() uint64

func (*ShardIdentifier) GetShardType 

func (m *ShardIdentifier) GetShardType() string

func (*ShardIdentifier) ProtoMessage 

func (*ShardIdentifier) ProtoMessage()

func (*ShardIdentifier) Reset 

func (m *ShardIdentifier) Reset()

func (*ShardIdentifier) String 

func (m *ShardIdentifier) String() string

func (*ShardIdentifier) XXX_DiscardUnknown 

func (m *ShardIdentifier) XXX_DiscardUnknown()

func (*ShardIdentifier) XXX_Marshal 

func (m *ShardIdentifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShardIdentifier) XXX_Merge 

func (m *ShardIdentifier) XXX_Merge(src proto.Message)

func (*ShardIdentifier) XXX_Size 

func (m *ShardIdentifier) XXX_Size() int

func (*ShardIdentifier) XXX_Unmarshal 

func (m *ShardIdentifier) XXX_Unmarshal(b []byte) error

type ShardInfo 

type ShardInfo struct {
	ID                   *uint64  `protobuf:"varint,1,req,name=ID" json:"ID,omitempty"`
	OwnerIDs             []uint32 `protobuf:"varint,2,rep,name=OwnerIDs" json:"OwnerIDs,omitempty"` // Deprecated: Do not use.
	Min                  *string  `protobuf:"bytes,3,req,name=Min" json:"Min,omitempty"`
	Max                  *string  `protobuf:"bytes,4,req,name=Max" json:"Max,omitempty"`
	Tier                 *uint64  `protobuf:"varint,5,req,name=Tier" json:"Tier,omitempty"`
	IndexID              *uint64  `protobuf:"varint,6,req,name=IndexID" json:"IndexID,omitempty"`
	DownSampleLevel      *int64   `protobuf:"varint,7,req,name=DownSampleLevel" json:"DownSampleLevel,omitempty"`
	DownSampleID         *uint64  `protobuf:"varint,8,opt,name=DownSampleID" json:"DownSampleID,omitempty"`
	ReadOnly             *bool    `protobuf:"varint,9,opt,name=ReadOnly" json:"ReadOnly,omitempty"`
	MarkDelete           *bool    `protobuf:"varint,10,opt,name=MarkDelete" json:"MarkDelete,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ShardInfo) Descriptor 

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

func (*ShardInfo) GetDownSampleID 

func (m *ShardInfo) GetDownSampleID() uint64

func (*ShardInfo) GetDownSampleLevel 

func (m *ShardInfo) GetDownSampleLevel() int64

func (*ShardInfo) GetID 

func (m *ShardInfo) GetID() uint64

func (*ShardInfo) GetIndexID 

func (m *ShardInfo) GetIndexID() uint64

func (*ShardInfo) GetMarkDelete 

func (m *ShardInfo) GetMarkDelete() bool

func (*ShardInfo) GetMax 

func (m *ShardInfo) GetMax() string

func (*ShardInfo) GetMin 

func (m *ShardInfo) GetMin() string

func (*ShardInfo) GetOwnerIDs deprecated 

func (m *ShardInfo) GetOwnerIDs() []uint32

Deprecated: Do not use.

func (*ShardInfo) GetReadOnly 

func (m *ShardInfo) GetReadOnly() bool

func (*ShardInfo) GetTier 

func (m *ShardInfo) GetTier() uint64

func (*ShardInfo) ProtoMessage 

func (*ShardInfo) ProtoMessage()

func (*ShardInfo) Reset 

func (m *ShardInfo) Reset()

func (*ShardInfo) String 

func (m *ShardInfo) String() string

func (*ShardInfo) XXX_DiscardUnknown 

func (m *ShardInfo) XXX_DiscardUnknown()

func (*ShardInfo) XXX_Marshal 

func (m *ShardInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShardInfo) XXX_Merge 

func (m *ShardInfo) XXX_Merge(src proto.Message)

func (*ShardInfo) XXX_Size 

func (m *ShardInfo) XXX_Size() int

func (*ShardInfo) XXX_Unmarshal 

func (m *ShardInfo) XXX_Unmarshal(b []byte) error

type ShardKeyInfo 

type ShardKeyInfo struct {
	ShardKey             []string `protobuf:"bytes,1,rep,name=ShardKey" json:"ShardKey,omitempty"`
	Type                 *string  `protobuf:"bytes,2,opt,name=Type" json:"Type,omitempty"`
	SgID                 *uint64  `protobuf:"varint,3,opt,name=SgID" json:"SgID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ShardKeyInfo) Descriptor 

func (*ShardKeyInfo) Descriptor() ([]byte, []int)

func (*ShardKeyInfo) GetSgID 

func (m *ShardKeyInfo) GetSgID() uint64

func (*ShardKeyInfo) GetShardKey 

func (m *ShardKeyInfo) GetShardKey() []string

func (*ShardKeyInfo) GetType 

func (m *ShardKeyInfo) GetType() string

func (*ShardKeyInfo) ProtoMessage 

func (*ShardKeyInfo) ProtoMessage()

func (*ShardKeyInfo) Reset 

func (m *ShardKeyInfo) Reset()

func (*ShardKeyInfo) String 

func (m *ShardKeyInfo) String() string

func (*ShardKeyInfo) XXX_DiscardUnknown 

func (m *ShardKeyInfo) XXX_DiscardUnknown()

func (*ShardKeyInfo) XXX_Marshal 

func (m *ShardKeyInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShardKeyInfo) XXX_Merge 

func (m *ShardKeyInfo) XXX_Merge(src proto.Message)

func (*ShardKeyInfo) XXX_Size 

func (m *ShardKeyInfo) XXX_Size() int

func (*ShardKeyInfo) XXX_Unmarshal 

func (m *ShardKeyInfo) XXX_Unmarshal(b []byte) error

type ShardOwner 

type ShardOwner struct {
	NodeID               *uint64  `protobuf:"varint,1,req,name=NodeID" json:"NodeID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ShardOwner) Descriptor 

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

func (*ShardOwner) GetNodeID 

func (m *ShardOwner) GetNodeID() uint64

func (*ShardOwner) ProtoMessage 

func (*ShardOwner) ProtoMessage()

func (*ShardOwner) Reset 

func (m *ShardOwner) Reset()

func (*ShardOwner) String 

func (m *ShardOwner) String() string

func (*ShardOwner) XXX_DiscardUnknown 

func (m *ShardOwner) XXX_DiscardUnknown()

func (*ShardOwner) XXX_Marshal 

func (m *ShardOwner) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShardOwner) XXX_Merge 

func (m *ShardOwner) XXX_Merge(src proto.Message)

func (*ShardOwner) XXX_Size 

func (m *ShardOwner) XXX_Size() int

func (*ShardOwner) XXX_Unmarshal 

func (m *ShardOwner) XXX_Unmarshal(b []byte) error

type ShardStatus 

type ShardStatus struct {
	ShardID              *uint64  `protobuf:"varint,1,req,name=ShardID" json:"ShardID,omitempty"`
	ShardSize            *uint64  `protobuf:"varint,2,req,name=ShardSize" json:"ShardSize,omitempty"`
	SeriesCount          *int32   `protobuf:"varint,3,req,name=SeriesCount" json:"SeriesCount,omitempty"`
	MaxTime              *int64   `protobuf:"varint,4,req,name=MaxTime" json:"MaxTime,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ShardStatus) Descriptor 

func (*ShardStatus) Descriptor() ([]byte, []int)

func (*ShardStatus) GetMaxTime 

func (m *ShardStatus) GetMaxTime() int64

func (*ShardStatus) GetSeriesCount 

func (m *ShardStatus) GetSeriesCount() int32

func (*ShardStatus) GetShardID 

func (m *ShardStatus) GetShardID() uint64

func (*ShardStatus) GetShardSize 

func (m *ShardStatus) GetShardSize() uint64

func (*ShardStatus) ProtoMessage 

func (*ShardStatus) ProtoMessage()

func (*ShardStatus) Reset 

func (m *ShardStatus) Reset()

func (*ShardStatus) String 

func (m *ShardStatus) String() string

func (*ShardStatus) XXX_DiscardUnknown 

func (m *ShardStatus) XXX_DiscardUnknown()

func (*ShardStatus) XXX_Marshal 

func (m *ShardStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShardStatus) XXX_Merge 

func (m *ShardStatus) XXX_Merge(src proto.Message)

func (*ShardStatus) XXX_Size 

func (m *ShardStatus) XXX_Size() int

func (*ShardStatus) XXX_Unmarshal 

func (m *ShardStatus) XXX_Unmarshal(b []byte) error

type ShardTimeRangeInfo 

type ShardTimeRangeInfo struct {
	TimeRange            *TimeRangeInfo     `protobuf:"bytes,1,req,name=TimeRange" json:"TimeRange,omitempty"`
	OwnerIndex           *IndexDescriptor   `protobuf:"bytes,2,req,name=OwnerIndex" json:"OwnerIndex,omitempty"`
	ShardDuration        *ShardDurationInfo `protobuf:"bytes,3,req,name=ShardDuration" json:"ShardDuration,omitempty"`
	ShardType            *string            `protobuf:"bytes,4,opt,name=ShardType" json:"ShardType,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ShardTimeRangeInfo) Descriptor 

func (*ShardTimeRangeInfo) Descriptor() ([]byte, []int)

func (*ShardTimeRangeInfo) GetOwnerIndex 

func (m *ShardTimeRangeInfo) GetOwnerIndex() *IndexDescriptor

func (*ShardTimeRangeInfo) GetShardDuration 

func (m *ShardTimeRangeInfo) GetShardDuration() *ShardDurationInfo

func (*ShardTimeRangeInfo) GetShardType 

func (m *ShardTimeRangeInfo) GetShardType() string

func (*ShardTimeRangeInfo) GetTimeRange 

func (m *ShardTimeRangeInfo) GetTimeRange() *TimeRangeInfo

func (*ShardTimeRangeInfo) ProtoMessage 

func (*ShardTimeRangeInfo) ProtoMessage()

func (*ShardTimeRangeInfo) Reset 

func (m *ShardTimeRangeInfo) Reset()

func (*ShardTimeRangeInfo) String 

func (m *ShardTimeRangeInfo) String() string

func (*ShardTimeRangeInfo) XXX_DiscardUnknown 

func (m *ShardTimeRangeInfo) XXX_DiscardUnknown()

func (*ShardTimeRangeInfo) XXX_Marshal 

func (m *ShardTimeRangeInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShardTimeRangeInfo) XXX_Merge 

func (m *ShardTimeRangeInfo) XXX_Merge(src proto.Message)

func (*ShardTimeRangeInfo) XXX_Size 

func (m *ShardTimeRangeInfo) XXX_Size() int

func (*ShardTimeRangeInfo) XXX_Unmarshal 

func (m *ShardTimeRangeInfo) XXX_Unmarshal(b []byte) error

type Sql2MetaHeartbeatCommand 

type Sql2MetaHeartbeatCommand struct {
	Host                 *string  `protobuf:"bytes,1,req,name=Host" json:"Host,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Sql2MetaHeartbeatCommand) Descriptor 

func (*Sql2MetaHeartbeatCommand) Descriptor() ([]byte, []int)

func (*Sql2MetaHeartbeatCommand) GetHost 

func (m *Sql2MetaHeartbeatCommand) GetHost() string

func (*Sql2MetaHeartbeatCommand) ProtoMessage 

func (*Sql2MetaHeartbeatCommand) ProtoMessage()

func (*Sql2MetaHeartbeatCommand) Reset 

func (m *Sql2MetaHeartbeatCommand) Reset()

func (*Sql2MetaHeartbeatCommand) String 

func (m *Sql2MetaHeartbeatCommand) String() string

func (*Sql2MetaHeartbeatCommand) XXX_DiscardUnknown 

func (m *Sql2MetaHeartbeatCommand) XXX_DiscardUnknown()

func (*Sql2MetaHeartbeatCommand) XXX_Marshal 

func (m *Sql2MetaHeartbeatCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Sql2MetaHeartbeatCommand) XXX_Merge 

func (m *Sql2MetaHeartbeatCommand) XXX_Merge(src proto.Message)

func (*Sql2MetaHeartbeatCommand) XXX_Size 

func (m *Sql2MetaHeartbeatCommand) XXX_Size() int

func (*Sql2MetaHeartbeatCommand) XXX_Unmarshal 

func (m *Sql2MetaHeartbeatCommand) XXX_Unmarshal(b []byte) error

type StreamCall 

type StreamCall struct {
	Call                 *string  `protobuf:"bytes,1,req,name=Call" json:"Call,omitempty"`
	Field                *string  `protobuf:"bytes,2,req,name=Field" json:"Field,omitempty"`
	Alias                *string  `protobuf:"bytes,3,req,name=Alias" json:"Alias,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamCall) Descriptor 

func (*StreamCall) Descriptor() ([]byte, []int)

func (*StreamCall) GetAlias 

func (m *StreamCall) GetAlias() string

func (*StreamCall) GetCall 

func (m *StreamCall) GetCall() string

func (*StreamCall) GetField 

func (m *StreamCall) GetField() string

func (*StreamCall) ProtoMessage 

func (*StreamCall) ProtoMessage()

func (*StreamCall) Reset 

func (m *StreamCall) Reset()

func (*StreamCall) String 

func (m *StreamCall) String() string

func (*StreamCall) XXX_DiscardUnknown 

func (m *StreamCall) XXX_DiscardUnknown()

func (*StreamCall) XXX_Marshal 

func (m *StreamCall) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamCall) XXX_Merge 

func (m *StreamCall) XXX_Merge(src proto.Message)

func (*StreamCall) XXX_Size 

func (m *StreamCall) XXX_Size() int

func (*StreamCall) XXX_Unmarshal 

func (m *StreamCall) XXX_Unmarshal(b []byte) error

type StreamInfo 

type StreamInfo struct {
	Name                 *string                `protobuf:"bytes,1,req,name=Name" json:"Name,omitempty"`
	ID                   *uint64                `protobuf:"varint,2,req,name=ID" json:"ID,omitempty"`
	SrcMst               *StreamMeasurementInfo `protobuf:"bytes,3,req,name=SrcMst" json:"SrcMst,omitempty"`
	DesMst               *StreamMeasurementInfo `protobuf:"bytes,4,req,name=DesMst" json:"DesMst,omitempty"`
	Interval             *int64                 `protobuf:"varint,5,req,name=Interval" json:"Interval,omitempty"`
	Delay                *int64                 `protobuf:"varint,6,req,name=Delay" json:"Delay,omitempty"`
	Dims                 []string               `protobuf:"bytes,7,rep,name=Dims" json:"Dims,omitempty"`
	Calls                []*StreamCall          `protobuf:"bytes,8,rep,name=Calls" json:"Calls,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*StreamInfo) Descriptor 

func (*StreamInfo) Descriptor() ([]byte, []int)

func (*StreamInfo) GetCalls 

func (m *StreamInfo) GetCalls() []*StreamCall

func (*StreamInfo) GetDelay 

func (m *StreamInfo) GetDelay() int64

func (*StreamInfo) GetDesMst 

func (m *StreamInfo) GetDesMst() *StreamMeasurementInfo

func (*StreamInfo) GetDims 

func (m *StreamInfo) GetDims() []string

func (*StreamInfo) GetID 

func (m *StreamInfo) GetID() uint64

func (*StreamInfo) GetInterval 

func (m *StreamInfo) GetInterval() int64

func (*StreamInfo) GetName 

func (m *StreamInfo) GetName() string

func (*StreamInfo) GetSrcMst 

func (m *StreamInfo) GetSrcMst() *StreamMeasurementInfo

func (*StreamInfo) ProtoMessage 

func (*StreamInfo) ProtoMessage()

func (*StreamInfo) Reset 

func (m *StreamInfo) Reset()

func (*StreamInfo) String 

func (m *StreamInfo) String() string

func (*StreamInfo) XXX_DiscardUnknown 

func (m *StreamInfo) XXX_DiscardUnknown()

func (*StreamInfo) XXX_Marshal 

func (m *StreamInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamInfo) XXX_Merge 

func (m *StreamInfo) XXX_Merge(src proto.Message)

func (*StreamInfo) XXX_Size 

func (m *StreamInfo) XXX_Size() int

func (*StreamInfo) XXX_Unmarshal 

func (m *StreamInfo) XXX_Unmarshal(b []byte) error

type StreamInfos 

type StreamInfos struct {
	Infos                []*StreamInfo `protobuf:"bytes,1,rep,name=Infos" json:"Infos,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*StreamInfos) Descriptor 

func (*StreamInfos) Descriptor() ([]byte, []int)

func (*StreamInfos) GetInfos 

func (m *StreamInfos) GetInfos() []*StreamInfo

func (*StreamInfos) ProtoMessage 

func (*StreamInfos) ProtoMessage()

func (*StreamInfos) Reset 

func (m *StreamInfos) Reset()

func (*StreamInfos) String 

func (m *StreamInfos) String() string

func (*StreamInfos) XXX_DiscardUnknown 

func (m *StreamInfos) XXX_DiscardUnknown()

func (*StreamInfos) XXX_Marshal 

func (m *StreamInfos) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamInfos) XXX_Merge 

func (m *StreamInfos) XXX_Merge(src proto.Message)

func (*StreamInfos) XXX_Size 

func (m *StreamInfos) XXX_Size() int

func (*StreamInfos) XXX_Unmarshal 

func (m *StreamInfos) XXX_Unmarshal(b []byte) error

type StreamMeasurementInfo 

type StreamMeasurementInfo struct {
	Name                 *string  `protobuf:"bytes,1,req,name=Name" json:"Name,omitempty"`
	Database             *string  `protobuf:"bytes,2,req,name=Database" json:"Database,omitempty"`
	RetentionPolicy      *string  `protobuf:"bytes,3,req,name=RetentionPolicy" json:"RetentionPolicy,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamMeasurementInfo) Descriptor 

func (*StreamMeasurementInfo) Descriptor() ([]byte, []int)

func (*StreamMeasurementInfo) GetDatabase 

func (m *StreamMeasurementInfo) GetDatabase() string

func (*StreamMeasurementInfo) GetName 

func (m *StreamMeasurementInfo) GetName() string

func (*StreamMeasurementInfo) GetRetentionPolicy 

func (m *StreamMeasurementInfo) GetRetentionPolicy() string

func (*StreamMeasurementInfo) ProtoMessage 

func (*StreamMeasurementInfo) ProtoMessage()

func (*StreamMeasurementInfo) Reset 

func (m *StreamMeasurementInfo) Reset()

func (*StreamMeasurementInfo) String 

func (m *StreamMeasurementInfo) String() string

func (*StreamMeasurementInfo) XXX_DiscardUnknown 

func (m *StreamMeasurementInfo) XXX_DiscardUnknown()

func (*StreamMeasurementInfo) XXX_Marshal 

func (m *StreamMeasurementInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamMeasurementInfo) XXX_Merge 

func (m *StreamMeasurementInfo) XXX_Merge(src proto.Message)

func (*StreamMeasurementInfo) XXX_Size 

func (m *StreamMeasurementInfo) XXX_Size() int

func (*StreamMeasurementInfo) XXX_Unmarshal 

func (m *StreamMeasurementInfo) XXX_Unmarshal(b []byte) error

type SubscriptionInfo 

type SubscriptionInfo struct {
	Name                 *string  `protobuf:"bytes,1,req,name=Name" json:"Name,omitempty"`
	Mode                 *string  `protobuf:"bytes,2,req,name=Mode" json:"Mode,omitempty"`
	Destinations         []string `protobuf:"bytes,3,rep,name=Destinations" json:"Destinations,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubscriptionInfo) Descriptor 

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

func (*SubscriptionInfo) GetDestinations 

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

func (*SubscriptionInfo) GetMode 

func (m *SubscriptionInfo) GetMode() string

func (*SubscriptionInfo) GetName 

func (m *SubscriptionInfo) GetName() string

func (*SubscriptionInfo) ProtoMessage 

func (*SubscriptionInfo) ProtoMessage()

func (*SubscriptionInfo) Reset 

func (m *SubscriptionInfo) Reset()

func (*SubscriptionInfo) String 

func (m *SubscriptionInfo) String() string

func (*SubscriptionInfo) XXX_DiscardUnknown 

func (m *SubscriptionInfo) XXX_DiscardUnknown()

func (*SubscriptionInfo) XXX_Marshal 

func (m *SubscriptionInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubscriptionInfo) XXX_Merge 

func (m *SubscriptionInfo) XXX_Merge(src proto.Message)

func (*SubscriptionInfo) XXX_Size 

func (m *SubscriptionInfo) XXX_Size() int

func (*SubscriptionInfo) XXX_Unmarshal 

func (m *SubscriptionInfo) XXX_Unmarshal(b []byte) error

type TimeRangeCommand 

type TimeRangeCommand struct {
	Database             *string  `protobuf:"bytes,1,req,name=Database" json:"Database,omitempty"`
	Policy               *string  `protobuf:"bytes,2,req,name=Policy" json:"Policy,omitempty"`
	ShardID              *uint64  `protobuf:"varint,3,req,name=ShardID" json:"ShardID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TimeRangeCommand) Descriptor 

func (*TimeRangeCommand) Descriptor() ([]byte, []int)

func (*TimeRangeCommand) GetDatabase 

func (m *TimeRangeCommand) GetDatabase() string

func (*TimeRangeCommand) GetPolicy 

func (m *TimeRangeCommand) GetPolicy() string

func (*TimeRangeCommand) GetShardID 

func (m *TimeRangeCommand) GetShardID() uint64

func (*TimeRangeCommand) ProtoMessage 

func (*TimeRangeCommand) ProtoMessage()

func (*TimeRangeCommand) Reset 

func (m *TimeRangeCommand) Reset()

func (*TimeRangeCommand) String 

func (m *TimeRangeCommand) String() string

func (*TimeRangeCommand) XXX_DiscardUnknown 

func (m *TimeRangeCommand) XXX_DiscardUnknown()

func (*TimeRangeCommand) XXX_Marshal 

func (m *TimeRangeCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TimeRangeCommand) XXX_Merge 

func (m *TimeRangeCommand) XXX_Merge(src proto.Message)

func (*TimeRangeCommand) XXX_Size 

func (m *TimeRangeCommand) XXX_Size() int

func (*TimeRangeCommand) XXX_Unmarshal 

func (m *TimeRangeCommand) XXX_Unmarshal(b []byte) error

type TimeRangeInfo 

type TimeRangeInfo struct {
	StartTime            *int64   `protobuf:"varint,1,req,name=StartTime" json:"StartTime,omitempty"`
	EndTime              *int64   `protobuf:"varint,2,req,name=EndTime" json:"EndTime,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TimeRangeInfo) Descriptor 

func (*TimeRangeInfo) Descriptor() ([]byte, []int)

func (*TimeRangeInfo) GetEndTime 

func (m *TimeRangeInfo) GetEndTime() int64

func (*TimeRangeInfo) GetStartTime 

func (m *TimeRangeInfo) GetStartTime() int64

func (*TimeRangeInfo) ProtoMessage 

func (*TimeRangeInfo) ProtoMessage()

func (*TimeRangeInfo) Reset 

func (m *TimeRangeInfo) Reset()

func (*TimeRangeInfo) String 

func (m *TimeRangeInfo) String() string

func (*TimeRangeInfo) XXX_DiscardUnknown 

func (m *TimeRangeInfo) XXX_DiscardUnknown()

func (*TimeRangeInfo) XXX_Marshal 

func (m *TimeRangeInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TimeRangeInfo) XXX_Merge 

func (m *TimeRangeInfo) XXX_Merge(src proto.Message)

func (*TimeRangeInfo) XXX_Size 

func (m *TimeRangeInfo) XXX_Size() int

func (*TimeRangeInfo) XXX_Unmarshal 

func (m *TimeRangeInfo) XXX_Unmarshal(b []byte) error

type UpdateDbPtStatusCommand 

type UpdateDbPtStatusCommand struct {
	TaskID               *uint64  `protobuf:"varint,1,req,name=TaskID" json:"TaskID,omitempty"`
	NodeId               *uint64  `protobuf:"varint,2,req,name=NodeId" json:"NodeId,omitempty"`
	DB                   *string  `protobuf:"bytes,3,req,name=DB" json:"DB,omitempty"`
	PT                   *uint32  `protobuf:"varint,4,req,name=PT" json:"PT,omitempty"`
	Error                *string  `protobuf:"bytes,5,opt,name=Error" json:"Error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateDbPtStatusCommand) Descriptor 

func (*UpdateDbPtStatusCommand) Descriptor() ([]byte, []int)

func (*UpdateDbPtStatusCommand) GetDB 

func (m *UpdateDbPtStatusCommand) GetDB() string

func (*UpdateDbPtStatusCommand) GetError 

func (m *UpdateDbPtStatusCommand) GetError() string

func (*UpdateDbPtStatusCommand) GetNodeId 

func (m *UpdateDbPtStatusCommand) GetNodeId() uint64

func (*UpdateDbPtStatusCommand) GetPT 

func (m *UpdateDbPtStatusCommand) GetPT() uint32

func (*UpdateDbPtStatusCommand) GetTaskID 

func (m *UpdateDbPtStatusCommand) GetTaskID() uint64

func (*UpdateDbPtStatusCommand) ProtoMessage 

func (*UpdateDbPtStatusCommand) ProtoMessage()

func (*UpdateDbPtStatusCommand) Reset 

func (m *UpdateDbPtStatusCommand) Reset()

func (*UpdateDbPtStatusCommand) String 

func (m *UpdateDbPtStatusCommand) String() string

func (*UpdateDbPtStatusCommand) XXX_DiscardUnknown 

func (m *UpdateDbPtStatusCommand) XXX_DiscardUnknown()

func (*UpdateDbPtStatusCommand) XXX_Marshal 

func (m *UpdateDbPtStatusCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateDbPtStatusCommand) XXX_Merge 

func (m *UpdateDbPtStatusCommand) XXX_Merge(src proto.Message)

func (*UpdateDbPtStatusCommand) XXX_Size 

func (m *UpdateDbPtStatusCommand) XXX_Size() int

func (*UpdateDbPtStatusCommand) XXX_Unmarshal 

func (m *UpdateDbPtStatusCommand) XXX_Unmarshal(b []byte) error

type UpdateEventCommand 

type UpdateEventCommand struct {
	EventInfo            *MigrateEventInfo `protobuf:"bytes,1,req,name=eventInfo" json:"eventInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*UpdateEventCommand) Descriptor 

func (*UpdateEventCommand) Descriptor() ([]byte, []int)

func (*UpdateEventCommand) GetEventInfo 

func (m *UpdateEventCommand) GetEventInfo() *MigrateEventInfo

func (*UpdateEventCommand) ProtoMessage 

func (*UpdateEventCommand) ProtoMessage()

func (*UpdateEventCommand) Reset 

func (m *UpdateEventCommand) Reset()

func (*UpdateEventCommand) String 

func (m *UpdateEventCommand) String() string

func (*UpdateEventCommand) XXX_DiscardUnknown 

func (m *UpdateEventCommand) XXX_DiscardUnknown()

func (*UpdateEventCommand) XXX_Marshal 

func (m *UpdateEventCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateEventCommand) XXX_Merge 

func (m *UpdateEventCommand) XXX_Merge(src proto.Message)

func (*UpdateEventCommand) XXX_Size 

func (m *UpdateEventCommand) XXX_Size() int

func (*UpdateEventCommand) XXX_Unmarshal 

func (m *UpdateEventCommand) XXX_Unmarshal(b []byte) error

type UpdateMeasurementCommand 

type UpdateMeasurementCommand struct {
	Db                   *string  `protobuf:"bytes,1,req,name=Db" json:"Db,omitempty"`
	Rp                   *string  `protobuf:"bytes,2,req,name=Rp" json:"Rp,omitempty"`
	Mst                  *string  `protobuf:"bytes,3,req,name=Mst" json:"Mst,omitempty"`
	Options              *Options `protobuf:"bytes,4,req,name=Options" json:"Options,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateMeasurementCommand) Descriptor 

func (*UpdateMeasurementCommand) Descriptor() ([]byte, []int)

func (*UpdateMeasurementCommand) GetDb 

func (m *UpdateMeasurementCommand) GetDb() string

func (*UpdateMeasurementCommand) GetMst 

func (m *UpdateMeasurementCommand) GetMst() string

func (*UpdateMeasurementCommand) GetOptions 

func (m *UpdateMeasurementCommand) GetOptions() *Options

func (*UpdateMeasurementCommand) GetRp 

func (m *UpdateMeasurementCommand) GetRp() string

func (*UpdateMeasurementCommand) ProtoMessage 

func (*UpdateMeasurementCommand) ProtoMessage()

func (*UpdateMeasurementCommand) Reset 

func (m *UpdateMeasurementCommand) Reset()

func (*UpdateMeasurementCommand) String 

func (m *UpdateMeasurementCommand) String() string

func (*UpdateMeasurementCommand) XXX_DiscardUnknown 

func (m *UpdateMeasurementCommand) XXX_DiscardUnknown()

func (*UpdateMeasurementCommand) XXX_Marshal 

func (m *UpdateMeasurementCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateMeasurementCommand) XXX_Merge 

func (m *UpdateMeasurementCommand) XXX_Merge(src proto.Message)

func (*UpdateMeasurementCommand) XXX_Size 

func (m *UpdateMeasurementCommand) XXX_Size() int

func (*UpdateMeasurementCommand) XXX_Unmarshal 

func (m *UpdateMeasurementCommand) XXX_Unmarshal(b []byte) error

type UpdateNodeStatusCommand 

type UpdateNodeStatusCommand struct {
	ID                   *uint64  `protobuf:"varint,1,req,name=ID" json:"ID,omitempty"`
	Status               *int32   `protobuf:"varint,2,req,name=Status" json:"Status,omitempty"`
	Ltime                *uint64  `protobuf:"varint,3,req,name=Ltime" json:"Ltime,omitempty"`
	GossipAddr           *string  `protobuf:"bytes,4,req,name=GossipAddr" json:"GossipAddr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateNodeStatusCommand) Descriptor 

func (*UpdateNodeStatusCommand) Descriptor() ([]byte, []int)

func (*UpdateNodeStatusCommand) GetGossipAddr 

func (m *UpdateNodeStatusCommand) GetGossipAddr() string

func (*UpdateNodeStatusCommand) GetID 

func (m *UpdateNodeStatusCommand) GetID() uint64

func (*UpdateNodeStatusCommand) GetLtime 

func (m *UpdateNodeStatusCommand) GetLtime() uint64

func (*UpdateNodeStatusCommand) GetStatus 

func (m *UpdateNodeStatusCommand) GetStatus() int32

func (*UpdateNodeStatusCommand) ProtoMessage 

func (*UpdateNodeStatusCommand) ProtoMessage()

func (*UpdateNodeStatusCommand) Reset 

func (m *UpdateNodeStatusCommand) Reset()

func (*UpdateNodeStatusCommand) String 

func (m *UpdateNodeStatusCommand) String() string

func (*UpdateNodeStatusCommand) XXX_DiscardUnknown 

func (m *UpdateNodeStatusCommand) XXX_DiscardUnknown()

func (*UpdateNodeStatusCommand) XXX_Marshal 

func (m *UpdateNodeStatusCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateNodeStatusCommand) XXX_Merge 

func (m *UpdateNodeStatusCommand) XXX_Merge(src proto.Message)

func (*UpdateNodeStatusCommand) XXX_Size 

func (m *UpdateNodeStatusCommand) XXX_Size() int

func (*UpdateNodeStatusCommand) XXX_Unmarshal 

func (m *UpdateNodeStatusCommand) XXX_Unmarshal(b []byte) error

type UpdatePtInfoCommand 

type UpdatePtInfoCommand struct {
	Db                   *string  `protobuf:"bytes,1,req,name=Db" json:"Db,omitempty"`
	Pt                   *PtInfo  `protobuf:"bytes,2,req,name=Pt" json:"Pt,omitempty"`
	OwnerNode            *uint64  `protobuf:"varint,3,opt,name=OwnerNode" json:"OwnerNode,omitempty"`
	Status               *uint32  `protobuf:"varint,4,opt,name=Status" json:"Status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdatePtInfoCommand) Descriptor 

func (*UpdatePtInfoCommand) Descriptor() ([]byte, []int)

func (*UpdatePtInfoCommand) GetDb 

func (m *UpdatePtInfoCommand) GetDb() string

func (*UpdatePtInfoCommand) GetOwnerNode 

func (m *UpdatePtInfoCommand) GetOwnerNode() uint64

func (*UpdatePtInfoCommand) GetPt 

func (m *UpdatePtInfoCommand) GetPt() *PtInfo

func (*UpdatePtInfoCommand) GetStatus 

func (m *UpdatePtInfoCommand) GetStatus() uint32

func (*UpdatePtInfoCommand) ProtoMessage 

func (*UpdatePtInfoCommand) ProtoMessage()

func (*UpdatePtInfoCommand) Reset 

func (m *UpdatePtInfoCommand) Reset()

func (*UpdatePtInfoCommand) String 

func (m *UpdatePtInfoCommand) String() string

func (*UpdatePtInfoCommand) XXX_DiscardUnknown 

func (m *UpdatePtInfoCommand) XXX_DiscardUnknown()

func (*UpdatePtInfoCommand) XXX_Marshal 

func (m *UpdatePtInfoCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdatePtInfoCommand) XXX_Merge 

func (m *UpdatePtInfoCommand) XXX_Merge(src proto.Message)

func (*UpdatePtInfoCommand) XXX_Size 

func (m *UpdatePtInfoCommand) XXX_Size() int

func (*UpdatePtInfoCommand) XXX_Unmarshal 

func (m *UpdatePtInfoCommand) XXX_Unmarshal(b []byte) error

type UpdatePtVersionCommand 

type UpdatePtVersionCommand struct {
	Db                   *string  `protobuf:"bytes,1,req,name=Db" json:"Db,omitempty"`
	Pt                   *uint32  `protobuf:"varint,2,req,name=Pt" json:"Pt,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdatePtVersionCommand) Descriptor 

func (*UpdatePtVersionCommand) Descriptor() ([]byte, []int)

func (*UpdatePtVersionCommand) GetDb 

func (m *UpdatePtVersionCommand) GetDb() string

func (*UpdatePtVersionCommand) GetPt 

func (m *UpdatePtVersionCommand) GetPt() uint32

func (*UpdatePtVersionCommand) ProtoMessage 

func (*UpdatePtVersionCommand) ProtoMessage()

func (*UpdatePtVersionCommand) Reset 

func (m *UpdatePtVersionCommand) Reset()

func (*UpdatePtVersionCommand) String 

func (m *UpdatePtVersionCommand) String() string

func (*UpdatePtVersionCommand) XXX_DiscardUnknown 

func (m *UpdatePtVersionCommand) XXX_DiscardUnknown()

func (*UpdatePtVersionCommand) XXX_Marshal 

func (m *UpdatePtVersionCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdatePtVersionCommand) XXX_Merge 

func (m *UpdatePtVersionCommand) XXX_Merge(src proto.Message)

func (*UpdatePtVersionCommand) XXX_Size 

func (m *UpdatePtVersionCommand) XXX_Size() int

func (*UpdatePtVersionCommand) XXX_Unmarshal 

func (m *UpdatePtVersionCommand) XXX_Unmarshal(b []byte) error

type UpdateReplicationCommand 

type UpdateReplicationCommand struct {
	Database             *string  `protobuf:"bytes,1,req,name=database" json:"database,omitempty"`
	RepGroupId           *uint32  `protobuf:"varint,2,req,name=repGroupId" json:"repGroupId,omitempty"`
	MasterId             *uint32  `protobuf:"varint,3,opt,name=masterId" json:"masterId,omitempty"`
	Peers                []*Peer  `protobuf:"bytes,4,rep,name=Peers" json:"Peers,omitempty"`
	RgStatus             *uint32  `protobuf:"varint,5,opt,name=rgStatus" json:"rgStatus,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateReplicationCommand) Descriptor 

func (*UpdateReplicationCommand) Descriptor() ([]byte, []int)

func (*UpdateReplicationCommand) GetDatabase 

func (m *UpdateReplicationCommand) GetDatabase() string

func (*UpdateReplicationCommand) GetMasterId 

func (m *UpdateReplicationCommand) GetMasterId() uint32

func (*UpdateReplicationCommand) GetPeers 

func (m *UpdateReplicationCommand) GetPeers() []*Peer

func (*UpdateReplicationCommand) GetRepGroupId 

func (m *UpdateReplicationCommand) GetRepGroupId() uint32

func (*UpdateReplicationCommand) GetRgStatus 

func (m *UpdateReplicationCommand) GetRgStatus() uint32

func (*UpdateReplicationCommand) ProtoMessage 

func (*UpdateReplicationCommand) ProtoMessage()

func (*UpdateReplicationCommand) Reset 

func (m *UpdateReplicationCommand) Reset()

func (*UpdateReplicationCommand) String 

func (m *UpdateReplicationCommand) String() string

func (*UpdateReplicationCommand) XXX_DiscardUnknown 

func (m *UpdateReplicationCommand) XXX_DiscardUnknown()

func (*UpdateReplicationCommand) XXX_Marshal 

func (m *UpdateReplicationCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateReplicationCommand) XXX_Merge 

func (m *UpdateReplicationCommand) XXX_Merge(src proto.Message)

func (*UpdateReplicationCommand) XXX_Size 

func (m *UpdateReplicationCommand) XXX_Size() int

func (*UpdateReplicationCommand) XXX_Unmarshal 

func (m *UpdateReplicationCommand) XXX_Unmarshal(b []byte) error

type UpdateRetentionPolicyCommand 

type UpdateRetentionPolicyCommand struct {
	Database             *string  `protobuf:"bytes,1,req,name=Database" json:"Database,omitempty"`
	Name                 *string  `protobuf:"bytes,2,req,name=Name" json:"Name,omitempty"`
	NewName              *string  `protobuf:"bytes,3,opt,name=NewName" json:"NewName,omitempty"`
	Duration             *int64   `protobuf:"varint,4,opt,name=Duration" json:"Duration,omitempty"`
	ReplicaN             *uint32  `protobuf:"varint,5,opt,name=ReplicaN" json:"ReplicaN,omitempty"`
	ShardGroupDuration   *int64   `protobuf:"varint,6,opt,name=ShardGroupDuration" json:"ShardGroupDuration,omitempty"`
	MakeDefault          *bool    `protobuf:"varint,7,req,name=MakeDefault" json:"MakeDefault,omitempty"`
	HotDuration          *int64   `protobuf:"varint,9,opt,name=HotDuration" json:"HotDuration,omitempty"`
	WarmDuration         *int64   `protobuf:"varint,10,opt,name=WarmDuration" json:"WarmDuration,omitempty"`
	IndexGroupDuration   *int64   `protobuf:"varint,11,opt,name=IndexGroupDuration" json:"IndexGroupDuration,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateRetentionPolicyCommand) Descriptor 

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

func (*UpdateRetentionPolicyCommand) GetDatabase 

func (m *UpdateRetentionPolicyCommand) GetDatabase() string

func (*UpdateRetentionPolicyCommand) GetDuration 

func (m *UpdateRetentionPolicyCommand) GetDuration() int64

func (*UpdateRetentionPolicyCommand) GetHotDuration 

func (m *UpdateRetentionPolicyCommand) GetHotDuration() int64

func (*UpdateRetentionPolicyCommand) GetIndexGroupDuration 

func (m *UpdateRetentionPolicyCommand) GetIndexGroupDuration() int64

func (*UpdateRetentionPolicyCommand) GetMakeDefault 

func (m *UpdateRetentionPolicyCommand) GetMakeDefault() bool

func (*UpdateRetentionPolicyCommand) GetName 

func (m *UpdateRetentionPolicyCommand) GetName() string

func (*UpdateRetentionPolicyCommand) GetNewName 

func (m *UpdateRetentionPolicyCommand) GetNewName() string

func (*UpdateRetentionPolicyCommand) GetReplicaN 

func (m *UpdateRetentionPolicyCommand) GetReplicaN() uint32

func (*UpdateRetentionPolicyCommand) GetShardGroupDuration 

func (m *UpdateRetentionPolicyCommand) GetShardGroupDuration() int64

func (*UpdateRetentionPolicyCommand) GetWarmDuration 

func (m *UpdateRetentionPolicyCommand) GetWarmDuration() int64

func (*UpdateRetentionPolicyCommand) ProtoMessage 

func (*UpdateRetentionPolicyCommand) ProtoMessage()

func (*UpdateRetentionPolicyCommand) Reset 

func (m *UpdateRetentionPolicyCommand) Reset()

func (*UpdateRetentionPolicyCommand) String 

func (m *UpdateRetentionPolicyCommand) String() string

func (*UpdateRetentionPolicyCommand) XXX_DiscardUnknown 

func (m *UpdateRetentionPolicyCommand) XXX_DiscardUnknown()

func (*UpdateRetentionPolicyCommand) XXX_Marshal 

func (m *UpdateRetentionPolicyCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateRetentionPolicyCommand) XXX_Merge 

func (m *UpdateRetentionPolicyCommand) XXX_Merge(src proto.Message)

func (*UpdateRetentionPolicyCommand) XXX_Size 

func (m *UpdateRetentionPolicyCommand) XXX_Size() int

func (*UpdateRetentionPolicyCommand) XXX_Unmarshal 

func (m *UpdateRetentionPolicyCommand) XXX_Unmarshal(b []byte) error

type UpdateSchemaCommand 

type UpdateSchemaCommand struct {
	Database             *string        `protobuf:"bytes,1,req,name=Database" json:"Database,omitempty"`
	RpName               *string        `protobuf:"bytes,2,req,name=RpName" json:"RpName,omitempty"`
	Measurement          *string        `protobuf:"bytes,3,req,name=Measurement" json:"Measurement,omitempty"`
	FieldToCreate        []*FieldSchema `protobuf:"bytes,4,rep,name=FieldToCreate" json:"FieldToCreate,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*UpdateSchemaCommand) Descriptor 

func (*UpdateSchemaCommand) Descriptor() ([]byte, []int)

func (*UpdateSchemaCommand) GetDatabase 

func (m *UpdateSchemaCommand) GetDatabase() string

func (*UpdateSchemaCommand) GetFieldToCreate 

func (m *UpdateSchemaCommand) GetFieldToCreate() []*FieldSchema

func (*UpdateSchemaCommand) GetMeasurement 

func (m *UpdateSchemaCommand) GetMeasurement() string

func (*UpdateSchemaCommand) GetRpName 

func (m *UpdateSchemaCommand) GetRpName() string

func (*UpdateSchemaCommand) ProtoMessage 

func (*UpdateSchemaCommand) ProtoMessage()

func (*UpdateSchemaCommand) Reset 

func (m *UpdateSchemaCommand) Reset()

func (*UpdateSchemaCommand) String 

func (m *UpdateSchemaCommand) String() string

func (*UpdateSchemaCommand) XXX_DiscardUnknown 

func (m *UpdateSchemaCommand) XXX_DiscardUnknown()

func (*UpdateSchemaCommand) XXX_Marshal 

func (m *UpdateSchemaCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateSchemaCommand) XXX_Merge 

func (m *UpdateSchemaCommand) XXX_Merge(src proto.Message)

func (*UpdateSchemaCommand) XXX_Size 

func (m *UpdateSchemaCommand) XXX_Size() int

func (*UpdateSchemaCommand) XXX_Unmarshal 

func (m *UpdateSchemaCommand) XXX_Unmarshal(b []byte) error

type UpdateShardDownSampleInfoCommand 

type UpdateShardDownSampleInfoCommand struct {
	Ident                *ShardIdentifier `protobuf:"bytes,1,req,name=Ident" json:"Ident,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*UpdateShardDownSampleInfoCommand) Descriptor 

func (*UpdateShardDownSampleInfoCommand) Descriptor() ([]byte, []int)

func (*UpdateShardDownSampleInfoCommand) GetIdent 

func (m *UpdateShardDownSampleInfoCommand) GetIdent() *ShardIdentifier

func (*UpdateShardDownSampleInfoCommand) ProtoMessage 

func (*UpdateShardDownSampleInfoCommand) ProtoMessage()

func (*UpdateShardDownSampleInfoCommand) Reset 

func (m *UpdateShardDownSampleInfoCommand) Reset()

func (*UpdateShardDownSampleInfoCommand) String 

func (m *UpdateShardDownSampleInfoCommand) String() string

func (*UpdateShardDownSampleInfoCommand) XXX_DiscardUnknown 

func (m *UpdateShardDownSampleInfoCommand) XXX_DiscardUnknown()

func (*UpdateShardDownSampleInfoCommand) XXX_Marshal 

func (m *UpdateShardDownSampleInfoCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateShardDownSampleInfoCommand) XXX_Merge 

func (m *UpdateShardDownSampleInfoCommand) XXX_Merge(src proto.Message)

func (*UpdateShardDownSampleInfoCommand) XXX_Size 

func (m *UpdateShardDownSampleInfoCommand) XXX_Size() int

func (*UpdateShardDownSampleInfoCommand) XXX_Unmarshal 

func (m *UpdateShardDownSampleInfoCommand) XXX_Unmarshal(b []byte) error

type UpdateShardInfoTierCommand 

type UpdateShardInfoTierCommand struct {
	ShardID              *uint64  `protobuf:"varint,1,req,name=ShardID" json:"ShardID,omitempty"`
	Tier                 *uint64  `protobuf:"varint,2,req,name=Tier" json:"Tier,omitempty"`
	DbName               *string  `protobuf:"bytes,3,req,name=DbName" json:"DbName,omitempty"`
	RpName               *string  `protobuf:"bytes,4,req,name=RpName" json:"RpName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateShardInfoTierCommand) Descriptor 

func (*UpdateShardInfoTierCommand) Descriptor() ([]byte, []int)

func (*UpdateShardInfoTierCommand) GetDbName 

func (m *UpdateShardInfoTierCommand) GetDbName() string

func (*UpdateShardInfoTierCommand) GetRpName 

func (m *UpdateShardInfoTierCommand) GetRpName() string

func (*UpdateShardInfoTierCommand) GetShardID 

func (m *UpdateShardInfoTierCommand) GetShardID() uint64

func (*UpdateShardInfoTierCommand) GetTier 

func (m *UpdateShardInfoTierCommand) GetTier() uint64

func (*UpdateShardInfoTierCommand) ProtoMessage 

func (*UpdateShardInfoTierCommand) ProtoMessage()

func (*UpdateShardInfoTierCommand) Reset 

func (m *UpdateShardInfoTierCommand) Reset()

func (*UpdateShardInfoTierCommand) String 

func (m *UpdateShardInfoTierCommand) String() string

func (*UpdateShardInfoTierCommand) XXX_DiscardUnknown 

func (m *UpdateShardInfoTierCommand) XXX_DiscardUnknown()

func (*UpdateShardInfoTierCommand) XXX_Marshal 

func (m *UpdateShardInfoTierCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateShardInfoTierCommand) XXX_Merge 

func (m *UpdateShardInfoTierCommand) XXX_Merge(src proto.Message)

func (*UpdateShardInfoTierCommand) XXX_Size 

func (m *UpdateShardInfoTierCommand) XXX_Size() int

func (*UpdateShardInfoTierCommand) XXX_Unmarshal 

func (m *UpdateShardInfoTierCommand) XXX_Unmarshal(b []byte) error

type UpdateShardOwnerCommand 

type UpdateShardOwnerCommand struct {
	ShardId              *int64   `protobuf:"varint,1,req,name=ShardId" json:"ShardId,omitempty"`
	OwnerId              *int64   `protobuf:"varint,2,req,name=OwnerId" json:"OwnerId,omitempty"`
	DbName               *string  `protobuf:"bytes,3,req,name=DbName" json:"DbName,omitempty"`
	RpName               *string  `protobuf:"bytes,4,req,name=RpName" json:"RpName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateShardOwnerCommand) Descriptor 

func (*UpdateShardOwnerCommand) Descriptor() ([]byte, []int)

func (*UpdateShardOwnerCommand) GetDbName 

func (m *UpdateShardOwnerCommand) GetDbName() string

func (*UpdateShardOwnerCommand) GetOwnerId 

func (m *UpdateShardOwnerCommand) GetOwnerId() int64

func (*UpdateShardOwnerCommand) GetRpName 

func (m *UpdateShardOwnerCommand) GetRpName() string

func (*UpdateShardOwnerCommand) GetShardId 

func (m *UpdateShardOwnerCommand) GetShardId() int64

func (*UpdateShardOwnerCommand) ProtoMessage 

func (*UpdateShardOwnerCommand) ProtoMessage()

func (*UpdateShardOwnerCommand) Reset 

func (m *UpdateShardOwnerCommand) Reset()

func (*UpdateShardOwnerCommand) String 

func (m *UpdateShardOwnerCommand) String() string

func (*UpdateShardOwnerCommand) XXX_DiscardUnknown 

func (m *UpdateShardOwnerCommand) XXX_DiscardUnknown()

func (*UpdateShardOwnerCommand) XXX_Marshal 

func (m *UpdateShardOwnerCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateShardOwnerCommand) XXX_Merge 

func (m *UpdateShardOwnerCommand) XXX_Merge(src proto.Message)

func (*UpdateShardOwnerCommand) XXX_Size 

func (m *UpdateShardOwnerCommand) XXX_Size() int

func (*UpdateShardOwnerCommand) XXX_Unmarshal 

func (m *UpdateShardOwnerCommand) XXX_Unmarshal(b []byte) error

type UpdateUserCommand 

type UpdateUserCommand struct {
	Name                 *string  `protobuf:"bytes,1,req,name=Name" json:"Name,omitempty"`
	Hash                 *string  `protobuf:"bytes,2,req,name=Hash" json:"Hash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateUserCommand) Descriptor 

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

func (*UpdateUserCommand) GetHash 

func (m *UpdateUserCommand) GetHash() string

func (*UpdateUserCommand) GetName 

func (m *UpdateUserCommand) GetName() string

func (*UpdateUserCommand) ProtoMessage 

func (*UpdateUserCommand) ProtoMessage()

func (*UpdateUserCommand) Reset 

func (m *UpdateUserCommand) Reset()

func (*UpdateUserCommand) String 

func (m *UpdateUserCommand) String() string

func (*UpdateUserCommand) XXX_DiscardUnknown 

func (m *UpdateUserCommand) XXX_DiscardUnknown()

func (*UpdateUserCommand) XXX_Marshal 

func (m *UpdateUserCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateUserCommand) XXX_Merge 

func (m *UpdateUserCommand) XXX_Merge(src proto.Message)

func (*UpdateUserCommand) XXX_Size 

func (m *UpdateUserCommand) XXX_Size() int

func (*UpdateUserCommand) XXX_Unmarshal 

func (m *UpdateUserCommand) XXX_Unmarshal(b []byte) error

type UserInfo 

type UserInfo struct {
	Name                 *string          `protobuf:"bytes,1,req,name=Name" json:"Name,omitempty"`
	Hash                 *string          `protobuf:"bytes,2,req,name=Hash" json:"Hash,omitempty"`
	Admin                *bool            `protobuf:"varint,3,req,name=Admin" json:"Admin,omitempty"`
	RwUser               *bool            `protobuf:"varint,4,opt,name=RwUser" json:"RwUser,omitempty"`
	Privileges           []*UserPrivilege `protobuf:"bytes,5,rep,name=Privileges" json:"Privileges,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*UserInfo) Descriptor 

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

func (*UserInfo) GetAdmin 

func (m *UserInfo) GetAdmin() bool

func (*UserInfo) GetHash 

func (m *UserInfo) GetHash() string

func (*UserInfo) GetName 

func (m *UserInfo) GetName() string

func (*UserInfo) GetPrivileges 

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

func (*UserInfo) GetRwUser 

func (m *UserInfo) GetRwUser() bool

func (*UserInfo) ProtoMessage 

func (*UserInfo) ProtoMessage()

func (*UserInfo) Reset 

func (m *UserInfo) Reset()

func (*UserInfo) String 

func (m *UserInfo) String() string

func (*UserInfo) XXX_DiscardUnknown 

func (m *UserInfo) XXX_DiscardUnknown()

func (*UserInfo) XXX_Marshal 

func (m *UserInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UserInfo) XXX_Merge 

func (m *UserInfo) XXX_Merge(src proto.Message)

func (*UserInfo) XXX_Size 

func (m *UserInfo) XXX_Size() int

func (*UserInfo) XXX_Unmarshal 

func (m *UserInfo) XXX_Unmarshal(b []byte) error

type UserPrivilege 

type UserPrivilege struct {
	Database             *string  `protobuf:"bytes,1,req,name=Database" json:"Database,omitempty"`
	Privilege            *int32   `protobuf:"varint,2,req,name=Privilege" json:"Privilege,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UserPrivilege) Descriptor 

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

func (*UserPrivilege) GetDatabase 

func (m *UserPrivilege) GetDatabase() string

func (*UserPrivilege) GetPrivilege 

func (m *UserPrivilege) GetPrivilege() int32

func (*UserPrivilege) ProtoMessage 

func (*UserPrivilege) ProtoMessage()

func (*UserPrivilege) Reset 

func (m *UserPrivilege) Reset()

func (*UserPrivilege) String 

func (m *UserPrivilege) String() string

func (*UserPrivilege) XXX_DiscardUnknown 

func (m *UserPrivilege) XXX_DiscardUnknown()

func (*UserPrivilege) XXX_Marshal 

func (m *UserPrivilege) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UserPrivilege) XXX_Merge 

func (m *UserPrivilege) XXX_Merge(src proto.Message)

func (*UserPrivilege) XXX_Size 

func (m *UserPrivilege) XXX_Size() int

func (*UserPrivilege) XXX_Unmarshal 

func (m *UserPrivilege) XXX_Unmarshal(b []byte) error

type VerifyDataNodeCommand 

type VerifyDataNodeCommand struct {
	NodeID               *uint64  `protobuf:"varint,1,req,name=NodeID" json:"NodeID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VerifyDataNodeCommand) Descriptor 

func (*VerifyDataNodeCommand) Descriptor() ([]byte, []int)

func (*VerifyDataNodeCommand) GetNodeID 

func (m *VerifyDataNodeCommand) GetNodeID() uint64

func (*VerifyDataNodeCommand) ProtoMessage 

func (*VerifyDataNodeCommand) ProtoMessage()

func (*VerifyDataNodeCommand) Reset 

func (m *VerifyDataNodeCommand) Reset()

func (*VerifyDataNodeCommand) String 

func (m *VerifyDataNodeCommand) String() string

func (*VerifyDataNodeCommand) XXX_DiscardUnknown 

func (m *VerifyDataNodeCommand) XXX_DiscardUnknown()

func (*VerifyDataNodeCommand) XXX_Marshal 

func (m *VerifyDataNodeCommand) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VerifyDataNodeCommand) XXX_Merge 

func (m *VerifyDataNodeCommand) XXX_Merge(src proto.Message)

func (*VerifyDataNodeCommand) XXX_Size 

func (m *VerifyDataNodeCommand) XXX_Size() int

func (*VerifyDataNodeCommand) XXX_Unmarshal 

func (m *VerifyDataNodeCommand) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.