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

meta

package
v1.13.2 Latest Latest
Warning

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

 Go to latest Published: Oct 29, 2026 License: MIT Imports: 5 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 added in v1.0.0 

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 v1.9.6 

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 v1.9.6 

func (Command_Type) Descriptor() protoreflect.EnumDescriptor

func (Command_Type) Enum 

func (x Command_Type) Enum() *Command_Type

func (Command_Type) EnumDescriptor deprecated added in v1.0.0 

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

Deprecated: Use Command_Type.Descriptor instead.

func (Command_Type) Number added in v1.9.6 

func (x Command_Type) Number() protoreflect.EnumNumber

func (Command_Type) String 

func (x Command_Type) String() string

func (Command_Type) Type added in v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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

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

Deprecated: Use CreateDatabaseCommand.ProtoReflect.Descriptor instead.

func (*CreateDatabaseCommand) GetName 

func (x *CreateDatabaseCommand) GetName() string

func (*CreateDatabaseCommand) GetRetentionPolicy added in v0.10.1 

func (x *CreateDatabaseCommand) GetRetentionPolicy() *RetentionPolicyInfo

func (*CreateDatabaseCommand) ProtoMessage 

func (*CreateDatabaseCommand) ProtoMessage()

func (*CreateDatabaseCommand) ProtoReflect added in v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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

func (*DropRetentionPolicyCommand) Reset 

func (x *DropRetentionPolicyCommand) Reset()

func (*DropRetentionPolicyCommand) String 

func (x *DropRetentionPolicyCommand) String() string

type DropShardCommand added in v0.12.0 

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

func (*DropShardCommand) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use DropShardCommand.ProtoReflect.Descriptor instead.

func (*DropShardCommand) GetID added in v0.12.0 

func (x *DropShardCommand) GetID() uint64

func (*DropShardCommand) ProtoMessage added in v0.12.0 

func (*DropShardCommand) ProtoMessage()

func (*DropShardCommand) ProtoReflect added in v1.9.6 

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

func (*DropShardCommand) Reset added in v0.12.0 

func (x *DropShardCommand) Reset()

func (*DropShardCommand) String added in v0.12.0 

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

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 v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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"`
	FutureWriteLimit   *int64              `protobuf:"varint,7,opt,name=FutureWriteLimit" json:"FutureWriteLimit,omitempty"`
	PastWriteLimit     *int64              `protobuf:"varint,8,opt,name=PastWriteLimit" json:"PastWriteLimit,omitempty"`
	// contains filtered or unexported fields
}

func (*RetentionPolicyInfo) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use RetentionPolicyInfo.ProtoReflect.Descriptor instead.

func (*RetentionPolicyInfo) GetDuration 

func (x *RetentionPolicyInfo) GetDuration() int64

func (*RetentionPolicyInfo) GetFutureWriteLimit added in v1.12.0 

func (x *RetentionPolicyInfo) GetFutureWriteLimit() int64

func (*RetentionPolicyInfo) GetName 

func (x *RetentionPolicyInfo) GetName() string

func (*RetentionPolicyInfo) GetPastWriteLimit added in v1.12.0 

func (x *RetentionPolicyInfo) GetPastWriteLimit() int64

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 v1.9.6 

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

func (*RetentionPolicyInfo) Reset 

func (x *RetentionPolicyInfo) Reset()

func (*RetentionPolicyInfo) String 

func (x *RetentionPolicyInfo) String() string

type RetentionPolicySpec added in v1.0.0 

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

func (*RetentionPolicySpec) Descriptor deprecated added in v1.0.0 

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

Deprecated: Use RetentionPolicySpec.ProtoReflect.Descriptor instead.

func (*RetentionPolicySpec) GetDuration added in v1.0.0 

func (x *RetentionPolicySpec) GetDuration() int64

func (*RetentionPolicySpec) GetFutureWriteLimit added in v1.12.0 

func (x *RetentionPolicySpec) GetFutureWriteLimit() int64

func (*RetentionPolicySpec) GetName added in v1.0.0 

func (x *RetentionPolicySpec) GetName() string

func (*RetentionPolicySpec) GetPastWriteLimit added in v1.12.0 

func (x *RetentionPolicySpec) GetPastWriteLimit() int64

func (*RetentionPolicySpec) GetReplicaN added in v1.0.0 

func (x *RetentionPolicySpec) GetReplicaN() uint32

func (*RetentionPolicySpec) GetShardGroupDuration added in v1.0.0 

func (x *RetentionPolicySpec) GetShardGroupDuration() int64

func (*RetentionPolicySpec) ProtoMessage added in v1.0.0 

func (*RetentionPolicySpec) ProtoMessage()

func (*RetentionPolicySpec) ProtoReflect added in v1.9.6 

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

func (*RetentionPolicySpec) Reset added in v1.0.0 

func (x *RetentionPolicySpec) Reset()

func (*RetentionPolicySpec) String added in v1.0.0 

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

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 v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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

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

func (x *ShardGroupInfo) GetTruncatedAt() int64

func (*ShardGroupInfo) ProtoMessage 

func (*ShardGroupInfo) ProtoMessage()

func (*ShardGroupInfo) ProtoReflect added in v1.9.6 

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: Marked as deprecated in internal/meta.proto.
	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 added in v1.0.0 

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: Marked as deprecated in internal/meta.proto.

func (*ShardInfo) GetOwners 

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

func (*ShardInfo) ProtoMessage 

func (*ShardInfo) ProtoMessage()

func (*ShardInfo) ProtoReflect added in v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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

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 v1.9.6 

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.