Help us shape the future of Go! Take the 2026 Go Developer Survey

meta

package
v1.8.7 Latest Latest
Warning

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

 Go to latest Published: Jul 21, 2021 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",
}
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",
	Filename:      "internal/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:      "internal/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:      "internal/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:      "internal/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:      "internal/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:      "internal/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:      "internal/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:      "internal/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:      "internal/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:      "internal/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:      "internal/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:      "internal/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:      "internal/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:      "internal/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:      "internal/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:      "internal/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:      "internal/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:      "internal/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:      "internal/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:      "internal/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:      "internal/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:      "internal/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:      "internal/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:      "internal/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:      "internal/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:      "internal/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:      "internal/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:      "internal/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:      "internal/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 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

func (*Command) XXX_DiscardUnknown added in v1.8.7 

func (m *Command) XXX_DiscardUnknown()

func (*Command) XXX_Marshal added in v1.8.7 

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

func (*Command) XXX_Merge added in v1.8.7 

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

func (*Command) XXX_Size added in v1.8.7 

func (m *Command) XXX_Size() int

func (*Command) XXX_Unmarshal added in v1.8.7 

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
)

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

func (*ContinuousQueryInfo) XXX_DiscardUnknown added in v1.8.7 

func (m *ContinuousQueryInfo) XXX_DiscardUnknown()

func (*ContinuousQueryInfo) XXX_Marshal added in v1.8.7 

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

func (*ContinuousQueryInfo) XXX_Merge added in v1.8.7 

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

func (*ContinuousQueryInfo) XXX_Size added in v1.8.7 

func (m *ContinuousQueryInfo) XXX_Size() int

func (*ContinuousQueryInfo) XXX_Unmarshal added in v1.8.7 

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

func (m *CreateContinuousQueryCommand) String() string

func (*CreateContinuousQueryCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *CreateContinuousQueryCommand) XXX_DiscardUnknown()

func (*CreateContinuousQueryCommand) XXX_Marshal added in v1.8.7 

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

func (*CreateContinuousQueryCommand) XXX_Merge added in v1.8.7 

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

func (*CreateContinuousQueryCommand) XXX_Size added in v1.8.7 

func (m *CreateContinuousQueryCommand) XXX_Size() int

func (*CreateContinuousQueryCommand) XXX_Unmarshal added in v1.8.7 

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

func (*CreateDataNodeCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *CreateDataNodeCommand) XXX_DiscardUnknown()

func (*CreateDataNodeCommand) XXX_Marshal added in v1.8.7 

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

func (*CreateDataNodeCommand) XXX_Merge added in v1.8.7 

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

func (*CreateDataNodeCommand) XXX_Size added in v1.8.7 

func (m *CreateDataNodeCommand) XXX_Size() int

func (*CreateDataNodeCommand) XXX_Unmarshal added in v1.8.7 

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

func (*CreateDatabaseCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *CreateDatabaseCommand) XXX_DiscardUnknown()

func (*CreateDatabaseCommand) XXX_Marshal added in v1.8.7 

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

func (*CreateDatabaseCommand) XXX_Merge added in v1.8.7 

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

func (*CreateDatabaseCommand) XXX_Size added in v1.8.7 

func (m *CreateDatabaseCommand) XXX_Size() int

func (*CreateDatabaseCommand) XXX_Unmarshal added in v1.8.7 

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

func (*CreateMetaNodeCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *CreateMetaNodeCommand) XXX_DiscardUnknown()

func (*CreateMetaNodeCommand) XXX_Marshal added in v1.8.7 

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

func (*CreateMetaNodeCommand) XXX_Merge added in v1.8.7 

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

func (*CreateMetaNodeCommand) XXX_Size added in v1.8.7 

func (m *CreateMetaNodeCommand) XXX_Size() int

func (*CreateMetaNodeCommand) XXX_Unmarshal added in v1.8.7 

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

func (*CreateNodeCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *CreateNodeCommand) XXX_DiscardUnknown()

func (*CreateNodeCommand) XXX_Marshal added in v1.8.7 

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

func (*CreateNodeCommand) XXX_Merge added in v1.8.7 

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

func (*CreateNodeCommand) XXX_Size added in v1.8.7 

func (m *CreateNodeCommand) XXX_Size() int

func (*CreateNodeCommand) XXX_Unmarshal added in v1.8.7 

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

func (m *CreateRetentionPolicyCommand) String() string

func (*CreateRetentionPolicyCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *CreateRetentionPolicyCommand) XXX_DiscardUnknown()

func (*CreateRetentionPolicyCommand) XXX_Marshal added in v1.8.7 

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

func (*CreateRetentionPolicyCommand) XXX_Merge added in v1.8.7 

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

func (*CreateRetentionPolicyCommand) XXX_Size added in v1.8.7 

func (m *CreateRetentionPolicyCommand) XXX_Size() int

func (*CreateRetentionPolicyCommand) XXX_Unmarshal added in v1.8.7 

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

type CreateShardGroupCommand 

type CreateShardGroupCommand struct {
	Database             *string  `protobuf:"bytes,1,req,name=Database" json:"Database,omitempty"`
	Policy               *string  `protobuf:"bytes,2,req,name=Policy" json:"Policy,omitempty"`
	Timestamp            *int64   `protobuf:"varint,3,req,name=Timestamp" json:"Timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*CreateShardGroupCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *CreateShardGroupCommand) XXX_DiscardUnknown()

func (*CreateShardGroupCommand) XXX_Marshal added in v1.8.7 

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

func (*CreateShardGroupCommand) XXX_Merge added in v1.8.7 

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

func (*CreateShardGroupCommand) XXX_Size added in v1.8.7 

func (m *CreateShardGroupCommand) XXX_Size() int

func (*CreateShardGroupCommand) XXX_Unmarshal added in v1.8.7 

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

func (*CreateSubscriptionCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *CreateSubscriptionCommand) XXX_DiscardUnknown()

func (*CreateSubscriptionCommand) XXX_Marshal added in v1.8.7 

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

func (*CreateSubscriptionCommand) XXX_Merge added in v1.8.7 

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

func (*CreateSubscriptionCommand) XXX_Size added in v1.8.7 

func (m *CreateSubscriptionCommand) XXX_Size() int

func (*CreateSubscriptionCommand) XXX_Unmarshal added in v1.8.7 

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

func (*CreateUserCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *CreateUserCommand) XXX_DiscardUnknown()

func (*CreateUserCommand) XXX_Marshal added in v1.8.7 

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

func (*CreateUserCommand) XXX_Merge added in v1.8.7 

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

func (*CreateUserCommand) XXX_Size added in v1.8.7 

func (m *CreateUserCommand) XXX_Size() int

func (*CreateUserCommand) XXX_Unmarshal added in v1.8.7 

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

func (*Data) XXX_DiscardUnknown added in v1.8.7 

func (m *Data) XXX_DiscardUnknown()

func (*Data) XXX_Marshal added in v1.8.7 

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

func (*Data) XXX_Merge added in v1.8.7 

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

func (*Data) XXX_Size added in v1.8.7 

func (m *Data) XXX_Size() int

func (*Data) XXX_Unmarshal added in v1.8.7 

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

func (*DatabaseInfo) XXX_DiscardUnknown added in v1.8.7 

func (m *DatabaseInfo) XXX_DiscardUnknown()

func (*DatabaseInfo) XXX_Marshal added in v1.8.7 

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

func (*DatabaseInfo) XXX_Merge added in v1.8.7 

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

func (*DatabaseInfo) XXX_Size added in v1.8.7 

func (m *DatabaseInfo) XXX_Size() int

func (*DatabaseInfo) XXX_Unmarshal added in v1.8.7 

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

func (*DeleteDataNodeCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *DeleteDataNodeCommand) XXX_DiscardUnknown()

func (*DeleteDataNodeCommand) XXX_Marshal added in v1.8.7 

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

func (*DeleteDataNodeCommand) XXX_Merge added in v1.8.7 

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

func (*DeleteDataNodeCommand) XXX_Size added in v1.8.7 

func (m *DeleteDataNodeCommand) XXX_Size() int

func (*DeleteDataNodeCommand) XXX_Unmarshal added in v1.8.7 

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

func (*DeleteMetaNodeCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *DeleteMetaNodeCommand) XXX_DiscardUnknown()

func (*DeleteMetaNodeCommand) XXX_Marshal added in v1.8.7 

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

func (*DeleteMetaNodeCommand) XXX_Merge added in v1.8.7 

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

func (*DeleteMetaNodeCommand) XXX_Size added in v1.8.7 

func (m *DeleteMetaNodeCommand) XXX_Size() int

func (*DeleteMetaNodeCommand) XXX_Unmarshal added in v1.8.7 

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

func (*DeleteNodeCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *DeleteNodeCommand) XXX_DiscardUnknown()

func (*DeleteNodeCommand) XXX_Marshal added in v1.8.7 

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

func (*DeleteNodeCommand) XXX_Merge added in v1.8.7 

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

func (*DeleteNodeCommand) XXX_Size added in v1.8.7 

func (m *DeleteNodeCommand) XXX_Size() int

func (*DeleteNodeCommand) XXX_Unmarshal added in v1.8.7 

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

type DeleteShardGroupCommand 

type DeleteShardGroupCommand struct {
	Database             *string  `protobuf:"bytes,1,req,name=Database" json:"Database,omitempty"`
	Policy               *string  `protobuf:"bytes,2,req,name=Policy" json:"Policy,omitempty"`
	ShardGroupID         *uint64  `protobuf:"varint,3,req,name=ShardGroupID" json:"ShardGroupID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*DeleteShardGroupCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *DeleteShardGroupCommand) XXX_DiscardUnknown()

func (*DeleteShardGroupCommand) XXX_Marshal added in v1.8.7 

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

func (*DeleteShardGroupCommand) XXX_Merge added in v1.8.7 

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

func (*DeleteShardGroupCommand) XXX_Size added in v1.8.7 

func (m *DeleteShardGroupCommand) XXX_Size() int

func (*DeleteShardGroupCommand) XXX_Unmarshal added in v1.8.7 

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

func (*DropContinuousQueryCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *DropContinuousQueryCommand) XXX_DiscardUnknown()

func (*DropContinuousQueryCommand) XXX_Marshal added in v1.8.7 

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

func (*DropContinuousQueryCommand) XXX_Merge added in v1.8.7 

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

func (*DropContinuousQueryCommand) XXX_Size added in v1.8.7 

func (m *DropContinuousQueryCommand) XXX_Size() int

func (*DropContinuousQueryCommand) XXX_Unmarshal added in v1.8.7 

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

func (*DropDatabaseCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *DropDatabaseCommand) XXX_DiscardUnknown()

func (*DropDatabaseCommand) XXX_Marshal added in v1.8.7 

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

func (*DropDatabaseCommand) XXX_Merge added in v1.8.7 

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

func (*DropDatabaseCommand) XXX_Size added in v1.8.7 

func (m *DropDatabaseCommand) XXX_Size() int

func (*DropDatabaseCommand) XXX_Unmarshal added in v1.8.7 

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

func (*DropRetentionPolicyCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *DropRetentionPolicyCommand) XXX_DiscardUnknown()

func (*DropRetentionPolicyCommand) XXX_Marshal added in v1.8.7 

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

func (*DropRetentionPolicyCommand) XXX_Merge added in v1.8.7 

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

func (*DropRetentionPolicyCommand) XXX_Size added in v1.8.7 

func (m *DropRetentionPolicyCommand) XXX_Size() int

func (*DropRetentionPolicyCommand) XXX_Unmarshal added in v1.8.7 

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

type DropShardCommand added in v0.12.0 

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

func (*DropShardCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *DropShardCommand) XXX_DiscardUnknown()

func (*DropShardCommand) XXX_Marshal added in v1.8.7 

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

func (*DropShardCommand) XXX_Merge added in v1.8.7 

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

func (*DropShardCommand) XXX_Size added in v1.8.7 

func (m *DropShardCommand) XXX_Size() int

func (*DropShardCommand) XXX_Unmarshal added in v1.8.7 

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

func (*DropSubscriptionCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *DropSubscriptionCommand) XXX_DiscardUnknown()

func (*DropSubscriptionCommand) XXX_Marshal added in v1.8.7 

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

func (*DropSubscriptionCommand) XXX_Merge added in v1.8.7 

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

func (*DropSubscriptionCommand) XXX_Size added in v1.8.7 

func (m *DropSubscriptionCommand) XXX_Size() int

func (*DropSubscriptionCommand) XXX_Unmarshal added in v1.8.7 

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

func (*DropUserCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *DropUserCommand) XXX_DiscardUnknown()

func (*DropUserCommand) XXX_Marshal added in v1.8.7 

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

func (*DropUserCommand) XXX_Merge added in v1.8.7 

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

func (*DropUserCommand) XXX_Size added in v1.8.7 

func (m *DropUserCommand) XXX_Size() int

func (*DropUserCommand) XXX_Unmarshal added in v1.8.7 

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

func (*NodeInfo) XXX_DiscardUnknown added in v1.8.7 

func (m *NodeInfo) XXX_DiscardUnknown()

func (*NodeInfo) XXX_Marshal added in v1.8.7 

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

func (*NodeInfo) XXX_Merge added in v1.8.7 

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

func (*NodeInfo) XXX_Size added in v1.8.7 

func (m *NodeInfo) XXX_Size() int

func (*NodeInfo) XXX_Unmarshal added in v1.8.7 

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

func (*RemovePeerCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *RemovePeerCommand) XXX_DiscardUnknown()

func (*RemovePeerCommand) XXX_Marshal added in v1.8.7 

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

func (*RemovePeerCommand) XXX_Merge added in v1.8.7 

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

func (*RemovePeerCommand) XXX_Size added in v1.8.7 

func (m *RemovePeerCommand) XXX_Size() int

func (*RemovePeerCommand) XXX_Unmarshal added in v1.8.7 

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

func (*Response) XXX_DiscardUnknown added in v1.8.7 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal added in v1.8.7 

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

func (*Response) XXX_Merge added in v1.8.7 

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

func (*Response) XXX_Size added in v1.8.7 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal added in v1.8.7 

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

func (*RetentionPolicyInfo) XXX_DiscardUnknown added in v1.8.7 

func (m *RetentionPolicyInfo) XXX_DiscardUnknown()

func (*RetentionPolicyInfo) XXX_Marshal added in v1.8.7 

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

func (*RetentionPolicyInfo) XXX_Merge added in v1.8.7 

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

func (*RetentionPolicyInfo) XXX_Size added in v1.8.7 

func (m *RetentionPolicyInfo) XXX_Size() int

func (*RetentionPolicyInfo) XXX_Unmarshal added in v1.8.7 

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

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

func (*RetentionPolicySpec) XXX_DiscardUnknown added in v1.8.7 

func (m *RetentionPolicySpec) XXX_DiscardUnknown()

func (*RetentionPolicySpec) XXX_Marshal added in v1.8.7 

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

func (*RetentionPolicySpec) XXX_Merge added in v1.8.7 

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

func (*RetentionPolicySpec) XXX_Size added in v1.8.7 

func (m *RetentionPolicySpec) XXX_Size() int

func (*RetentionPolicySpec) XXX_Unmarshal added in v1.8.7 

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

func (*SetAdminPrivilegeCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *SetAdminPrivilegeCommand) XXX_DiscardUnknown()

func (*SetAdminPrivilegeCommand) XXX_Marshal added in v1.8.7 

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

func (*SetAdminPrivilegeCommand) XXX_Merge added in v1.8.7 

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

func (*SetAdminPrivilegeCommand) XXX_Size added in v1.8.7 

func (m *SetAdminPrivilegeCommand) XXX_Size() int

func (*SetAdminPrivilegeCommand) XXX_Unmarshal added in v1.8.7 

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

func (*SetDataCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *SetDataCommand) XXX_DiscardUnknown()

func (*SetDataCommand) XXX_Marshal added in v1.8.7 

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

func (*SetDataCommand) XXX_Merge added in v1.8.7 

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

func (*SetDataCommand) XXX_Size added in v1.8.7 

func (m *SetDataCommand) XXX_Size() int

func (*SetDataCommand) XXX_Unmarshal added in v1.8.7 

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

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

func (m *SetDefaultRetentionPolicyCommand) XXX_DiscardUnknown()

func (*SetDefaultRetentionPolicyCommand) XXX_Marshal added in v1.8.7 

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

func (*SetDefaultRetentionPolicyCommand) XXX_Merge added in v1.8.7 

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

func (*SetDefaultRetentionPolicyCommand) XXX_Size added in v1.8.7 

func (m *SetDefaultRetentionPolicyCommand) XXX_Size() int

func (*SetDefaultRetentionPolicyCommand) XXX_Unmarshal added in v1.8.7 

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

func (*SetMetaNodeCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *SetMetaNodeCommand) XXX_DiscardUnknown()

func (*SetMetaNodeCommand) XXX_Marshal added in v1.8.7 

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

func (*SetMetaNodeCommand) XXX_Merge added in v1.8.7 

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

func (*SetMetaNodeCommand) XXX_Size added in v1.8.7 

func (m *SetMetaNodeCommand) XXX_Size() int

func (*SetMetaNodeCommand) XXX_Unmarshal added in v1.8.7 

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

func (*SetPrivilegeCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *SetPrivilegeCommand) XXX_DiscardUnknown()

func (*SetPrivilegeCommand) XXX_Marshal added in v1.8.7 

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

func (*SetPrivilegeCommand) XXX_Merge added in v1.8.7 

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

func (*SetPrivilegeCommand) XXX_Size added in v1.8.7 

func (m *SetPrivilegeCommand) XXX_Size() int

func (*SetPrivilegeCommand) XXX_Unmarshal added in v1.8.7 

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

func (*ShardGroupInfo) XXX_DiscardUnknown added in v1.8.7 

func (m *ShardGroupInfo) XXX_DiscardUnknown()

func (*ShardGroupInfo) XXX_Marshal added in v1.8.7 

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

func (*ShardGroupInfo) XXX_Merge added in v1.8.7 

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

func (*ShardGroupInfo) XXX_Size added in v1.8.7 

func (m *ShardGroupInfo) XXX_Size() int

func (*ShardGroupInfo) XXX_Unmarshal added in v1.8.7 

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

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

func (m *ShardInfo) XXX_DiscardUnknown()

func (*ShardInfo) XXX_Marshal added in v1.8.7 

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

func (*ShardInfo) XXX_Merge added in v1.8.7 

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

func (*ShardInfo) XXX_Size added in v1.8.7 

func (m *ShardInfo) XXX_Size() int

func (*ShardInfo) XXX_Unmarshal added in v1.8.7 

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

func (*ShardOwner) XXX_DiscardUnknown added in v1.8.7 

func (m *ShardOwner) XXX_DiscardUnknown()

func (*ShardOwner) XXX_Marshal added in v1.8.7 

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

func (*ShardOwner) XXX_Merge added in v1.8.7 

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

func (*ShardOwner) XXX_Size added in v1.8.7 

func (m *ShardOwner) XXX_Size() int

func (*ShardOwner) XXX_Unmarshal added in v1.8.7 

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

func (*SubscriptionInfo) XXX_DiscardUnknown added in v1.8.7 

func (m *SubscriptionInfo) XXX_DiscardUnknown()

func (*SubscriptionInfo) XXX_Marshal added in v1.8.7 

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

func (*SubscriptionInfo) XXX_Merge added in v1.8.7 

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

func (*SubscriptionInfo) XXX_Size added in v1.8.7 

func (m *SubscriptionInfo) XXX_Size() int

func (*SubscriptionInfo) XXX_Unmarshal added in v1.8.7 

func (m *SubscriptionInfo) 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 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

func (*UpdateDataNodeCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *UpdateDataNodeCommand) XXX_DiscardUnknown()

func (*UpdateDataNodeCommand) XXX_Marshal added in v1.8.7 

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

func (*UpdateDataNodeCommand) XXX_Merge added in v1.8.7 

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

func (*UpdateDataNodeCommand) XXX_Size added in v1.8.7 

func (m *UpdateDataNodeCommand) XXX_Size() int

func (*UpdateDataNodeCommand) XXX_Unmarshal added in v1.8.7 

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

func (*UpdateNodeCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *UpdateNodeCommand) XXX_DiscardUnknown()

func (*UpdateNodeCommand) XXX_Marshal added in v1.8.7 

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

func (*UpdateNodeCommand) XXX_Merge added in v1.8.7 

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

func (*UpdateNodeCommand) XXX_Size added in v1.8.7 

func (m *UpdateNodeCommand) XXX_Size() int

func (*UpdateNodeCommand) XXX_Unmarshal added in v1.8.7 

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

func (m *UpdateRetentionPolicyCommand) String() string

func (*UpdateRetentionPolicyCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *UpdateRetentionPolicyCommand) XXX_DiscardUnknown()

func (*UpdateRetentionPolicyCommand) XXX_Marshal added in v1.8.7 

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

func (*UpdateRetentionPolicyCommand) XXX_Merge added in v1.8.7 

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

func (*UpdateRetentionPolicyCommand) XXX_Size added in v1.8.7 

func (m *UpdateRetentionPolicyCommand) XXX_Size() int

func (*UpdateRetentionPolicyCommand) XXX_Unmarshal added in v1.8.7 

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

func (*UpdateUserCommand) XXX_DiscardUnknown added in v1.8.7 

func (m *UpdateUserCommand) XXX_DiscardUnknown()

func (*UpdateUserCommand) XXX_Marshal added in v1.8.7 

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

func (*UpdateUserCommand) XXX_Merge added in v1.8.7 

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

func (*UpdateUserCommand) XXX_Size added in v1.8.7 

func (m *UpdateUserCommand) XXX_Size() int

func (*UpdateUserCommand) XXX_Unmarshal added in v1.8.7 

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

func (*UserInfo) XXX_DiscardUnknown added in v1.8.7 

func (m *UserInfo) XXX_DiscardUnknown()

func (*UserInfo) XXX_Marshal added in v1.8.7 

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

func (*UserInfo) XXX_Merge added in v1.8.7 

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

func (*UserInfo) XXX_Size added in v1.8.7 

func (m *UserInfo) XXX_Size() int

func (*UserInfo) XXX_Unmarshal added in v1.8.7 

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

func (*UserPrivilege) XXX_DiscardUnknown added in v1.8.7 

func (m *UserPrivilege) XXX_DiscardUnknown()

func (*UserPrivilege) XXX_Marshal added in v1.8.7 

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

func (*UserPrivilege) XXX_Merge added in v1.8.7 

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

func (*UserPrivilege) XXX_Size added in v1.8.7 

func (m *UserPrivilege) XXX_Size() int

func (*UserPrivilege) XXX_Unmarshal added in v1.8.7 

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.