meta

package
v2.7.10 Latest Latest
Warning

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

 Go to latest Published: Aug 15, 2024 License: MIT Imports: 4 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",
	}
	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,
	}
)

Enum value maps for Command_Type.

View Source 
var (
	// optional meta.CreateNodeCommand command = 101;
	E_CreateNodeCommand_Command = &file_internal_meta_proto_extTypes[0]
	// optional meta.DeleteNodeCommand command = 102;
	E_DeleteNodeCommand_Command = &file_internal_meta_proto_extTypes[1]
	// optional meta.CreateDatabaseCommand command = 103;
	E_CreateDatabaseCommand_Command = &file_internal_meta_proto_extTypes[2]
	// optional meta.DropDatabaseCommand command = 104;
	E_DropDatabaseCommand_Command = &file_internal_meta_proto_extTypes[3]
	// optional meta.CreateRetentionPolicyCommand command = 105;
	E_CreateRetentionPolicyCommand_Command = &file_internal_meta_proto_extTypes[4]
	// optional meta.DropRetentionPolicyCommand command = 106;
	E_DropRetentionPolicyCommand_Command = &file_internal_meta_proto_extTypes[5]
	// optional meta.SetDefaultRetentionPolicyCommand command = 107;
	E_SetDefaultRetentionPolicyCommand_Command = &file_internal_meta_proto_extTypes[6]
	// optional meta.UpdateRetentionPolicyCommand command = 108;
	E_UpdateRetentionPolicyCommand_Command = &file_internal_meta_proto_extTypes[7]
	// optional meta.CreateShardGroupCommand command = 109;
	E_CreateShardGroupCommand_Command = &file_internal_meta_proto_extTypes[8]
	// optional meta.DeleteShardGroupCommand command = 110;
	E_DeleteShardGroupCommand_Command = &file_internal_meta_proto_extTypes[9]
	// optional meta.CreateContinuousQueryCommand command = 111;
	E_CreateContinuousQueryCommand_Command = &file_internal_meta_proto_extTypes[10]
	// optional meta.DropContinuousQueryCommand command = 112;
	E_DropContinuousQueryCommand_Command = &file_internal_meta_proto_extTypes[11]
	// optional meta.CreateUserCommand command = 113;
	E_CreateUserCommand_Command = &file_internal_meta_proto_extTypes[12]
	// optional meta.DropUserCommand command = 114;
	E_DropUserCommand_Command = &file_internal_meta_proto_extTypes[13]
	// optional meta.UpdateUserCommand command = 115;
	E_UpdateUserCommand_Command = &file_internal_meta_proto_extTypes[14]
	// optional meta.SetPrivilegeCommand command = 116;
	E_SetPrivilegeCommand_Command = &file_internal_meta_proto_extTypes[15]
	// optional meta.SetDataCommand command = 117;
	E_SetDataCommand_Command = &file_internal_meta_proto_extTypes[16]
	// optional meta.SetAdminPrivilegeCommand command = 118;
	E_SetAdminPrivilegeCommand_Command = &file_internal_meta_proto_extTypes[17]
	// optional meta.UpdateNodeCommand command = 119;
	E_UpdateNodeCommand_Command = &file_internal_meta_proto_extTypes[18]
	// optional meta.CreateSubscriptionCommand command = 121;
	E_CreateSubscriptionCommand_Command = &file_internal_meta_proto_extTypes[19]
	// optional meta.DropSubscriptionCommand command = 122;
	E_DropSubscriptionCommand_Command = &file_internal_meta_proto_extTypes[20]
	// optional meta.RemovePeerCommand command = 123;
	E_RemovePeerCommand_Command = &file_internal_meta_proto_extTypes[21]
	// optional meta.CreateMetaNodeCommand command = 124;
	E_CreateMetaNodeCommand_Command = &file_internal_meta_proto_extTypes[22]
	// optional meta.CreateDataNodeCommand command = 125;
	E_CreateDataNodeCommand_Command = &file_internal_meta_proto_extTypes[23]
	// optional meta.UpdateDataNodeCommand command = 126;
	E_UpdateDataNodeCommand_Command = &file_internal_meta_proto_extTypes[24]
	// optional meta.DeleteMetaNodeCommand command = 127;
	E_DeleteMetaNodeCommand_Command = &file_internal_meta_proto_extTypes[25]
	// optional meta.DeleteDataNodeCommand command = 128;
	E_DeleteDataNodeCommand_Command = &file_internal_meta_proto_extTypes[26]
	// optional meta.SetMetaNodeCommand command = 129;
	E_SetMetaNodeCommand_Command = &file_internal_meta_proto_extTypes[27]
	// optional meta.DropShardCommand command = 130;
	E_DropShardCommand_Command = &file_internal_meta_proto_extTypes[28]
)

Extension fields to Command.

View Source 
var File_internal_meta_proto protoreflect.FileDescriptor

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"`
	// contains filtered or unexported fields
}

func (*Command) Descriptor deprecated 

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

Deprecated: Use Command.ProtoReflect.Descriptor instead.

func (*Command) GetType 

func (x *Command) GetType() Command_Type

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) ProtoReflect added in v2.2.0 

func (x *Command) ProtoReflect() protoreflect.Message

func (*Command) Reset 

func (x *Command) Reset()

func (*Command) String 

func (x *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) Descriptor added in v2.2.0 

func (Command_Type) Descriptor() protoreflect.EnumDescriptor

func (Command_Type) Enum 

func (x Command_Type) Enum() *Command_Type

func (Command_Type) EnumDescriptor deprecated 

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

Deprecated: Use Command_Type.Descriptor instead.

func (Command_Type) Number added in v2.2.0 

func (x Command_Type) Number() protoreflect.EnumNumber

func (Command_Type) String 

func (x Command_Type) String() string

func (Command_Type) Type added in v2.2.0 

func (Command_Type) Type() protoreflect.EnumType

func (*Command_Type) UnmarshalJSON deprecated 

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

Deprecated: Do not use.

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"`
	// contains filtered or unexported fields
}

func (*ContinuousQueryInfo) Descriptor deprecated 

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

Deprecated: Use ContinuousQueryInfo.ProtoReflect.Descriptor instead.

func (*ContinuousQueryInfo) GetName 

func (x *ContinuousQueryInfo) GetName() string

func (*ContinuousQueryInfo) GetQuery 

func (x *ContinuousQueryInfo) GetQuery() string

func (*ContinuousQueryInfo) ProtoMessage 

func (*ContinuousQueryInfo) ProtoMessage()

func (*ContinuousQueryInfo) ProtoReflect added in v2.2.0 

func (x *ContinuousQueryInfo) ProtoReflect() protoreflect.Message

func (*ContinuousQueryInfo) Reset 

func (x *ContinuousQueryInfo) Reset()

func (*ContinuousQueryInfo) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*CreateContinuousQueryCommand) Descriptor deprecated 

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

Deprecated: Use CreateContinuousQueryCommand.ProtoReflect.Descriptor instead.

func (*CreateContinuousQueryCommand) GetDatabase 

func (x *CreateContinuousQueryCommand) GetDatabase() string

func (*CreateContinuousQueryCommand) GetName 

func (x *CreateContinuousQueryCommand) GetName() string

func (*CreateContinuousQueryCommand) GetQuery 

func (x *CreateContinuousQueryCommand) GetQuery() string

func (*CreateContinuousQueryCommand) ProtoMessage 

func (*CreateContinuousQueryCommand) ProtoMessage()

func (*CreateContinuousQueryCommand) ProtoReflect added in v2.2.0 

func (x *CreateContinuousQueryCommand) ProtoReflect() protoreflect.Message

func (*CreateContinuousQueryCommand) Reset 

func (x *CreateContinuousQueryCommand) Reset()

func (*CreateContinuousQueryCommand) String 

func (x *CreateContinuousQueryCommand) String() 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"`
	// contains filtered or unexported fields
}

func (*CreateDataNodeCommand) Descriptor deprecated 

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

Deprecated: Use CreateDataNodeCommand.ProtoReflect.Descriptor instead.

func (*CreateDataNodeCommand) GetHTTPAddr 

func (x *CreateDataNodeCommand) GetHTTPAddr() string

func (*CreateDataNodeCommand) GetTCPAddr 

func (x *CreateDataNodeCommand) GetTCPAddr() string

func (*CreateDataNodeCommand) ProtoMessage 

func (*CreateDataNodeCommand) ProtoMessage()

func (*CreateDataNodeCommand) ProtoReflect added in v2.2.0 

func (x *CreateDataNodeCommand) ProtoReflect() protoreflect.Message

func (*CreateDataNodeCommand) Reset 

func (x *CreateDataNodeCommand) Reset()

func (*CreateDataNodeCommand) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*CreateDatabaseCommand) Descriptor deprecated 

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

Deprecated: Use CreateDatabaseCommand.ProtoReflect.Descriptor instead.

func (*CreateDatabaseCommand) GetName 

func (x *CreateDatabaseCommand) GetName() string

func (*CreateDatabaseCommand) GetRetentionPolicy 

func (x *CreateDatabaseCommand) GetRetentionPolicy() *RetentionPolicyInfo

func (*CreateDatabaseCommand) ProtoMessage 

func (*CreateDatabaseCommand) ProtoMessage()

func (*CreateDatabaseCommand) ProtoReflect added in v2.2.0 

func (x *CreateDatabaseCommand) ProtoReflect() protoreflect.Message

func (*CreateDatabaseCommand) Reset 

func (x *CreateDatabaseCommand) Reset()

func (*CreateDatabaseCommand) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*CreateMetaNodeCommand) Descriptor deprecated 

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

Deprecated: Use CreateMetaNodeCommand.ProtoReflect.Descriptor instead.

func (*CreateMetaNodeCommand) GetHTTPAddr 

func (x *CreateMetaNodeCommand) GetHTTPAddr() string

func (*CreateMetaNodeCommand) GetRand 

func (x *CreateMetaNodeCommand) GetRand() uint64

func (*CreateMetaNodeCommand) GetTCPAddr 

func (x *CreateMetaNodeCommand) GetTCPAddr() string

func (*CreateMetaNodeCommand) ProtoMessage 

func (*CreateMetaNodeCommand) ProtoMessage()

func (*CreateMetaNodeCommand) ProtoReflect added in v2.2.0 

func (x *CreateMetaNodeCommand) ProtoReflect() protoreflect.Message

func (*CreateMetaNodeCommand) Reset 

func (x *CreateMetaNodeCommand) Reset()

func (*CreateMetaNodeCommand) String 

func (x *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"`
	// contains filtered or unexported fields
}

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

func (*CreateNodeCommand) Descriptor deprecated 

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

Deprecated: Use CreateNodeCommand.ProtoReflect.Descriptor instead.

func (*CreateNodeCommand) GetHost 

func (x *CreateNodeCommand) GetHost() string

func (*CreateNodeCommand) GetRand 

func (x *CreateNodeCommand) GetRand() uint64

func (*CreateNodeCommand) ProtoMessage 

func (*CreateNodeCommand) ProtoMessage()

func (*CreateNodeCommand) ProtoReflect added in v2.2.0 

func (x *CreateNodeCommand) ProtoReflect() protoreflect.Message

func (*CreateNodeCommand) Reset 

func (x *CreateNodeCommand) Reset()

func (*CreateNodeCommand) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*CreateRetentionPolicyCommand) Descriptor deprecated 

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

Deprecated: Use CreateRetentionPolicyCommand.ProtoReflect.Descriptor instead.

func (*CreateRetentionPolicyCommand) GetDatabase 

func (x *CreateRetentionPolicyCommand) GetDatabase() string

func (*CreateRetentionPolicyCommand) GetRetentionPolicy 

func (x *CreateRetentionPolicyCommand) GetRetentionPolicy() *RetentionPolicyInfo

func (*CreateRetentionPolicyCommand) ProtoMessage 

func (*CreateRetentionPolicyCommand) ProtoMessage()

func (*CreateRetentionPolicyCommand) ProtoReflect added in v2.2.0 

func (x *CreateRetentionPolicyCommand) ProtoReflect() protoreflect.Message

func (*CreateRetentionPolicyCommand) Reset 

func (x *CreateRetentionPolicyCommand) Reset()

func (*CreateRetentionPolicyCommand) String 

func (x *CreateRetentionPolicyCommand) String() 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"`
	// contains filtered or unexported fields
}

func (*CreateShardGroupCommand) Descriptor deprecated 

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

Deprecated: Use CreateShardGroupCommand.ProtoReflect.Descriptor instead.

func (*CreateShardGroupCommand) GetDatabase 

func (x *CreateShardGroupCommand) GetDatabase() string

func (*CreateShardGroupCommand) GetPolicy 

func (x *CreateShardGroupCommand) GetPolicy() string

func (*CreateShardGroupCommand) GetTimestamp 

func (x *CreateShardGroupCommand) GetTimestamp() int64

func (*CreateShardGroupCommand) ProtoMessage 

func (*CreateShardGroupCommand) ProtoMessage()

func (*CreateShardGroupCommand) ProtoReflect added in v2.2.0 

func (x *CreateShardGroupCommand) ProtoReflect() protoreflect.Message

func (*CreateShardGroupCommand) Reset 

func (x *CreateShardGroupCommand) Reset()

func (*CreateShardGroupCommand) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*CreateSubscriptionCommand) Descriptor deprecated 

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

Deprecated: Use CreateSubscriptionCommand.ProtoReflect.Descriptor instead.

func (*CreateSubscriptionCommand) GetDatabase 

func (x *CreateSubscriptionCommand) GetDatabase() string

func (*CreateSubscriptionCommand) GetDestinations 

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

func (*CreateSubscriptionCommand) GetMode 

func (x *CreateSubscriptionCommand) GetMode() string

func (*CreateSubscriptionCommand) GetName 

func (x *CreateSubscriptionCommand) GetName() string

func (*CreateSubscriptionCommand) GetRetentionPolicy 

func (x *CreateSubscriptionCommand) GetRetentionPolicy() string

func (*CreateSubscriptionCommand) ProtoMessage 

func (*CreateSubscriptionCommand) ProtoMessage()

func (*CreateSubscriptionCommand) ProtoReflect added in v2.2.0 

func (x *CreateSubscriptionCommand) ProtoReflect() protoreflect.Message

func (*CreateSubscriptionCommand) Reset 

func (x *CreateSubscriptionCommand) Reset()

func (*CreateSubscriptionCommand) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*CreateUserCommand) Descriptor deprecated 

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

Deprecated: Use CreateUserCommand.ProtoReflect.Descriptor instead.

func (*CreateUserCommand) GetAdmin 

func (x *CreateUserCommand) GetAdmin() bool

func (*CreateUserCommand) GetHash 

func (x *CreateUserCommand) GetHash() string

func (*CreateUserCommand) GetName 

func (x *CreateUserCommand) GetName() string

func (*CreateUserCommand) ProtoMessage 

func (*CreateUserCommand) ProtoMessage()

func (*CreateUserCommand) ProtoReflect added in v2.2.0 

func (x *CreateUserCommand) ProtoReflect() protoreflect.Message

func (*CreateUserCommand) Reset 

func (x *CreateUserCommand) Reset()

func (*CreateUserCommand) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*Data) Descriptor deprecated 

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

Deprecated: Use Data.ProtoReflect.Descriptor instead.

func (*Data) GetClusterID 

func (x *Data) GetClusterID() uint64

func (*Data) GetDataNodes 

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

func (*Data) GetDatabases 

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

func (*Data) GetIndex 

func (x *Data) GetIndex() uint64

func (*Data) GetMaxNodeID 

func (x *Data) GetMaxNodeID() uint64

func (*Data) GetMaxShardGroupID 

func (x *Data) GetMaxShardGroupID() uint64

func (*Data) GetMaxShardID 

func (x *Data) GetMaxShardID() uint64

func (*Data) GetMetaNodes 

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

func (*Data) GetNodes 

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

func (*Data) GetTerm 

func (x *Data) GetTerm() uint64

func (*Data) GetUsers 

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

func (*Data) ProtoMessage 

func (*Data) ProtoMessage()

func (*Data) ProtoReflect added in v2.2.0 

func (x *Data) ProtoReflect() protoreflect.Message

func (*Data) Reset 

func (x *Data) Reset()

func (*Data) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*DatabaseInfo) Descriptor deprecated 

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

Deprecated: Use DatabaseInfo.ProtoReflect.Descriptor instead.

func (*DatabaseInfo) GetContinuousQueries 

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

func (*DatabaseInfo) GetDefaultRetentionPolicy 

func (x *DatabaseInfo) GetDefaultRetentionPolicy() string

func (*DatabaseInfo) GetName 

func (x *DatabaseInfo) GetName() string

func (*DatabaseInfo) GetRetentionPolicies 

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

func (*DatabaseInfo) ProtoMessage 

func (*DatabaseInfo) ProtoMessage()

func (*DatabaseInfo) ProtoReflect added in v2.2.0 

func (x *DatabaseInfo) ProtoReflect() protoreflect.Message

func (*DatabaseInfo) Reset 

func (x *DatabaseInfo) Reset()

func (*DatabaseInfo) String 

func (x *DatabaseInfo) String() string

type DeleteDataNodeCommand 

type DeleteDataNodeCommand struct {
	ID *uint64 `protobuf:"varint,1,req,name=ID" json:"ID,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteDataNodeCommand) Descriptor deprecated 

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

Deprecated: Use DeleteDataNodeCommand.ProtoReflect.Descriptor instead.

func (*DeleteDataNodeCommand) GetID 

func (x *DeleteDataNodeCommand) GetID() uint64

func (*DeleteDataNodeCommand) ProtoMessage 

func (*DeleteDataNodeCommand) ProtoMessage()

func (*DeleteDataNodeCommand) ProtoReflect added in v2.2.0 

func (x *DeleteDataNodeCommand) ProtoReflect() protoreflect.Message

func (*DeleteDataNodeCommand) Reset 

func (x *DeleteDataNodeCommand) Reset()

func (*DeleteDataNodeCommand) String 

func (x *DeleteDataNodeCommand) String() string

type DeleteMetaNodeCommand 

type DeleteMetaNodeCommand struct {
	ID *uint64 `protobuf:"varint,1,req,name=ID" json:"ID,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteMetaNodeCommand) Descriptor deprecated 

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

Deprecated: Use DeleteMetaNodeCommand.ProtoReflect.Descriptor instead.

func (*DeleteMetaNodeCommand) GetID 

func (x *DeleteMetaNodeCommand) GetID() uint64

func (*DeleteMetaNodeCommand) ProtoMessage 

func (*DeleteMetaNodeCommand) ProtoMessage()

func (*DeleteMetaNodeCommand) ProtoReflect added in v2.2.0 

func (x *DeleteMetaNodeCommand) ProtoReflect() protoreflect.Message

func (*DeleteMetaNodeCommand) Reset 

func (x *DeleteMetaNodeCommand) Reset()

func (*DeleteMetaNodeCommand) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*DeleteNodeCommand) Descriptor deprecated 

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

Deprecated: Use DeleteNodeCommand.ProtoReflect.Descriptor instead.

func (*DeleteNodeCommand) GetForce 

func (x *DeleteNodeCommand) GetForce() bool

func (*DeleteNodeCommand) GetID 

func (x *DeleteNodeCommand) GetID() uint64

func (*DeleteNodeCommand) ProtoMessage 

func (*DeleteNodeCommand) ProtoMessage()

func (*DeleteNodeCommand) ProtoReflect added in v2.2.0 

func (x *DeleteNodeCommand) ProtoReflect() protoreflect.Message

func (*DeleteNodeCommand) Reset 

func (x *DeleteNodeCommand) Reset()

func (*DeleteNodeCommand) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*DeleteShardGroupCommand) Descriptor deprecated 

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

Deprecated: Use DeleteShardGroupCommand.ProtoReflect.Descriptor instead.

func (*DeleteShardGroupCommand) GetDatabase 

func (x *DeleteShardGroupCommand) GetDatabase() string

func (*DeleteShardGroupCommand) GetPolicy 

func (x *DeleteShardGroupCommand) GetPolicy() string

func (*DeleteShardGroupCommand) GetShardGroupID 

func (x *DeleteShardGroupCommand) GetShardGroupID() uint64

func (*DeleteShardGroupCommand) ProtoMessage 

func (*DeleteShardGroupCommand) ProtoMessage()

func (*DeleteShardGroupCommand) ProtoReflect added in v2.2.0 

func (x *DeleteShardGroupCommand) ProtoReflect() protoreflect.Message

func (*DeleteShardGroupCommand) Reset 

func (x *DeleteShardGroupCommand) Reset()

func (*DeleteShardGroupCommand) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*DropContinuousQueryCommand) Descriptor deprecated 

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

Deprecated: Use DropContinuousQueryCommand.ProtoReflect.Descriptor instead.

func (*DropContinuousQueryCommand) GetDatabase 

func (x *DropContinuousQueryCommand) GetDatabase() string

func (*DropContinuousQueryCommand) GetName 

func (x *DropContinuousQueryCommand) GetName() string

func (*DropContinuousQueryCommand) ProtoMessage 

func (*DropContinuousQueryCommand) ProtoMessage()

func (*DropContinuousQueryCommand) ProtoReflect added in v2.2.0 

func (x *DropContinuousQueryCommand) ProtoReflect() protoreflect.Message

func (*DropContinuousQueryCommand) Reset 

func (x *DropContinuousQueryCommand) Reset()

func (*DropContinuousQueryCommand) String 

func (x *DropContinuousQueryCommand) String() string

type DropDatabaseCommand 

type DropDatabaseCommand struct {
	Name *string `protobuf:"bytes,1,req,name=Name" json:"Name,omitempty"`
	// contains filtered or unexported fields
}

func (*DropDatabaseCommand) Descriptor deprecated 

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

Deprecated: Use DropDatabaseCommand.ProtoReflect.Descriptor instead.

func (*DropDatabaseCommand) GetName 

func (x *DropDatabaseCommand) GetName() string

func (*DropDatabaseCommand) ProtoMessage 

func (*DropDatabaseCommand) ProtoMessage()

func (*DropDatabaseCommand) ProtoReflect added in v2.2.0 

func (x *DropDatabaseCommand) ProtoReflect() protoreflect.Message

func (*DropDatabaseCommand) Reset 

func (x *DropDatabaseCommand) Reset()

func (*DropDatabaseCommand) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*DropRetentionPolicyCommand) Descriptor deprecated 

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

Deprecated: Use DropRetentionPolicyCommand.ProtoReflect.Descriptor instead.

func (*DropRetentionPolicyCommand) GetDatabase 

func (x *DropRetentionPolicyCommand) GetDatabase() string

func (*DropRetentionPolicyCommand) GetName 

func (x *DropRetentionPolicyCommand) GetName() string

func (*DropRetentionPolicyCommand) ProtoMessage 

func (*DropRetentionPolicyCommand) ProtoMessage()

func (*DropRetentionPolicyCommand) ProtoReflect added in v2.2.0 

func (x *DropRetentionPolicyCommand) ProtoReflect() protoreflect.Message

func (*DropRetentionPolicyCommand) Reset 

func (x *DropRetentionPolicyCommand) Reset()

func (*DropRetentionPolicyCommand) String 

func (x *DropRetentionPolicyCommand) String() string

type DropShardCommand 

type DropShardCommand struct {
	ID *uint64 `protobuf:"varint,1,req,name=ID" json:"ID,omitempty"`
	// contains filtered or unexported fields
}

func (*DropShardCommand) Descriptor deprecated 

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

Deprecated: Use DropShardCommand.ProtoReflect.Descriptor instead.

func (*DropShardCommand) GetID 

func (x *DropShardCommand) GetID() uint64

func (*DropShardCommand) ProtoMessage 

func (*DropShardCommand) ProtoMessage()

func (*DropShardCommand) ProtoReflect added in v2.2.0 

func (x *DropShardCommand) ProtoReflect() protoreflect.Message

func (*DropShardCommand) Reset 

func (x *DropShardCommand) Reset()

func (*DropShardCommand) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*DropSubscriptionCommand) Descriptor deprecated 

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

Deprecated: Use DropSubscriptionCommand.ProtoReflect.Descriptor instead.

func (*DropSubscriptionCommand) GetDatabase 

func (x *DropSubscriptionCommand) GetDatabase() string

func (*DropSubscriptionCommand) GetName 

func (x *DropSubscriptionCommand) GetName() string

func (*DropSubscriptionCommand) GetRetentionPolicy 

func (x *DropSubscriptionCommand) GetRetentionPolicy() string

func (*DropSubscriptionCommand) ProtoMessage 

func (*DropSubscriptionCommand) ProtoMessage()

func (*DropSubscriptionCommand) ProtoReflect added in v2.2.0 

func (x *DropSubscriptionCommand) ProtoReflect() protoreflect.Message

func (*DropSubscriptionCommand) Reset 

func (x *DropSubscriptionCommand) Reset()

func (*DropSubscriptionCommand) String 

func (x *DropSubscriptionCommand) String() string

type DropUserCommand 

type DropUserCommand struct {
	Name *string `protobuf:"bytes,1,req,name=Name" json:"Name,omitempty"`
	// contains filtered or unexported fields
}

func (*DropUserCommand) Descriptor deprecated 

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

Deprecated: Use DropUserCommand.ProtoReflect.Descriptor instead.

func (*DropUserCommand) GetName 

func (x *DropUserCommand) GetName() string

func (*DropUserCommand) ProtoMessage 

func (*DropUserCommand) ProtoMessage()

func (*DropUserCommand) ProtoReflect added in v2.2.0 

func (x *DropUserCommand) ProtoReflect() protoreflect.Message

func (*DropUserCommand) Reset 

func (x *DropUserCommand) Reset()

func (*DropUserCommand) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*NodeInfo) Descriptor deprecated 

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

Deprecated: Use NodeInfo.ProtoReflect.Descriptor instead.

func (*NodeInfo) GetHost 

func (x *NodeInfo) GetHost() string

func (*NodeInfo) GetID 

func (x *NodeInfo) GetID() uint64

func (*NodeInfo) GetTCPHost 

func (x *NodeInfo) GetTCPHost() string

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) ProtoReflect added in v2.2.0 

func (x *NodeInfo) ProtoReflect() protoreflect.Message

func (*NodeInfo) Reset 

func (x *NodeInfo) Reset()

func (*NodeInfo) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*RemovePeerCommand) Descriptor deprecated 

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

Deprecated: Use RemovePeerCommand.ProtoReflect.Descriptor instead.

func (*RemovePeerCommand) GetAddr 

func (x *RemovePeerCommand) GetAddr() string

func (*RemovePeerCommand) GetID 

func (x *RemovePeerCommand) GetID() uint64

func (*RemovePeerCommand) ProtoMessage 

func (*RemovePeerCommand) ProtoMessage()

func (*RemovePeerCommand) ProtoReflect added in v2.2.0 

func (x *RemovePeerCommand) ProtoReflect() protoreflect.Message

func (*RemovePeerCommand) Reset 

func (x *RemovePeerCommand) Reset()

func (*RemovePeerCommand) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*Response) Descriptor deprecated 

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

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetError 

func (x *Response) GetError() string

func (*Response) GetIndex 

func (x *Response) GetIndex() uint64

func (*Response) GetOK 

func (x *Response) GetOK() bool

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect added in v2.2.0 

func (x *Response) ProtoReflect() protoreflect.Message

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*RetentionPolicyInfo) Descriptor deprecated 

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

Deprecated: Use RetentionPolicyInfo.ProtoReflect.Descriptor instead.

func (*RetentionPolicyInfo) GetDuration 

func (x *RetentionPolicyInfo) GetDuration() int64

func (*RetentionPolicyInfo) GetName 

func (x *RetentionPolicyInfo) GetName() string

func (*RetentionPolicyInfo) GetReplicaN 

func (x *RetentionPolicyInfo) GetReplicaN() uint32

func (*RetentionPolicyInfo) GetShardGroupDuration 

func (x *RetentionPolicyInfo) GetShardGroupDuration() int64

func (*RetentionPolicyInfo) GetShardGroups 

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

func (*RetentionPolicyInfo) GetSubscriptions 

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

func (*RetentionPolicyInfo) ProtoMessage 

func (*RetentionPolicyInfo) ProtoMessage()

func (*RetentionPolicyInfo) ProtoReflect added in v2.2.0 

func (x *RetentionPolicyInfo) ProtoReflect() protoreflect.Message

func (*RetentionPolicyInfo) Reset 

func (x *RetentionPolicyInfo) Reset()

func (*RetentionPolicyInfo) String 

func (x *RetentionPolicyInfo) String() string

type RetentionPolicySpec 

type RetentionPolicySpec struct {
	Name               *string `protobuf:"bytes,1,opt,name=Name" json:"Name,omitempty"`
	Duration           *int64  `protobuf:"varint,2,opt,name=Duration" json:"Duration,omitempty"`
	ShardGroupDuration *int64  `protobuf:"varint,3,opt,name=ShardGroupDuration" json:"ShardGroupDuration,omitempty"`
	ReplicaN           *uint32 `protobuf:"varint,4,opt,name=ReplicaN" json:"ReplicaN,omitempty"`
	// contains filtered or unexported fields
}

func (*RetentionPolicySpec) Descriptor deprecated 

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

Deprecated: Use RetentionPolicySpec.ProtoReflect.Descriptor instead.

func (*RetentionPolicySpec) GetDuration 

func (x *RetentionPolicySpec) GetDuration() int64

func (*RetentionPolicySpec) GetName 

func (x *RetentionPolicySpec) GetName() string

func (*RetentionPolicySpec) GetReplicaN 

func (x *RetentionPolicySpec) GetReplicaN() uint32

func (*RetentionPolicySpec) GetShardGroupDuration 

func (x *RetentionPolicySpec) GetShardGroupDuration() int64

func (*RetentionPolicySpec) ProtoMessage 

func (*RetentionPolicySpec) ProtoMessage()

func (*RetentionPolicySpec) ProtoReflect added in v2.2.0 

func (x *RetentionPolicySpec) ProtoReflect() protoreflect.Message

func (*RetentionPolicySpec) Reset 

func (x *RetentionPolicySpec) Reset()

func (*RetentionPolicySpec) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*SetAdminPrivilegeCommand) Descriptor deprecated 

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

Deprecated: Use SetAdminPrivilegeCommand.ProtoReflect.Descriptor instead.

func (*SetAdminPrivilegeCommand) GetAdmin 

func (x *SetAdminPrivilegeCommand) GetAdmin() bool

func (*SetAdminPrivilegeCommand) GetUsername 

func (x *SetAdminPrivilegeCommand) GetUsername() string

func (*SetAdminPrivilegeCommand) ProtoMessage 

func (*SetAdminPrivilegeCommand) ProtoMessage()

func (*SetAdminPrivilegeCommand) ProtoReflect added in v2.2.0 

func (x *SetAdminPrivilegeCommand) ProtoReflect() protoreflect.Message

func (*SetAdminPrivilegeCommand) Reset 

func (x *SetAdminPrivilegeCommand) Reset()

func (*SetAdminPrivilegeCommand) String 

func (x *SetAdminPrivilegeCommand) String() string

type SetDataCommand 

type SetDataCommand struct {
	Data *Data `protobuf:"bytes,1,req,name=Data" json:"Data,omitempty"`
	// contains filtered or unexported fields
}

func (*SetDataCommand) Descriptor deprecated 

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

Deprecated: Use SetDataCommand.ProtoReflect.Descriptor instead.

func (*SetDataCommand) GetData 

func (x *SetDataCommand) GetData() *Data

func (*SetDataCommand) ProtoMessage 

func (*SetDataCommand) ProtoMessage()

func (*SetDataCommand) ProtoReflect added in v2.2.0 

func (x *SetDataCommand) ProtoReflect() protoreflect.Message

func (*SetDataCommand) Reset 

func (x *SetDataCommand) Reset()

func (*SetDataCommand) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*SetDefaultRetentionPolicyCommand) Descriptor deprecated 

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

Deprecated: Use SetDefaultRetentionPolicyCommand.ProtoReflect.Descriptor instead.

func (*SetDefaultRetentionPolicyCommand) GetDatabase 

func (x *SetDefaultRetentionPolicyCommand) GetDatabase() string

func (*SetDefaultRetentionPolicyCommand) GetName 

func (x *SetDefaultRetentionPolicyCommand) GetName() string

func (*SetDefaultRetentionPolicyCommand) ProtoMessage 

func (*SetDefaultRetentionPolicyCommand) ProtoMessage()

func (*SetDefaultRetentionPolicyCommand) ProtoReflect added in v2.2.0 

func (x *SetDefaultRetentionPolicyCommand) ProtoReflect() protoreflect.Message

func (*SetDefaultRetentionPolicyCommand) Reset 

func (x *SetDefaultRetentionPolicyCommand) Reset()

func (*SetDefaultRetentionPolicyCommand) String 

func (x *SetDefaultRetentionPolicyCommand) String() 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"`
	// contains filtered or unexported fields
}

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 deprecated 

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

Deprecated: Use SetMetaNodeCommand.ProtoReflect.Descriptor instead.

func (*SetMetaNodeCommand) GetHTTPAddr 

func (x *SetMetaNodeCommand) GetHTTPAddr() string

func (*SetMetaNodeCommand) GetRand 

func (x *SetMetaNodeCommand) GetRand() uint64

func (*SetMetaNodeCommand) GetTCPAddr 

func (x *SetMetaNodeCommand) GetTCPAddr() string

func (*SetMetaNodeCommand) ProtoMessage 

func (*SetMetaNodeCommand) ProtoMessage()

func (*SetMetaNodeCommand) ProtoReflect added in v2.2.0 

func (x *SetMetaNodeCommand) ProtoReflect() protoreflect.Message

func (*SetMetaNodeCommand) Reset 

func (x *SetMetaNodeCommand) Reset()

func (*SetMetaNodeCommand) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*SetPrivilegeCommand) Descriptor deprecated 

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

Deprecated: Use SetPrivilegeCommand.ProtoReflect.Descriptor instead.

func (*SetPrivilegeCommand) GetDatabase 

func (x *SetPrivilegeCommand) GetDatabase() string

func (*SetPrivilegeCommand) GetPrivilege 

func (x *SetPrivilegeCommand) GetPrivilege() int32

func (*SetPrivilegeCommand) GetUsername 

func (x *SetPrivilegeCommand) GetUsername() string

func (*SetPrivilegeCommand) ProtoMessage 

func (*SetPrivilegeCommand) ProtoMessage()

func (*SetPrivilegeCommand) ProtoReflect added in v2.2.0 

func (x *SetPrivilegeCommand) ProtoReflect() protoreflect.Message

func (*SetPrivilegeCommand) Reset 

func (x *SetPrivilegeCommand) Reset()

func (*SetPrivilegeCommand) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*ShardGroupInfo) Descriptor deprecated 

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

Deprecated: Use ShardGroupInfo.ProtoReflect.Descriptor instead.

func (*ShardGroupInfo) GetDeletedAt 

func (x *ShardGroupInfo) GetDeletedAt() int64

func (*ShardGroupInfo) GetEndTime 

func (x *ShardGroupInfo) GetEndTime() int64

func (*ShardGroupInfo) GetID 

func (x *ShardGroupInfo) GetID() uint64

func (*ShardGroupInfo) GetShards 

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

func (*ShardGroupInfo) GetStartTime 

func (x *ShardGroupInfo) GetStartTime() int64

func (*ShardGroupInfo) GetTruncatedAt 

func (x *ShardGroupInfo) GetTruncatedAt() int64

func (*ShardGroupInfo) ProtoMessage 

func (*ShardGroupInfo) ProtoMessage()

func (*ShardGroupInfo) ProtoReflect added in v2.2.0 

func (x *ShardGroupInfo) ProtoReflect() protoreflect.Message

func (*ShardGroupInfo) Reset 

func (x *ShardGroupInfo) Reset()

func (*ShardGroupInfo) String 

func (x *ShardGroupInfo) String() string

type ShardInfo 

type ShardInfo struct {
	ID *uint64 `protobuf:"varint,1,req,name=ID" json:"ID,omitempty"`
	// Deprecated: Do not use.
	OwnerIDs []uint64      `protobuf:"varint,2,rep,name=OwnerIDs" json:"OwnerIDs,omitempty"`
	Owners   []*ShardOwner `protobuf:"bytes,3,rep,name=Owners" json:"Owners,omitempty"`
	// contains filtered or unexported fields
}

func (*ShardInfo) Descriptor deprecated 

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

Deprecated: Use ShardInfo.ProtoReflect.Descriptor instead.

func (*ShardInfo) GetID 

func (x *ShardInfo) GetID() uint64

func (*ShardInfo) GetOwnerIDs deprecated 

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

Deprecated: Do not use.

func (*ShardInfo) GetOwners 

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

func (*ShardInfo) ProtoMessage 

func (*ShardInfo) ProtoMessage()

func (*ShardInfo) ProtoReflect added in v2.2.0 

func (x *ShardInfo) ProtoReflect() protoreflect.Message

func (*ShardInfo) Reset 

func (x *ShardInfo) Reset()

func (*ShardInfo) String 

func (x *ShardInfo) String() string

type ShardOwner 

type ShardOwner struct {
	NodeID *uint64 `protobuf:"varint,1,req,name=NodeID" json:"NodeID,omitempty"`
	// contains filtered or unexported fields
}

func (*ShardOwner) Descriptor deprecated 

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

Deprecated: Use ShardOwner.ProtoReflect.Descriptor instead.

func (*ShardOwner) GetNodeID 

func (x *ShardOwner) GetNodeID() uint64

func (*ShardOwner) ProtoMessage 

func (*ShardOwner) ProtoMessage()

func (*ShardOwner) ProtoReflect added in v2.2.0 

func (x *ShardOwner) ProtoReflect() protoreflect.Message

func (*ShardOwner) Reset 

func (x *ShardOwner) Reset()

func (*ShardOwner) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*SubscriptionInfo) Descriptor deprecated 

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

Deprecated: Use SubscriptionInfo.ProtoReflect.Descriptor instead.

func (*SubscriptionInfo) GetDestinations 

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

func (*SubscriptionInfo) GetMode 

func (x *SubscriptionInfo) GetMode() string

func (*SubscriptionInfo) GetName 

func (x *SubscriptionInfo) GetName() string

func (*SubscriptionInfo) ProtoMessage 

func (*SubscriptionInfo) ProtoMessage()

func (*SubscriptionInfo) ProtoReflect added in v2.2.0 

func (x *SubscriptionInfo) ProtoReflect() protoreflect.Message

func (*SubscriptionInfo) Reset 

func (x *SubscriptionInfo) Reset()

func (*SubscriptionInfo) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*UpdateDataNodeCommand) Descriptor deprecated 

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

Deprecated: Use UpdateDataNodeCommand.ProtoReflect.Descriptor instead.

func (*UpdateDataNodeCommand) GetHost 

func (x *UpdateDataNodeCommand) GetHost() string

func (*UpdateDataNodeCommand) GetID 

func (x *UpdateDataNodeCommand) GetID() uint64

func (*UpdateDataNodeCommand) GetTCPHost 

func (x *UpdateDataNodeCommand) GetTCPHost() string

func (*UpdateDataNodeCommand) ProtoMessage 

func (*UpdateDataNodeCommand) ProtoMessage()

func (*UpdateDataNodeCommand) ProtoReflect added in v2.2.0 

func (x *UpdateDataNodeCommand) ProtoReflect() protoreflect.Message

func (*UpdateDataNodeCommand) Reset 

func (x *UpdateDataNodeCommand) Reset()

func (*UpdateDataNodeCommand) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*UpdateNodeCommand) Descriptor deprecated 

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

Deprecated: Use UpdateNodeCommand.ProtoReflect.Descriptor instead.

func (*UpdateNodeCommand) GetHost 

func (x *UpdateNodeCommand) GetHost() string

func (*UpdateNodeCommand) GetID 

func (x *UpdateNodeCommand) GetID() uint64

func (*UpdateNodeCommand) ProtoMessage 

func (*UpdateNodeCommand) ProtoMessage()

func (*UpdateNodeCommand) ProtoReflect added in v2.2.0 

func (x *UpdateNodeCommand) ProtoReflect() protoreflect.Message

func (*UpdateNodeCommand) Reset 

func (x *UpdateNodeCommand) Reset()

func (*UpdateNodeCommand) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*UpdateRetentionPolicyCommand) Descriptor deprecated 

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

Deprecated: Use UpdateRetentionPolicyCommand.ProtoReflect.Descriptor instead.

func (*UpdateRetentionPolicyCommand) GetDatabase 

func (x *UpdateRetentionPolicyCommand) GetDatabase() string

func (*UpdateRetentionPolicyCommand) GetDuration 

func (x *UpdateRetentionPolicyCommand) GetDuration() int64

func (*UpdateRetentionPolicyCommand) GetName 

func (x *UpdateRetentionPolicyCommand) GetName() string

func (*UpdateRetentionPolicyCommand) GetNewName 

func (x *UpdateRetentionPolicyCommand) GetNewName() string

func (*UpdateRetentionPolicyCommand) GetReplicaN 

func (x *UpdateRetentionPolicyCommand) GetReplicaN() uint32

func (*UpdateRetentionPolicyCommand) ProtoMessage 

func (*UpdateRetentionPolicyCommand) ProtoMessage()

func (*UpdateRetentionPolicyCommand) ProtoReflect added in v2.2.0 

func (x *UpdateRetentionPolicyCommand) ProtoReflect() protoreflect.Message

func (*UpdateRetentionPolicyCommand) Reset 

func (x *UpdateRetentionPolicyCommand) Reset()

func (*UpdateRetentionPolicyCommand) String 

func (x *UpdateRetentionPolicyCommand) String() 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"`
	// contains filtered or unexported fields
}

func (*UpdateUserCommand) Descriptor deprecated 

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

Deprecated: Use UpdateUserCommand.ProtoReflect.Descriptor instead.

func (*UpdateUserCommand) GetHash 

func (x *UpdateUserCommand) GetHash() string

func (*UpdateUserCommand) GetName 

func (x *UpdateUserCommand) GetName() string

func (*UpdateUserCommand) ProtoMessage 

func (*UpdateUserCommand) ProtoMessage()

func (*UpdateUserCommand) ProtoReflect added in v2.2.0 

func (x *UpdateUserCommand) ProtoReflect() protoreflect.Message

func (*UpdateUserCommand) Reset 

func (x *UpdateUserCommand) Reset()

func (*UpdateUserCommand) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*UserInfo) Descriptor deprecated 

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

Deprecated: Use UserInfo.ProtoReflect.Descriptor instead.

func (*UserInfo) GetAdmin 

func (x *UserInfo) GetAdmin() bool

func (*UserInfo) GetHash 

func (x *UserInfo) GetHash() string

func (*UserInfo) GetName 

func (x *UserInfo) GetName() string

func (*UserInfo) GetPrivileges 

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

func (*UserInfo) ProtoMessage 

func (*UserInfo) ProtoMessage()

func (*UserInfo) ProtoReflect added in v2.2.0 

func (x *UserInfo) ProtoReflect() protoreflect.Message

func (*UserInfo) Reset 

func (x *UserInfo) Reset()

func (*UserInfo) String 

func (x *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"`
	// contains filtered or unexported fields
}

func (*UserPrivilege) Descriptor deprecated 

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

Deprecated: Use UserPrivilege.ProtoReflect.Descriptor instead.

func (*UserPrivilege) GetDatabase 

func (x *UserPrivilege) GetDatabase() string

func (*UserPrivilege) GetPrivilege 

func (x *UserPrivilege) GetPrivilege() int32

func (*UserPrivilege) ProtoMessage 

func (*UserPrivilege) ProtoMessage()

func (*UserPrivilege) ProtoReflect added in v2.2.0 

func (x *UserPrivilege) ProtoReflect() protoreflect.Message

func (*UserPrivilege) Reset 

func (x *UserPrivilege) Reset()

func (*UserPrivilege) String 

func (x *UserPrivilege) String() string

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.