meta

package
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Sep 7, 2016 License: MIT Imports: 3 Imported by: 0

Documentation

Overview

Package meta is a generated protocol buffer package.

It is generated from these files:

internal/meta.proto

It has these top-level messages:

Data
NodeInfo
DatabaseInfo
RetentionPolicySpec
RetentionPolicyInfo
ShardGroupInfo
ShardInfo
SubscriptionInfo
ShardOwner
ContinuousQueryInfo
UserInfo
UserPrivilege
Command
CreateNodeCommand
DeleteNodeCommand
CreateDatabaseCommand
DropDatabaseCommand
CreateRetentionPolicyCommand
DropRetentionPolicyCommand
SetDefaultRetentionPolicyCommand
UpdateRetentionPolicyCommand
CreateShardGroupCommand
DeleteShardGroupCommand
CreateContinuousQueryCommand
DropContinuousQueryCommand
CreateUserCommand
DropUserCommand
UpdateUserCommand
SetPrivilegeCommand
SetDataCommand
SetAdminPrivilegeCommand
UpdateNodeCommand
CreateSubscriptionCommand
DropSubscriptionCommand
RemovePeerCommand
CreateMetaNodeCommand
CreateDataNodeCommand
UpdateDataNodeCommand
DeleteMetaNodeCommand
DeleteDataNodeCommand
Response
SetMetaNodeCommand
DropShardCommand

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",
}
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,
}
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",
}
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",
}
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",
}
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",
}
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",
}
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",
}
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",
}
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",
}
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",
}
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",
}
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",
}
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",
}
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",
}
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",
}
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",
}
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",
}
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",
}
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",
}
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",
}
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",
}
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",
}
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",
}
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",
}
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",
}
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",
}
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",
}
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",
}
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",
}
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",
}

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"`
	proto.XXX_InternalExtensions `json:"-"`
	XXX_unrecognized             []byte `json:"-"`
}

func (*Command) Descriptor added in v1.0.0

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

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
)

func (Command_Type) Enum

func (x Command_Type) Enum() *Command_Type

func (Command_Type) EnumDescriptor added in v1.0.0

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_unrecognized []byte  `json:"-"`
}

func (*ContinuousQueryInfo) Descriptor added in v1.0.0

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

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_unrecognized []byte  `json:"-"`
}

func (*CreateContinuousQueryCommand) Descriptor added in v1.0.0

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

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_unrecognized []byte  `json:"-"`
}

func (*CreateDataNodeCommand) Descriptor added in v1.0.0

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

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_unrecognized []byte               `json:"-"`
}

func (*CreateDatabaseCommand) Descriptor added in v1.0.0

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

func (*CreateDatabaseCommand) GetName

func (m *CreateDatabaseCommand) GetName() string

func (*CreateDatabaseCommand) GetRetentionPolicy added in v0.10.1

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

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_unrecognized []byte  `json:"-"`
}

func (*CreateMetaNodeCommand) Descriptor added in v1.0.0

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

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_unrecognized []byte  `json:"-"`
}

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

func (*CreateNodeCommand) Descriptor added in v1.0.0

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

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"`
	XXX_unrecognized []byte               `json:"-"`
}

func (*CreateRetentionPolicyCommand) Descriptor added in v1.0.0

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

func (*CreateRetentionPolicyCommand) GetDatabase

func (m *CreateRetentionPolicyCommand) GetDatabase() string

func (*CreateRetentionPolicyCommand) GetRetentionPolicy

func (m *CreateRetentionPolicyCommand) GetRetentionPolicy() *RetentionPolicyInfo

func (*CreateRetentionPolicyCommand) ProtoMessage

func (*CreateRetentionPolicyCommand) ProtoMessage()

func (*CreateRetentionPolicyCommand) Reset

func (m *CreateRetentionPolicyCommand) Reset()

func (*CreateRetentionPolicyCommand) String

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"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CreateShardGroupCommand) Descriptor added in v1.0.0

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

func (*CreateShardGroupCommand) GetDatabase

func (m *CreateShardGroupCommand) GetDatabase() string

func (*CreateShardGroupCommand) GetPolicy

func (m *CreateShardGroupCommand) GetPolicy() string

func (*CreateShardGroupCommand) GetTimestamp

func (m *CreateShardGroupCommand) GetTimestamp() int64

func (*CreateShardGroupCommand) ProtoMessage

func (*CreateShardGroupCommand) ProtoMessage()

func (*CreateShardGroupCommand) Reset

func (m *CreateShardGroupCommand) Reset()

func (*CreateShardGroupCommand) String

func (m *CreateShardGroupCommand) String() string

type 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_unrecognized []byte   `json:"-"`
}

func (*CreateSubscriptionCommand) Descriptor added in v1.0.0

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

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_unrecognized []byte  `json:"-"`
}

func (*CreateUserCommand) Descriptor added in v1.0.0

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

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_unrecognized []byte      `json:"-"`
}

func (*Data) Descriptor added in v1.0.0

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

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_unrecognized       []byte                 `json:"-"`
}

func (*DatabaseInfo) Descriptor added in v1.0.0

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

type DeleteDataNodeCommand

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

func (*DeleteDataNodeCommand) Descriptor added in v1.0.0

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

type DeleteMetaNodeCommand

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

func (*DeleteMetaNodeCommand) Descriptor added in v1.0.0

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

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_unrecognized []byte  `json:"-"`
}

func (*DeleteNodeCommand) Descriptor added in v1.0.0

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

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"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*DeleteShardGroupCommand) Descriptor added in v1.0.0

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

func (*DeleteShardGroupCommand) GetDatabase

func (m *DeleteShardGroupCommand) GetDatabase() string

func (*DeleteShardGroupCommand) GetPolicy

func (m *DeleteShardGroupCommand) GetPolicy() string

func (*DeleteShardGroupCommand) GetShardGroupID

func (m *DeleteShardGroupCommand) GetShardGroupID() uint64

func (*DeleteShardGroupCommand) ProtoMessage

func (*DeleteShardGroupCommand) ProtoMessage()

func (*DeleteShardGroupCommand) Reset

func (m *DeleteShardGroupCommand) Reset()

func (*DeleteShardGroupCommand) String

func (m *DeleteShardGroupCommand) String() string

type DropContinuousQueryCommand

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

func (*DropContinuousQueryCommand) Descriptor added in v1.0.0

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

type DropDatabaseCommand

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

func (*DropDatabaseCommand) Descriptor added in v1.0.0

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

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_unrecognized []byte  `json:"-"`
}

func (*DropRetentionPolicyCommand) Descriptor added in v1.0.0

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

type DropShardCommand added in v0.12.0

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

func (*DropShardCommand) Descriptor added in v1.0.0

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

func (*DropShardCommand) GetID added in v0.12.0

func (m *DropShardCommand) GetID() uint64

func (*DropShardCommand) ProtoMessage added in v0.12.0

func (*DropShardCommand) ProtoMessage()

func (*DropShardCommand) Reset added in v0.12.0

func (m *DropShardCommand) Reset()

func (*DropShardCommand) String added in v0.12.0

func (m *DropShardCommand) String() string

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_unrecognized []byte  `json:"-"`
}

func (*DropSubscriptionCommand) Descriptor added in v1.0.0

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

type DropUserCommand

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

func (*DropUserCommand) Descriptor added in v1.0.0

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

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_unrecognized []byte  `json:"-"`
}

func (*NodeInfo) Descriptor added in v1.0.0

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

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_unrecognized []byte  `json:"-"`
}

func (*RemovePeerCommand) Descriptor added in v1.0.0

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

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_unrecognized []byte  `json:"-"`
}

func (*Response) Descriptor added in v1.0.0

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

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_unrecognized   []byte              `json:"-"`
}

func (*RetentionPolicyInfo) Descriptor added in v1.0.0

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

type RetentionPolicySpec added in v1.0.0

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_unrecognized   []byte  `json:"-"`
}

func (*RetentionPolicySpec) Descriptor added in v1.0.0

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

func (*RetentionPolicySpec) GetDuration added in v1.0.0

func (m *RetentionPolicySpec) GetDuration() int64

func (*RetentionPolicySpec) GetName added in v1.0.0

func (m *RetentionPolicySpec) GetName() string

func (*RetentionPolicySpec) GetReplicaN added in v1.0.0

func (m *RetentionPolicySpec) GetReplicaN() uint32

func (*RetentionPolicySpec) GetShardGroupDuration added in v1.0.0

func (m *RetentionPolicySpec) GetShardGroupDuration() int64

func (*RetentionPolicySpec) ProtoMessage added in v1.0.0

func (*RetentionPolicySpec) ProtoMessage()

func (*RetentionPolicySpec) Reset added in v1.0.0

func (m *RetentionPolicySpec) Reset()

func (*RetentionPolicySpec) String added in v1.0.0

func (m *RetentionPolicySpec) String() string

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_unrecognized []byte  `json:"-"`
}

func (*SetAdminPrivilegeCommand) Descriptor added in v1.0.0

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

type SetDataCommand

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

func (*SetDataCommand) Descriptor added in v1.0.0

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

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_unrecognized []byte  `json:"-"`
}

func (*SetDefaultRetentionPolicyCommand) Descriptor added in v1.0.0

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

func (*SetDefaultRetentionPolicyCommand) GetDatabase

func (m *SetDefaultRetentionPolicyCommand) GetDatabase() string

func (*SetDefaultRetentionPolicyCommand) GetName

func (*SetDefaultRetentionPolicyCommand) ProtoMessage

func (*SetDefaultRetentionPolicyCommand) ProtoMessage()

func (*SetDefaultRetentionPolicyCommand) Reset

func (*SetDefaultRetentionPolicyCommand) String

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_unrecognized []byte  `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 added in v1.0.0

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

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_unrecognized []byte  `json:"-"`
}

func (*SetPrivilegeCommand) Descriptor added in v1.0.0

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

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_unrecognized []byte       `json:"-"`
}

func (*ShardGroupInfo) Descriptor added in v1.0.0

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

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

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"`
	Owners           []*ShardOwner `protobuf:"bytes,3,rep,name=Owners" json:"Owners,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*ShardInfo) Descriptor added in v1.0.0

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

func (*ShardInfo) GetID

func (m *ShardInfo) GetID() uint64

func (*ShardInfo) GetOwnerIDs

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

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

type ShardOwner

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

func (*ShardOwner) Descriptor added in v1.0.0

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

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_unrecognized []byte   `json:"-"`
}

func (*SubscriptionInfo) Descriptor added in v1.0.0

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

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_unrecognized []byte  `json:"-"`
}

func (*UpdateDataNodeCommand) Descriptor added in v1.0.0

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

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_unrecognized []byte  `json:"-"`
}

func (*UpdateNodeCommand) Descriptor added in v1.0.0

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

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"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*UpdateRetentionPolicyCommand) Descriptor added in v1.0.0

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

func (*UpdateRetentionPolicyCommand) GetDatabase

func (m *UpdateRetentionPolicyCommand) GetDatabase() string

func (*UpdateRetentionPolicyCommand) GetDuration

func (m *UpdateRetentionPolicyCommand) GetDuration() int64

func (*UpdateRetentionPolicyCommand) GetName

func (m *UpdateRetentionPolicyCommand) GetName() string

func (*UpdateRetentionPolicyCommand) GetNewName

func (m *UpdateRetentionPolicyCommand) GetNewName() string

func (*UpdateRetentionPolicyCommand) GetReplicaN

func (m *UpdateRetentionPolicyCommand) GetReplicaN() uint32

func (*UpdateRetentionPolicyCommand) ProtoMessage

func (*UpdateRetentionPolicyCommand) ProtoMessage()

func (*UpdateRetentionPolicyCommand) Reset

func (m *UpdateRetentionPolicyCommand) Reset()

func (*UpdateRetentionPolicyCommand) String

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_unrecognized []byte  `json:"-"`
}

func (*UpdateUserCommand) Descriptor added in v1.0.0

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

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_unrecognized []byte           `json:"-"`
}

func (*UserInfo) Descriptor added in v1.0.0

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

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_unrecognized []byte  `json:"-"`
}

func (*UserPrivilege) Descriptor added in v1.0.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL