meta

package
v1.0.3 Latest Latest
Warning

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

 Go to latest Published: Jun 17, 2022 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Command_Type_name = map[int32]string{
	1:  "CreateNodeCommand",
	2:  "DeleteNodeCommand",
	3:  "CreateDatabaseCommand",
	4:  "DropDatabaseCommand",
	5:  "CreateRetentionPolicyCommand",
	6:  "DropRetentionPolicyCommand",
	7:  "SetDefaultRetentionPolicyCommand",
	8:  "UpdateRetentionPolicyCommand",
	9:  "CreateShardGroupCommand",
	10: "DeleteShardGroupCommand",
	11: "CreateContinuousQueryCommand",
	12: "DropContinuousQueryCommand",
	13: "CreateUserCommand",
	14: "DropUserCommand",
	15: "UpdateUserCommand",
	16: "SetPrivilegeCommand",
	17: "SetDataCommand",
	18: "SetAdminPrivilegeCommand",
	19: "UpdateNodeCommand",
	21: "CreateSubscriptionCommand",
	22: "DropSubscriptionCommand",
	23: "RemovePeerCommand",
	24: "CreateMetaNodeCommand",
	25: "CreateDataNodeCommand",
	26: "UpdateDataNodeCommand",
	27: "DeleteMetaNodeCommand",
	28: "DeleteDataNodeCommand",
	29: "SetMetaNodeCommand",
	30: "DropShardCommand",
	31: "UpdateShardOwnersCommand",
	32: "TruncatedShardsCommand",
}
View Source 
var Command_Type_value = map[string]int32{
	"CreateNodeCommand":                1,
	"DeleteNodeCommand":                2,
	"CreateDatabaseCommand":            3,
	"DropDatabaseCommand":              4,
	"CreateRetentionPolicyCommand":     5,
	"DropRetentionPolicyCommand":       6,
	"SetDefaultRetentionPolicyCommand": 7,
	"UpdateRetentionPolicyCommand":     8,
	"CreateShardGroupCommand":          9,
	"DeleteShardGroupCommand":          10,
	"CreateContinuousQueryCommand":     11,
	"DropContinuousQueryCommand":       12,
	"CreateUserCommand":                13,
	"DropUserCommand":                  14,
	"UpdateUserCommand":                15,
	"SetPrivilegeCommand":              16,
	"SetDataCommand":                   17,
	"SetAdminPrivilegeCommand":         18,
	"UpdateNodeCommand":                19,
	"CreateSubscriptionCommand":        21,
	"DropSubscriptionCommand":          22,
	"RemovePeerCommand":                23,
	"CreateMetaNodeCommand":            24,
	"CreateDataNodeCommand":            25,
	"UpdateDataNodeCommand":            26,
	"DeleteMetaNodeCommand":            27,
	"DeleteDataNodeCommand":            28,
	"SetMetaNodeCommand":               29,
	"DropShardCommand":                 30,
	"UpdateShardOwnersCommand":         31,
	"TruncatedShardsCommand":           32,
}
View Source 
var E_CreateContinuousQueryCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*CreateContinuousQueryCommand)(nil),
	Field:         111,
	Name:          "meta.CreateContinuousQueryCommand.command",
	Tag:           "bytes,111,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_CreateDataNodeCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*CreateDataNodeCommand)(nil),
	Field:         125,
	Name:          "meta.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:          "meta.CreateDatabaseCommand.command",
	Tag:           "bytes,103,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_CreateMetaNodeCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*CreateMetaNodeCommand)(nil),
	Field:         124,
	Name:          "meta.CreateMetaNodeCommand.command",
	Tag:           "bytes,124,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_CreateNodeCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*CreateNodeCommand)(nil),
	Field:         101,
	Name:          "meta.CreateNodeCommand.command",
	Tag:           "bytes,101,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_CreateRetentionPolicyCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*CreateRetentionPolicyCommand)(nil),
	Field:         105,
	Name:          "meta.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:          "meta.CreateShardGroupCommand.command",
	Tag:           "bytes,109,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_CreateSubscriptionCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*CreateSubscriptionCommand)(nil),
	Field:         121,
	Name:          "meta.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:          "meta.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:          "meta.DeleteDataNodeCommand.command",
	Tag:           "bytes,128,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_DeleteMetaNodeCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*DeleteMetaNodeCommand)(nil),
	Field:         127,
	Name:          "meta.DeleteMetaNodeCommand.command",
	Tag:           "bytes,127,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_DeleteNodeCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*DeleteNodeCommand)(nil),
	Field:         102,
	Name:          "meta.DeleteNodeCommand.command",
	Tag:           "bytes,102,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_DeleteShardGroupCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*DeleteShardGroupCommand)(nil),
	Field:         110,
	Name:          "meta.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:         112,
	Name:          "meta.DropContinuousQueryCommand.command",
	Tag:           "bytes,112,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_DropDatabaseCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*DropDatabaseCommand)(nil),
	Field:         104,
	Name:          "meta.DropDatabaseCommand.command",
	Tag:           "bytes,104,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_DropRetentionPolicyCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*DropRetentionPolicyCommand)(nil),
	Field:         106,
	Name:          "meta.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:          "meta.DropShardCommand.command",
	Tag:           "bytes,130,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_DropSubscriptionCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*DropSubscriptionCommand)(nil),
	Field:         122,
	Name:          "meta.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:          "meta.DropUserCommand.command",
	Tag:           "bytes,114,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_RemovePeerCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*RemovePeerCommand)(nil),
	Field:         123,
	Name:          "meta.RemovePeerCommand.command",
	Tag:           "bytes,123,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_SetAdminPrivilegeCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*SetAdminPrivilegeCommand)(nil),
	Field:         118,
	Name:          "meta.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:          "meta.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:          "meta.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:          "meta.SetMetaNodeCommand.command",
	Tag:           "bytes,129,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_SetPrivilegeCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*SetPrivilegeCommand)(nil),
	Field:         116,
	Name:          "meta.SetPrivilegeCommand.command",
	Tag:           "bytes,116,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_TruncatedShardsCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*TruncatedShardsCommand)(nil),
	Field:         132,
	Name:          "meta.TruncatedShardsCommand.command",
	Tag:           "bytes,132,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_UpdateDataNodeCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*UpdateDataNodeCommand)(nil),
	Field:         126,
	Name:          "meta.UpdateDataNodeCommand.command",
	Tag:           "bytes,126,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_UpdateNodeCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*UpdateNodeCommand)(nil),
	Field:         119,
	Name:          "meta.UpdateNodeCommand.command",
	Tag:           "bytes,119,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_UpdateRetentionPolicyCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*UpdateRetentionPolicyCommand)(nil),
	Field:         108,
	Name:          "meta.UpdateRetentionPolicyCommand.command",
	Tag:           "bytes,108,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_UpdateShardOwnersCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*UpdateShardOwnersCommand)(nil),
	Field:         131,
	Name:          "meta.UpdateShardOwnersCommand.command",
	Tag:           "bytes,131,opt,name=command",
	Filename:      "meta.proto",
}
View Source 
var E_UpdateUserCommand_Command = &proto.ExtensionDesc{
	ExtendedType:  (*Command)(nil),
	ExtensionType: (*UpdateUserCommand)(nil),
	Field:         115,
	Name:          "meta.UpdateUserCommand.command",
	Tag:           "bytes,115,opt,name=command",
	Filename:      "meta.proto",
}

Functions

This section is empty.

Types

type Command 

type Command struct {
	Type                         *Command_Type `protobuf:"varint,1,req,name=type,enum=meta.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_CreateNodeCommand                Command_Type = 1
	Command_DeleteNodeCommand                Command_Type = 2
	Command_CreateDatabaseCommand            Command_Type = 3
	Command_DropDatabaseCommand              Command_Type = 4
	Command_CreateRetentionPolicyCommand     Command_Type = 5
	Command_DropRetentionPolicyCommand       Command_Type = 6
	Command_SetDefaultRetentionPolicyCommand Command_Type = 7
	Command_UpdateRetentionPolicyCommand     Command_Type = 8
	Command_CreateShardGroupCommand          Command_Type = 9
	Command_DeleteShardGroupCommand          Command_Type = 10
	Command_CreateContinuousQueryCommand     Command_Type = 11
	Command_DropContinuousQueryCommand       Command_Type = 12
	Command_CreateUserCommand                Command_Type = 13
	Command_DropUserCommand                  Command_Type = 14
	Command_UpdateUserCommand                Command_Type = 15
	Command_SetPrivilegeCommand              Command_Type = 16
	Command_SetDataCommand                   Command_Type = 17
	Command_SetAdminPrivilegeCommand         Command_Type = 18
	Command_UpdateNodeCommand                Command_Type = 19
	Command_CreateSubscriptionCommand        Command_Type = 21
	Command_DropSubscriptionCommand          Command_Type = 22
	Command_RemovePeerCommand                Command_Type = 23
	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_UpdateShardOwnersCommand         Command_Type = 31
	Command_TruncatedShardsCommand           Command_Type = 32
)

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ContinuousQueryInfo) Descriptor 

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

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 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"`
	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) 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"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*CreateDatabaseCommand) Descriptor 

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

func (*CreateDatabaseCommand) GetName 

func (m *CreateDatabaseCommand) GetName() string

func (*CreateDatabaseCommand) GetRetentionPolicy 

func (m *CreateDatabaseCommand) GetRetentionPolicy() *RetentionPolicyInfo

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 CreateMetaNodeCommand 

type CreateMetaNodeCommand struct {
	HTTPAddr             *string  `protobuf:"bytes,1,req,name=HTTPAddr" json:"HTTPAddr,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) 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 CreateNodeCommand 

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

This isn't used in >= 0.10.0. Kept around for upgrade purposes. Instead look at CreateDataNodeCommand and CreateMetaNodeCommand

func (*CreateNodeCommand) Descriptor 

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

func (*CreateNodeCommand) GetHost 

func (m *CreateNodeCommand) GetHost() string

func (*CreateNodeCommand) GetRand 

func (m *CreateNodeCommand) GetRand() uint64

func (*CreateNodeCommand) ProtoMessage 

func (*CreateNodeCommand) ProtoMessage()

func (*CreateNodeCommand) Reset 

func (m *CreateNodeCommand) Reset()

func (*CreateNodeCommand) String 

func (m *CreateNodeCommand) String() string

func (*CreateNodeCommand) XXX_DiscardUnknown 

func (m *CreateNodeCommand) XXX_DiscardUnknown()

func (*CreateNodeCommand) XXX_Marshal 

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

func (*CreateNodeCommand) XXX_Merge 

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

func (*CreateNodeCommand) XXX_Size 

func (m *CreateNodeCommand) XXX_Size() int

func (*CreateNodeCommand) XXX_Unmarshal 

func (m *CreateNodeCommand) 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"`
	Default              *bool                `protobuf:"varint,3,req,name=Default" json:"Default,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) GetDefault 

func (m *CreateRetentionPolicyCommand) GetDefault() 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"`
	RetentionPolicy      *string  `protobuf:"bytes,2,req,name=RetentionPolicy" json:"RetentionPolicy,omitempty"`
	Timestamp            *int64   `protobuf:"varint,3,req,name=Timestamp" json:"Timestamp,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) GetRetentionPolicy 

func (m *CreateShardGroupCommand) GetRetentionPolicy() string

func (*CreateShardGroupCommand) GetTimestamp 

func (m *CreateShardGroupCommand) GetTimestamp() int64

func (*CreateShardGroupCommand) ProtoMessage 

func (*CreateShardGroupCommand) ProtoMessage()

func (*CreateShardGroupCommand) Reset 

func (m *CreateShardGroupCommand) Reset()

func (*CreateShardGroupCommand) String 

func (m *CreateShardGroupCommand) String() string

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 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"`
	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) 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 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"`
	// added for 0.10.0
	DataNodes            []*NodeInfo `protobuf:"bytes,10,rep,name=DataNodes" json:"DataNodes,omitempty"`
	MetaNodes            []*NodeInfo `protobuf:"bytes,11,rep,name=MetaNodes" json:"MetaNodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*Data) Descriptor 

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

func (*Data) GetClusterID 

func (m *Data) GetClusterID() uint64

func (*Data) GetDataNodes 

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

func (*Data) GetDatabases 

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

func (*Data) GetIndex 

func (m *Data) GetIndex() 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) GetMetaNodes 

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

func (*Data) GetNodes 

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

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 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"`
	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) GetName 

func (m *DatabaseInfo) GetName() string

func (*DatabaseInfo) GetRetentionPolicies 

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

func (*DatabaseInfo) ProtoMessage 

func (*DatabaseInfo) ProtoMessage()

func (*DatabaseInfo) Reset 

func (m *DatabaseInfo) Reset()

func (*DatabaseInfo) String 

func (m *DatabaseInfo) String() string

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 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 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 DeleteNodeCommand 

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

func (*DeleteNodeCommand) Descriptor 

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

func (*DeleteNodeCommand) GetForce 

func (m *DeleteNodeCommand) GetForce() bool

func (*DeleteNodeCommand) GetID 

func (m *DeleteNodeCommand) GetID() uint64

func (*DeleteNodeCommand) ProtoMessage 

func (*DeleteNodeCommand) ProtoMessage()

func (*DeleteNodeCommand) Reset 

func (m *DeleteNodeCommand) Reset()

func (*DeleteNodeCommand) String 

func (m *DeleteNodeCommand) String() string

func (*DeleteNodeCommand) XXX_DiscardUnknown 

func (m *DeleteNodeCommand) XXX_DiscardUnknown()

func (*DeleteNodeCommand) XXX_Marshal 

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

func (*DeleteNodeCommand) XXX_Merge 

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

func (*DeleteNodeCommand) XXX_Size 

func (m *DeleteNodeCommand) XXX_Size() int

func (*DeleteNodeCommand) XXX_Unmarshal 

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

type DeleteShardGroupCommand 

type DeleteShardGroupCommand struct {
	Database             *string  `protobuf:"bytes,1,req,name=Database" json:"Database,omitempty"`
	RetentionPolicy      *string  `protobuf:"bytes,2,req,name=RetentionPolicy" json:"RetentionPolicy,omitempty"`
	ShardGroupID         *uint64  `protobuf:"varint,3,req,name=ShardGroupID" json:"ShardGroupID,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) GetRetentionPolicy 

func (m *DeleteShardGroupCommand) GetRetentionPolicy() 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 DropContinuousQueryCommand 

type DropContinuousQueryCommand 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 (*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 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 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 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"`
	TCPHost              *string  `protobuf:"bytes,3,opt,name=TCPHost" json:"TCPHost,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeInfo) Descriptor 

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

func (*NodeInfo) GetHost 

func (m *NodeInfo) GetHost() string

func (*NodeInfo) GetID 

func (m *NodeInfo) GetID() uint64

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 RemovePeerCommand 

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

func (*RemovePeerCommand) Descriptor 

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

func (*RemovePeerCommand) GetAddr 

func (m *RemovePeerCommand) GetAddr() string

func (*RemovePeerCommand) GetID 

func (m *RemovePeerCommand) GetID() uint64

func (*RemovePeerCommand) ProtoMessage 

func (*RemovePeerCommand) ProtoMessage()

func (*RemovePeerCommand) Reset 

func (m *RemovePeerCommand) Reset()

func (*RemovePeerCommand) String 

func (m *RemovePeerCommand) String() string

func (*RemovePeerCommand) XXX_DiscardUnknown 

func (m *RemovePeerCommand) XXX_DiscardUnknown()

func (*RemovePeerCommand) XXX_Marshal 

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

func (*RemovePeerCommand) XXX_Merge 

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

func (*RemovePeerCommand) XXX_Size 

func (m *RemovePeerCommand) XXX_Size() int

func (*RemovePeerCommand) XXX_Unmarshal 

func (m *RemovePeerCommand) 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"`
	ShardGroups          []*ShardGroupInfo   `protobuf:"bytes,5,rep,name=ShardGroups" json:"ShardGroups,omitempty"`
	Subscriptions        []*SubscriptionInfo `protobuf:"bytes,6,rep,name=Subscriptions" json:"Subscriptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*RetentionPolicyInfo) Descriptor 

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

func (*RetentionPolicyInfo) GetDuration 

func (m *RetentionPolicyInfo) GetDuration() int64

func (*RetentionPolicyInfo) GetName 

func (m *RetentionPolicyInfo) GetName() string

func (*RetentionPolicyInfo) GetReplicaN 

func (m *RetentionPolicyInfo) GetReplicaN() uint32

func (*RetentionPolicyInfo) GetShardGroupDuration 

func (m *RetentionPolicyInfo) GetShardGroupDuration() int64

func (*RetentionPolicyInfo) GetShardGroups 

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

func (*RetentionPolicyInfo) GetSubscriptions 

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

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"`
	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) 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 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"`
	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) 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 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 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"`
	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) 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) 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 ShardInfo 

type ShardInfo struct {
	ID                   *uint64       `protobuf:"varint,1,req,name=ID" json:"ID,omitempty"`
	OwnerIDs             []uint64      `protobuf:"varint,2,rep,name=OwnerIDs" json:"OwnerIDs,omitempty"` // Deprecated: Do not use.
	Owners               []*ShardOwner `protobuf:"bytes,3,rep,name=Owners" json:"Owners,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ShardInfo) Descriptor 

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

func (*ShardInfo) GetID 

func (m *ShardInfo) GetID() uint64

func (*ShardInfo) GetOwnerIDs deprecated 

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

Deprecated: Do not use.

func (*ShardInfo) GetOwners 

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

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 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 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 TruncatedShardsCommand added in v1.0.2 

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

func (*TruncatedShardsCommand) Descriptor added in v1.0.2 

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

func (*TruncatedShardsCommand) GetTimestamp added in v1.0.2 

func (m *TruncatedShardsCommand) GetTimestamp() int64

func (*TruncatedShardsCommand) ProtoMessage added in v1.0.2 

func (*TruncatedShardsCommand) ProtoMessage()

func (*TruncatedShardsCommand) Reset added in v1.0.2 

func (m *TruncatedShardsCommand) Reset()

func (*TruncatedShardsCommand) String added in v1.0.2 

func (m *TruncatedShardsCommand) String() string

func (*TruncatedShardsCommand) XXX_DiscardUnknown added in v1.0.2 

func (m *TruncatedShardsCommand) XXX_DiscardUnknown()

func (*TruncatedShardsCommand) XXX_Marshal added in v1.0.2 

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

func (*TruncatedShardsCommand) XXX_Merge added in v1.0.2 

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

func (*TruncatedShardsCommand) XXX_Size added in v1.0.2 

func (m *TruncatedShardsCommand) XXX_Size() int

func (*TruncatedShardsCommand) XXX_Unmarshal added in v1.0.2 

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

type UpdateDataNodeCommand 

type UpdateDataNodeCommand struct {
	ID                   *uint64  `protobuf:"varint,1,req,name=ID" json:"ID,omitempty"`
	Host                 *string  `protobuf:"bytes,2,req,name=Host" json:"Host,omitempty"`
	TCPHost              *string  `protobuf:"bytes,3,req,name=TCPHost" json:"TCPHost,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateDataNodeCommand) Descriptor 

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

func (*UpdateDataNodeCommand) GetHost 

func (m *UpdateDataNodeCommand) GetHost() string

func (*UpdateDataNodeCommand) GetID 

func (m *UpdateDataNodeCommand) GetID() uint64

func (*UpdateDataNodeCommand) GetTCPHost 

func (m *UpdateDataNodeCommand) GetTCPHost() string

func (*UpdateDataNodeCommand) ProtoMessage 

func (*UpdateDataNodeCommand) ProtoMessage()

func (*UpdateDataNodeCommand) Reset 

func (m *UpdateDataNodeCommand) Reset()

func (*UpdateDataNodeCommand) String 

func (m *UpdateDataNodeCommand) String() string

func (*UpdateDataNodeCommand) XXX_DiscardUnknown 

func (m *UpdateDataNodeCommand) XXX_DiscardUnknown()

func (*UpdateDataNodeCommand) XXX_Marshal 

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

func (*UpdateDataNodeCommand) XXX_Merge 

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

func (*UpdateDataNodeCommand) XXX_Size 

func (m *UpdateDataNodeCommand) XXX_Size() int

func (*UpdateDataNodeCommand) XXX_Unmarshal 

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

type UpdateNodeCommand 

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

func (*UpdateNodeCommand) Descriptor 

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

func (*UpdateNodeCommand) GetHost 

func (m *UpdateNodeCommand) GetHost() string

func (*UpdateNodeCommand) GetID 

func (m *UpdateNodeCommand) GetID() uint64

func (*UpdateNodeCommand) ProtoMessage 

func (*UpdateNodeCommand) ProtoMessage()

func (*UpdateNodeCommand) Reset 

func (m *UpdateNodeCommand) Reset()

func (*UpdateNodeCommand) String 

func (m *UpdateNodeCommand) String() string

func (*UpdateNodeCommand) XXX_DiscardUnknown 

func (m *UpdateNodeCommand) XXX_DiscardUnknown()

func (*UpdateNodeCommand) XXX_Marshal 

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

func (*UpdateNodeCommand) XXX_Merge 

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

func (*UpdateNodeCommand) XXX_Size 

func (m *UpdateNodeCommand) XXX_Size() int

func (*UpdateNodeCommand) XXX_Unmarshal 

func (m *UpdateNodeCommand) 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"`
	Default              *bool    `protobuf:"varint,6,req,name=Default" json:"Default,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) GetDefault 

func (m *UpdateRetentionPolicyCommand) GetDefault() bool

func (*UpdateRetentionPolicyCommand) GetDuration 

func (m *UpdateRetentionPolicyCommand) GetDuration() int64

func (*UpdateRetentionPolicyCommand) GetName 

func (m *UpdateRetentionPolicyCommand) GetName() string

func (*UpdateRetentionPolicyCommand) GetNewName 

func (m *UpdateRetentionPolicyCommand) GetNewName() string

func (*UpdateRetentionPolicyCommand) GetReplicaN 

func (m *UpdateRetentionPolicyCommand) GetReplicaN() uint32

func (*UpdateRetentionPolicyCommand) ProtoMessage 

func (*UpdateRetentionPolicyCommand) ProtoMessage()

func (*UpdateRetentionPolicyCommand) Reset 

func (m *UpdateRetentionPolicyCommand) Reset()

func (*UpdateRetentionPolicyCommand) String 

func (m *UpdateRetentionPolicyCommand) String() string

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 UpdateShardOwnersCommand added in v1.0.2 

type UpdateShardOwnersCommand struct {
	ID                   *uint64  `protobuf:"varint,1,req,name=ID" json:"ID,omitempty"`
	AddOwners            []uint64 `protobuf:"varint,2,rep,name=AddOwners" json:"AddOwners,omitempty"`
	DelOwners            []uint64 `protobuf:"varint,3,rep,name=DelOwners" json:"DelOwners,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UpdateShardOwnersCommand) Descriptor added in v1.0.2 

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

func (*UpdateShardOwnersCommand) GetAddOwners added in v1.0.2 

func (m *UpdateShardOwnersCommand) GetAddOwners() []uint64

func (*UpdateShardOwnersCommand) GetDelOwners added in v1.0.2 

func (m *UpdateShardOwnersCommand) GetDelOwners() []uint64

func (*UpdateShardOwnersCommand) GetID added in v1.0.2 

func (m *UpdateShardOwnersCommand) GetID() uint64

func (*UpdateShardOwnersCommand) ProtoMessage added in v1.0.2 

func (*UpdateShardOwnersCommand) ProtoMessage()

func (*UpdateShardOwnersCommand) Reset added in v1.0.2 

func (m *UpdateShardOwnersCommand) Reset()

func (*UpdateShardOwnersCommand) String added in v1.0.2 

func (m *UpdateShardOwnersCommand) String() string

func (*UpdateShardOwnersCommand) XXX_DiscardUnknown added in v1.0.2 

func (m *UpdateShardOwnersCommand) XXX_DiscardUnknown()

func (*UpdateShardOwnersCommand) XXX_Marshal added in v1.0.2 

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

func (*UpdateShardOwnersCommand) XXX_Merge added in v1.0.2 

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

func (*UpdateShardOwnersCommand) XXX_Size added in v1.0.2 

func (m *UpdateShardOwnersCommand) XXX_Size() int

func (*UpdateShardOwnersCommand) XXX_Unmarshal added in v1.0.2 

func (m *UpdateShardOwnersCommand) 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"`
	Privileges           []*UserPrivilege `protobuf:"bytes,4,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) 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

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.