backup_restore

package

Go to main page

Versions in this module

v2

v2.7.5

Apr 16, 2024

v2.7.4

Apr 5, 2024

v2.7.3

Apr 28, 2023

v2.7.2

Apr 26, 2023

v2.7.1

Apr 5, 2023

v2.7.0

Apr 3, 2023

v2.6.1

Dec 29, 2022

v2.6.0

Dec 12, 2022

v2.5.0

Oct 28, 2022

v2.4.0

Aug 18, 2022

v2.3.0

Mar 18, 2022

v2.2.1

Nov 9, 2021

v2.2.0

Oct 21, 2021

Changes in this version

+ var File_meta_proto protoreflect.FileDescriptor

type Command

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

type Command_Type

+ func (Command_Type) Descriptor() protoreflect.EnumDescriptor

+ func (Command_Type) Type() protoreflect.EnumType

+ func (x Command_Type) Number() protoreflect.EnumNumber

type ContinuousQueryInfo

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

type CreateContinuousQueryCommand

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

type CreateDataNodeCommand

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

type CreateDatabaseCommand

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

type CreateMetaNodeCommand

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

type CreateNodeCommand

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

type CreateRetentionPolicyCommand

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

type CreateShardGroupCommand

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

type CreateSubscriptionCommand

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

type CreateUserCommand

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

type Data

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

type DatabaseInfo

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

type DeleteDataNodeCommand

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

type DeleteMetaNodeCommand

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

type DeleteNodeCommand

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

type DeleteShardGroupCommand

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

type DropContinuousQueryCommand

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

type DropDatabaseCommand

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

type DropRetentionPolicyCommand

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

type DropShardCommand

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

type DropSubscriptionCommand

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

type DropUserCommand

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

type NodeInfo

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

type RemovePeerCommand

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

type Response

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

type RetentionPolicyInfo

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

type RetentionPolicySpec

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

type SetAdminPrivilegeCommand

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

type SetDataCommand

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

type SetDefaultRetentionPolicyCommand

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

type SetMetaNodeCommand

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

type SetPrivilegeCommand

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

type ShardGroupInfo

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

type ShardInfo

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

type ShardOwner

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

type SubscriptionInfo

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

type UpdateDataNodeCommand

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

type UpdateNodeCommand

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

type UpdateRetentionPolicyCommand

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

type UpdateUserCommand

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

type UserInfo

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

type UserPrivilege

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

v2.1.1

Sep 22, 2021

v2.1.0

Jul 29, 2021

Changes in this version

+ const ManifestExtension

+ const ManifestVersion

+ var Command_Type_name = map[int32]string

+ var Command_Type_value = map[string]int32

+ var E_CreateContinuousQueryCommand_Command = &proto.ExtensionDesc

+ var E_CreateDataNodeCommand_Command = &proto.ExtensionDesc

+ var E_CreateDatabaseCommand_Command = &proto.ExtensionDesc

+ var E_CreateMetaNodeCommand_Command = &proto.ExtensionDesc

+ var E_CreateNodeCommand_Command = &proto.ExtensionDesc

+ var E_CreateRetentionPolicyCommand_Command = &proto.ExtensionDesc

+ var E_CreateShardGroupCommand_Command = &proto.ExtensionDesc

+ var E_CreateSubscriptionCommand_Command = &proto.ExtensionDesc

+ var E_CreateUserCommand_Command = &proto.ExtensionDesc

+ var E_DeleteDataNodeCommand_Command = &proto.ExtensionDesc

+ var E_DeleteMetaNodeCommand_Command = &proto.ExtensionDesc

+ var E_DeleteNodeCommand_Command = &proto.ExtensionDesc

+ var E_DeleteShardGroupCommand_Command = &proto.ExtensionDesc

+ var E_DropContinuousQueryCommand_Command = &proto.ExtensionDesc

+ var E_DropDatabaseCommand_Command = &proto.ExtensionDesc

+ var E_DropRetentionPolicyCommand_Command = &proto.ExtensionDesc

+ var E_DropShardCommand_Command = &proto.ExtensionDesc

+ var E_DropSubscriptionCommand_Command = &proto.ExtensionDesc

+ var E_DropUserCommand_Command = &proto.ExtensionDesc

+ var E_RemovePeerCommand_Command = &proto.ExtensionDesc

+ var E_SetAdminPrivilegeCommand_Command = &proto.ExtensionDesc

+ var E_SetDataCommand_Command = &proto.ExtensionDesc

+ var E_SetDefaultRetentionPolicyCommand_Command = &proto.ExtensionDesc

+ var E_SetMetaNodeCommand_Command = &proto.ExtensionDesc

+ var E_SetPrivilegeCommand_Command = &proto.ExtensionDesc

+ var E_UpdateDataNodeCommand_Command = &proto.ExtensionDesc

+ var E_UpdateNodeCommand_Command = &proto.ExtensionDesc

+ var E_UpdateRetentionPolicyCommand_Command = &proto.ExtensionDesc

+ var E_UpdateUserCommand_Command = &proto.ExtensionDesc

+ func ExtractBucketMetadata(boltPath string) ([]api.BucketMetadataManifest, error)

+ func ServerIsLegacy(ctx context.Context, client api.HealthApi) (bool, error)

+ type Command struct

+ Type *Command_Type

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Command) ExtensionRangeArray() []proto.ExtensionRange

+ func (*Command) ProtoMessage()

+ func (m *Command) GetType() Command_Type

+ func (m *Command) Reset()

+ func (m *Command) String() string

+ func (m *Command) XXX_DiscardUnknown()

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

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

+ func (m *Command) XXX_Size() int

+ func (m *Command) XXX_Unmarshal(b []byte) error

+ type Command_Type int32

+ const Command_CreateContinuousQueryCommand

+ const Command_CreateDataNodeCommand

+ const Command_CreateDatabaseCommand

+ const Command_CreateMetaNodeCommand

+ const Command_CreateNodeCommand

+ const Command_CreateRetentionPolicyCommand

+ const Command_CreateShardGroupCommand

+ const Command_CreateSubscriptionCommand

+ const Command_CreateUserCommand

+ const Command_DeleteDataNodeCommand

+ const Command_DeleteMetaNodeCommand

+ const Command_DeleteNodeCommand

+ const Command_DeleteShardGroupCommand

+ const Command_DropContinuousQueryCommand

+ const Command_DropDatabaseCommand

+ const Command_DropRetentionPolicyCommand

+ const Command_DropShardCommand

+ const Command_DropSubscriptionCommand

+ const Command_DropUserCommand

+ const Command_RemovePeerCommand

+ const Command_SetAdminPrivilegeCommand

+ const Command_SetDataCommand

+ const Command_SetDefaultRetentionPolicyCommand

+ const Command_SetMetaNodeCommand

+ const Command_SetPrivilegeCommand

+ const Command_UpdateDataNodeCommand

+ const Command_UpdateNodeCommand

+ const Command_UpdateRetentionPolicyCommand

+ const Command_UpdateUserCommand

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

+ func (x *Command_Type) UnmarshalJSON(data []byte) error

+ func (x Command_Type) Enum() *Command_Type

+ func (x Command_Type) String() string

+ type ContinuousQueryInfo struct

+ Name *string

+ Query *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ContinuousQueryInfo) ProtoMessage()

+ func (m *ContinuousQueryInfo) GetName() string

+ func (m *ContinuousQueryInfo) GetQuery() string

+ func (m *ContinuousQueryInfo) Reset()

+ func (m *ContinuousQueryInfo) String() string

+ func (m *ContinuousQueryInfo) XXX_DiscardUnknown()

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

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

+ func (m *ContinuousQueryInfo) XXX_Size() int

+ func (m *ContinuousQueryInfo) XXX_Unmarshal(b []byte) error

+ type CreateContinuousQueryCommand struct

+ Database *string

+ Name *string

+ Query *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateContinuousQueryCommand) ProtoMessage()

+ func (m *CreateContinuousQueryCommand) GetDatabase() string

+ func (m *CreateContinuousQueryCommand) GetName() string

+ func (m *CreateContinuousQueryCommand) GetQuery() string

+ func (m *CreateContinuousQueryCommand) Reset()

+ func (m *CreateContinuousQueryCommand) String() string

+ func (m *CreateContinuousQueryCommand) XXX_DiscardUnknown()

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

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

+ func (m *CreateContinuousQueryCommand) XXX_Size() int

+ func (m *CreateContinuousQueryCommand) XXX_Unmarshal(b []byte) error

+ type CreateDataNodeCommand struct

+ HTTPAddr *string

+ TCPAddr *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateDataNodeCommand) ProtoMessage()

+ func (m *CreateDataNodeCommand) GetHTTPAddr() string

+ func (m *CreateDataNodeCommand) GetTCPAddr() string

+ func (m *CreateDataNodeCommand) Reset()

+ func (m *CreateDataNodeCommand) String() string

+ func (m *CreateDataNodeCommand) XXX_DiscardUnknown()

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

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

+ func (m *CreateDataNodeCommand) XXX_Size() int

+ func (m *CreateDataNodeCommand) XXX_Unmarshal(b []byte) error

+ type CreateDatabaseCommand struct

+ Name *string

+ RetentionPolicy *RetentionPolicyInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateDatabaseCommand) ProtoMessage()

+ func (m *CreateDatabaseCommand) GetName() string

+ func (m *CreateDatabaseCommand) GetRetentionPolicy() *RetentionPolicyInfo

+ func (m *CreateDatabaseCommand) Reset()

+ func (m *CreateDatabaseCommand) String() string

+ func (m *CreateDatabaseCommand) XXX_DiscardUnknown()

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

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

+ func (m *CreateDatabaseCommand) XXX_Size() int

+ func (m *CreateDatabaseCommand) XXX_Unmarshal(b []byte) error

+ type CreateMetaNodeCommand struct

+ HTTPAddr *string

+ Rand *uint64

+ TCPAddr *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateMetaNodeCommand) ProtoMessage()

+ func (m *CreateMetaNodeCommand) GetHTTPAddr() string

+ func (m *CreateMetaNodeCommand) GetRand() uint64

+ func (m *CreateMetaNodeCommand) GetTCPAddr() string

+ func (m *CreateMetaNodeCommand) Reset()

+ func (m *CreateMetaNodeCommand) String() string

+ func (m *CreateMetaNodeCommand) XXX_DiscardUnknown()

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

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

+ func (m *CreateMetaNodeCommand) XXX_Size() int

+ func (m *CreateMetaNodeCommand) XXX_Unmarshal(b []byte) error

+ type CreateNodeCommand struct

+ Host *string

+ Rand *uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateNodeCommand) ProtoMessage()

+ func (m *CreateNodeCommand) GetHost() string

+ func (m *CreateNodeCommand) GetRand() uint64

+ func (m *CreateNodeCommand) Reset()

+ func (m *CreateNodeCommand) String() string

+ func (m *CreateNodeCommand) XXX_DiscardUnknown()

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

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

+ func (m *CreateNodeCommand) XXX_Size() int

+ func (m *CreateNodeCommand) XXX_Unmarshal(b []byte) error

+ type CreateRetentionPolicyCommand struct

+ Database *string

+ RetentionPolicy *RetentionPolicyInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateRetentionPolicyCommand) ProtoMessage()

+ func (m *CreateRetentionPolicyCommand) GetDatabase() string

+ func (m *CreateRetentionPolicyCommand) GetRetentionPolicy() *RetentionPolicyInfo

+ func (m *CreateRetentionPolicyCommand) Reset()

+ func (m *CreateRetentionPolicyCommand) String() string

+ func (m *CreateRetentionPolicyCommand) XXX_DiscardUnknown()

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

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

+ func (m *CreateRetentionPolicyCommand) XXX_Size() int

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

+ type CreateShardGroupCommand struct

+ Database *string

+ Policy *string

+ Timestamp *int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateShardGroupCommand) ProtoMessage()

+ func (m *CreateShardGroupCommand) GetDatabase() string

+ func (m *CreateShardGroupCommand) GetPolicy() string

+ func (m *CreateShardGroupCommand) GetTimestamp() int64

+ func (m *CreateShardGroupCommand) Reset()

+ func (m *CreateShardGroupCommand) String() string

+ func (m *CreateShardGroupCommand) XXX_DiscardUnknown()

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

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

+ func (m *CreateShardGroupCommand) XXX_Size() int

+ func (m *CreateShardGroupCommand) XXX_Unmarshal(b []byte) error

+ type CreateSubscriptionCommand struct

+ Database *string

+ Destinations []string

+ Mode *string

+ Name *string

+ RetentionPolicy *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateSubscriptionCommand) ProtoMessage()

+ func (m *CreateSubscriptionCommand) GetDatabase() string

+ func (m *CreateSubscriptionCommand) GetDestinations() []string

+ func (m *CreateSubscriptionCommand) GetMode() string

+ func (m *CreateSubscriptionCommand) GetName() string

+ func (m *CreateSubscriptionCommand) GetRetentionPolicy() string

+ func (m *CreateSubscriptionCommand) Reset()

+ func (m *CreateSubscriptionCommand) String() string

+ func (m *CreateSubscriptionCommand) XXX_DiscardUnknown()

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

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

+ func (m *CreateSubscriptionCommand) XXX_Size() int

+ func (m *CreateSubscriptionCommand) XXX_Unmarshal(b []byte) error

+ type CreateUserCommand struct

+ Admin *bool

+ Hash *string

+ Name *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*CreateUserCommand) ProtoMessage()

+ func (m *CreateUserCommand) GetAdmin() bool

+ func (m *CreateUserCommand) GetHash() string

+ func (m *CreateUserCommand) GetName() string

+ func (m *CreateUserCommand) Reset()

+ func (m *CreateUserCommand) String() string

+ func (m *CreateUserCommand) XXX_DiscardUnknown()

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

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

+ func (m *CreateUserCommand) XXX_Size() int

+ func (m *CreateUserCommand) XXX_Unmarshal(b []byte) error

+ type Data struct

+ ClusterID *uint64

+ DataNodes []*NodeInfo

+ Databases []*DatabaseInfo

+ Index *uint64

+ MaxNodeID *uint64

+ MaxShardGroupID *uint64

+ MaxShardID *uint64

+ MetaNodes []*NodeInfo

+ Nodes []*NodeInfo

+ Term *uint64

+ Users []*UserInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Data) ProtoMessage()

+ func (m *Data) GetClusterID() uint64

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

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

+ func (m *Data) GetIndex() uint64

+ func (m *Data) GetMaxNodeID() uint64

+ func (m *Data) GetMaxShardGroupID() uint64

+ func (m *Data) GetMaxShardID() uint64

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

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

+ func (m *Data) GetTerm() uint64

+ func (m *Data) GetUsers() []*UserInfo

+ func (m *Data) Reset()

+ func (m *Data) String() string

+ func (m *Data) XXX_DiscardUnknown()

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

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

+ func (m *Data) XXX_Size() int

+ func (m *Data) XXX_Unmarshal(b []byte) error

+ type DatabaseInfo struct

+ ContinuousQueries []*ContinuousQueryInfo

+ DefaultRetentionPolicy *string

+ Name *string

+ RetentionPolicies []*RetentionPolicyInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DatabaseInfo) ProtoMessage()

+ func (m *DatabaseInfo) GetContinuousQueries() []*ContinuousQueryInfo

+ func (m *DatabaseInfo) GetDefaultRetentionPolicy() string

+ func (m *DatabaseInfo) GetName() string

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

+ func (m *DatabaseInfo) Reset()

+ func (m *DatabaseInfo) String() string

+ func (m *DatabaseInfo) XXX_DiscardUnknown()

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

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

+ func (m *DatabaseInfo) XXX_Size() int

+ func (m *DatabaseInfo) XXX_Unmarshal(b []byte) error

+ type DeleteDataNodeCommand struct

+ ID *uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeleteDataNodeCommand) ProtoMessage()

+ func (m *DeleteDataNodeCommand) GetID() uint64

+ func (m *DeleteDataNodeCommand) Reset()

+ func (m *DeleteDataNodeCommand) String() string

+ func (m *DeleteDataNodeCommand) XXX_DiscardUnknown()

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

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

+ func (m *DeleteDataNodeCommand) XXX_Size() int

+ func (m *DeleteDataNodeCommand) XXX_Unmarshal(b []byte) error

+ type DeleteMetaNodeCommand struct

+ ID *uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeleteMetaNodeCommand) ProtoMessage()

+ func (m *DeleteMetaNodeCommand) GetID() uint64

+ func (m *DeleteMetaNodeCommand) Reset()

+ func (m *DeleteMetaNodeCommand) String() string

+ func (m *DeleteMetaNodeCommand) XXX_DiscardUnknown()

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

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

+ func (m *DeleteMetaNodeCommand) XXX_Size() int

+ func (m *DeleteMetaNodeCommand) XXX_Unmarshal(b []byte) error

+ type DeleteNodeCommand struct

+ Force *bool

+ ID *uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeleteNodeCommand) ProtoMessage()

+ func (m *DeleteNodeCommand) GetForce() bool

+ func (m *DeleteNodeCommand) GetID() uint64

+ func (m *DeleteNodeCommand) Reset()

+ func (m *DeleteNodeCommand) String() string

+ func (m *DeleteNodeCommand) XXX_DiscardUnknown()

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

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

+ func (m *DeleteNodeCommand) XXX_Size() int

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

+ type DeleteShardGroupCommand struct

+ Database *string

+ Policy *string

+ ShardGroupID *uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DeleteShardGroupCommand) ProtoMessage()

+ func (m *DeleteShardGroupCommand) GetDatabase() string

+ func (m *DeleteShardGroupCommand) GetPolicy() string

+ func (m *DeleteShardGroupCommand) GetShardGroupID() uint64

+ func (m *DeleteShardGroupCommand) Reset()

+ func (m *DeleteShardGroupCommand) String() string

+ func (m *DeleteShardGroupCommand) XXX_DiscardUnknown()

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

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

+ func (m *DeleteShardGroupCommand) XXX_Size() int

+ func (m *DeleteShardGroupCommand) XXX_Unmarshal(b []byte) error

+ type DropContinuousQueryCommand struct

+ Database *string

+ Name *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DropContinuousQueryCommand) ProtoMessage()

+ func (m *DropContinuousQueryCommand) GetDatabase() string

+ func (m *DropContinuousQueryCommand) GetName() string

+ func (m *DropContinuousQueryCommand) Reset()

+ func (m *DropContinuousQueryCommand) String() string

+ func (m *DropContinuousQueryCommand) XXX_DiscardUnknown()

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

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

+ func (m *DropContinuousQueryCommand) XXX_Size() int

+ func (m *DropContinuousQueryCommand) XXX_Unmarshal(b []byte) error

+ type DropDatabaseCommand struct

+ Name *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DropDatabaseCommand) ProtoMessage()

+ func (m *DropDatabaseCommand) GetName() string

+ func (m *DropDatabaseCommand) Reset()

+ func (m *DropDatabaseCommand) String() string

+ func (m *DropDatabaseCommand) XXX_DiscardUnknown()

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

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

+ func (m *DropDatabaseCommand) XXX_Size() int

+ func (m *DropDatabaseCommand) XXX_Unmarshal(b []byte) error

+ type DropRetentionPolicyCommand struct

+ Database *string

+ Name *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DropRetentionPolicyCommand) ProtoMessage()

+ func (m *DropRetentionPolicyCommand) GetDatabase() string

+ func (m *DropRetentionPolicyCommand) GetName() string

+ func (m *DropRetentionPolicyCommand) Reset()

+ func (m *DropRetentionPolicyCommand) String() string

+ func (m *DropRetentionPolicyCommand) XXX_DiscardUnknown()

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

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

+ func (m *DropRetentionPolicyCommand) XXX_Size() int

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

+ type DropShardCommand struct

+ ID *uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DropShardCommand) ProtoMessage()

+ func (m *DropShardCommand) GetID() uint64

+ func (m *DropShardCommand) Reset()

+ func (m *DropShardCommand) String() string

+ func (m *DropShardCommand) XXX_DiscardUnknown()

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

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

+ func (m *DropShardCommand) XXX_Size() int

+ func (m *DropShardCommand) XXX_Unmarshal(b []byte) error

+ type DropSubscriptionCommand struct

+ Database *string

+ Name *string

+ RetentionPolicy *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DropSubscriptionCommand) ProtoMessage()

+ func (m *DropSubscriptionCommand) GetDatabase() string

+ func (m *DropSubscriptionCommand) GetName() string

+ func (m *DropSubscriptionCommand) GetRetentionPolicy() string

+ func (m *DropSubscriptionCommand) Reset()

+ func (m *DropSubscriptionCommand) String() string

+ func (m *DropSubscriptionCommand) XXX_DiscardUnknown()

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

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

+ func (m *DropSubscriptionCommand) XXX_Size() int

+ func (m *DropSubscriptionCommand) XXX_Unmarshal(b []byte) error

+ type DropUserCommand struct

+ Name *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*DropUserCommand) ProtoMessage()

+ func (m *DropUserCommand) GetName() string

+ func (m *DropUserCommand) Reset()

+ func (m *DropUserCommand) String() string

+ func (m *DropUserCommand) XXX_DiscardUnknown()

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

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

+ func (m *DropUserCommand) XXX_Size() int

+ func (m *DropUserCommand) XXX_Unmarshal(b []byte) error

+ type FileCompression int

+ const GzipCompression

+ const NoCompression

+ func (c *FileCompression) Set(v string) error

+ func (c FileCompression) String() string

+ type Manifest struct

+ Buckets []ManifestBucketEntry

+ KV ManifestFileEntry

+ SQL *ManifestFileEntry

+ Version int

+ type ManifestBucketEntry struct

+ BucketID string

+ BucketName string

+ DefaultRetentionPolicy string

+ Description *string

+ OrganizationID string

+ OrganizationName string

+ RetentionPolicies []ManifestRetentionPolicy

+ func ConvertBucketManifest(manifest api.BucketMetadataManifest, ...) (ManifestBucketEntry, error)

+ type ManifestFileEntry struct

+ Compression FileCompression

+ FileName string

+ Size int64

+ type ManifestRetentionPolicy struct

+ Duration int64

+ Name string

+ ReplicaN int32

+ ShardGroupDuration int64

+ ShardGroups []ManifestShardGroup

+ Subscriptions []ManifestSubscription

+ func ConvertRetentionPolicy(manifest api.RetentionPolicyManifest, ...) (ManifestRetentionPolicy, error)

+ type ManifestShardEntry struct

+ ID int64

+ ShardOwners []ShardOwnerEntry

+ func ConvertShard(manifest api.ShardManifest, ...) (*ManifestShardEntry, error)

+ type ManifestShardGroup struct

+ DeletedAt *time.Time

+ EndTime time.Time

+ ID int64

+ Shards []ManifestShardEntry

+ StartTime time.Time

+ TruncatedAt *time.Time

+ func ConvertShardGroup(manifest api.ShardGroupManifest, ...) (ManifestShardGroup, error)

+ type ManifestSubscription struct

+ Destinations []string

+ Mode string

+ Name string

+ type NodeInfo struct

+ Host *string

+ ID *uint64

+ TCPHost *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*NodeInfo) ProtoMessage()

+ func (m *NodeInfo) GetHost() string

+ func (m *NodeInfo) GetID() uint64

+ func (m *NodeInfo) GetTCPHost() string

+ func (m *NodeInfo) Reset()

+ func (m *NodeInfo) String() string

+ func (m *NodeInfo) XXX_DiscardUnknown()

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

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

+ func (m *NodeInfo) XXX_Size() int

+ func (m *NodeInfo) XXX_Unmarshal(b []byte) error

+ type RemovePeerCommand struct

+ Addr *string

+ ID *uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RemovePeerCommand) ProtoMessage()

+ func (m *RemovePeerCommand) GetAddr() string

+ func (m *RemovePeerCommand) GetID() uint64

+ func (m *RemovePeerCommand) Reset()

+ func (m *RemovePeerCommand) String() string

+ func (m *RemovePeerCommand) XXX_DiscardUnknown()

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

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

+ func (m *RemovePeerCommand) XXX_Size() int

+ func (m *RemovePeerCommand) XXX_Unmarshal(b []byte) error

+ type Response struct

+ Error *string

+ Index *uint64

+ OK *bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Response) ProtoMessage()

+ func (m *Response) GetError() string

+ func (m *Response) GetIndex() uint64

+ func (m *Response) GetOK() bool

+ func (m *Response) Reset()

+ func (m *Response) String() string

+ func (m *Response) XXX_DiscardUnknown()

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

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

+ func (m *Response) XXX_Size() int

+ func (m *Response) XXX_Unmarshal(b []byte) error

+ type RetentionPolicyInfo struct

+ Duration *int64

+ Name *string

+ ReplicaN *uint32

+ ShardGroupDuration *int64

+ ShardGroups []*ShardGroupInfo

+ Subscriptions []*SubscriptionInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RetentionPolicyInfo) ProtoMessage()

+ func (m *RetentionPolicyInfo) GetDuration() int64

+ func (m *RetentionPolicyInfo) GetName() string

+ func (m *RetentionPolicyInfo) GetReplicaN() uint32

+ func (m *RetentionPolicyInfo) GetShardGroupDuration() int64

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

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

+ func (m *RetentionPolicyInfo) Reset()

+ func (m *RetentionPolicyInfo) String() string

+ func (m *RetentionPolicyInfo) XXX_DiscardUnknown()

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

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

+ func (m *RetentionPolicyInfo) XXX_Size() int

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

+ type RetentionPolicySpec struct

+ Duration *int64

+ Name *string

+ ReplicaN *uint32

+ ShardGroupDuration *int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RetentionPolicySpec) ProtoMessage()

+ func (m *RetentionPolicySpec) GetDuration() int64

+ func (m *RetentionPolicySpec) GetName() string

+ func (m *RetentionPolicySpec) GetReplicaN() uint32

+ func (m *RetentionPolicySpec) GetShardGroupDuration() int64

+ func (m *RetentionPolicySpec) Reset()

+ func (m *RetentionPolicySpec) String() string

+ func (m *RetentionPolicySpec) XXX_DiscardUnknown()

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

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

+ func (m *RetentionPolicySpec) XXX_Size() int

+ func (m *RetentionPolicySpec) XXX_Unmarshal(b []byte) error

+ type SetAdminPrivilegeCommand struct

+ Admin *bool

+ Username *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SetAdminPrivilegeCommand) ProtoMessage()

+ func (m *SetAdminPrivilegeCommand) GetAdmin() bool

+ func (m *SetAdminPrivilegeCommand) GetUsername() string

+ func (m *SetAdminPrivilegeCommand) Reset()

+ func (m *SetAdminPrivilegeCommand) String() string

+ func (m *SetAdminPrivilegeCommand) XXX_DiscardUnknown()

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

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

+ func (m *SetAdminPrivilegeCommand) XXX_Size() int

+ func (m *SetAdminPrivilegeCommand) XXX_Unmarshal(b []byte) error

+ type SetDataCommand struct

+ Data *Data

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SetDataCommand) ProtoMessage()

+ func (m *SetDataCommand) GetData() *Data

+ func (m *SetDataCommand) Reset()

+ func (m *SetDataCommand) String() string

+ func (m *SetDataCommand) XXX_DiscardUnknown()

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

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

+ func (m *SetDataCommand) XXX_Size() int

+ func (m *SetDataCommand) XXX_Unmarshal(b []byte) error

+ type SetDefaultRetentionPolicyCommand struct

+ Database *string

+ Name *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SetDefaultRetentionPolicyCommand) ProtoMessage()

+ func (m *SetDefaultRetentionPolicyCommand) GetDatabase() string

+ func (m *SetDefaultRetentionPolicyCommand) GetName() string

+ func (m *SetDefaultRetentionPolicyCommand) Reset()

+ func (m *SetDefaultRetentionPolicyCommand) String() string

+ func (m *SetDefaultRetentionPolicyCommand) XXX_DiscardUnknown()

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

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

+ func (m *SetDefaultRetentionPolicyCommand) XXX_Size() int

+ func (m *SetDefaultRetentionPolicyCommand) XXX_Unmarshal(b []byte) error

+ type SetMetaNodeCommand struct

+ HTTPAddr *string

+ Rand *uint64

+ TCPAddr *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SetMetaNodeCommand) ProtoMessage()

+ func (m *SetMetaNodeCommand) GetHTTPAddr() string

+ func (m *SetMetaNodeCommand) GetRand() uint64

+ func (m *SetMetaNodeCommand) GetTCPAddr() string

+ func (m *SetMetaNodeCommand) Reset()

+ func (m *SetMetaNodeCommand) String() string

+ func (m *SetMetaNodeCommand) XXX_DiscardUnknown()

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

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

+ func (m *SetMetaNodeCommand) XXX_Size() int

+ func (m *SetMetaNodeCommand) XXX_Unmarshal(b []byte) error

+ type SetPrivilegeCommand struct

+ Database *string

+ Privilege *int32

+ Username *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SetPrivilegeCommand) ProtoMessage()

+ func (m *SetPrivilegeCommand) GetDatabase() string

+ func (m *SetPrivilegeCommand) GetPrivilege() int32

+ func (m *SetPrivilegeCommand) GetUsername() string

+ func (m *SetPrivilegeCommand) Reset()

+ func (m *SetPrivilegeCommand) String() string

+ func (m *SetPrivilegeCommand) XXX_DiscardUnknown()

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

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

+ func (m *SetPrivilegeCommand) XXX_Size() int

+ func (m *SetPrivilegeCommand) XXX_Unmarshal(b []byte) error

+ type ShardGroupInfo struct

+ DeletedAt *int64

+ EndTime *int64

+ ID *uint64

+ Shards []*ShardInfo

+ StartTime *int64

+ TruncatedAt *int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ShardGroupInfo) ProtoMessage()

+ func (m *ShardGroupInfo) GetDeletedAt() int64

+ func (m *ShardGroupInfo) GetEndTime() int64

+ func (m *ShardGroupInfo) GetID() uint64

+ func (m *ShardGroupInfo) GetShards() []*ShardInfo

+ func (m *ShardGroupInfo) GetStartTime() int64

+ func (m *ShardGroupInfo) GetTruncatedAt() int64

+ func (m *ShardGroupInfo) Reset()

+ func (m *ShardGroupInfo) String() string

+ func (m *ShardGroupInfo) XXX_DiscardUnknown()

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

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

+ func (m *ShardGroupInfo) XXX_Size() int

+ func (m *ShardGroupInfo) XXX_Unmarshal(b []byte) error

+ type ShardInfo struct

+ ID *uint64

+ OwnerIDs []uint64

+ Owners []*ShardOwner

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ShardInfo) ProtoMessage()

+ func (m *ShardInfo) GetID() uint64

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

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

+ func (m *ShardInfo) Reset()

+ func (m *ShardInfo) String() string

+ func (m *ShardInfo) XXX_DiscardUnknown()

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

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

+ func (m *ShardInfo) XXX_Size() int

+ func (m *ShardInfo) XXX_Unmarshal(b []byte) error

+ type ShardOwner struct

+ NodeID *uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ShardOwner) ProtoMessage()

+ func (m *ShardOwner) GetNodeID() uint64

+ func (m *ShardOwner) Reset()

+ func (m *ShardOwner) String() string

+ func (m *ShardOwner) XXX_DiscardUnknown()

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

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

+ func (m *ShardOwner) XXX_Size() int

+ func (m *ShardOwner) XXX_Unmarshal(b []byte) error

+ type ShardOwnerEntry struct

+ NodeID int64

+ type SubscriptionInfo struct

+ Destinations []string

+ Mode *string

+ Name *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*SubscriptionInfo) ProtoMessage()

+ func (m *SubscriptionInfo) GetDestinations() []string

+ func (m *SubscriptionInfo) GetMode() string

+ func (m *SubscriptionInfo) GetName() string

+ func (m *SubscriptionInfo) Reset()

+ func (m *SubscriptionInfo) String() string

+ func (m *SubscriptionInfo) XXX_DiscardUnknown()

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

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

+ func (m *SubscriptionInfo) XXX_Size() int

+ func (m *SubscriptionInfo) XXX_Unmarshal(b []byte) error

+ type UpdateDataNodeCommand struct

+ Host *string

+ ID *uint64

+ TCPHost *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UpdateDataNodeCommand) ProtoMessage()

+ func (m *UpdateDataNodeCommand) GetHost() string

+ func (m *UpdateDataNodeCommand) GetID() uint64

+ func (m *UpdateDataNodeCommand) GetTCPHost() string

+ func (m *UpdateDataNodeCommand) Reset()

+ func (m *UpdateDataNodeCommand) String() string

+ func (m *UpdateDataNodeCommand) XXX_DiscardUnknown()

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

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

+ func (m *UpdateDataNodeCommand) XXX_Size() int

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

+ type UpdateNodeCommand struct

+ Host *string

+ ID *uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UpdateNodeCommand) ProtoMessage()

+ func (m *UpdateNodeCommand) GetHost() string

+ func (m *UpdateNodeCommand) GetID() uint64

+ func (m *UpdateNodeCommand) Reset()

+ func (m *UpdateNodeCommand) String() string

+ func (m *UpdateNodeCommand) XXX_DiscardUnknown()

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

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

+ func (m *UpdateNodeCommand) XXX_Size() int

+ func (m *UpdateNodeCommand) XXX_Unmarshal(b []byte) error

+ type UpdateRetentionPolicyCommand struct

+ Database *string

+ Duration *int64

+ Name *string

+ NewName *string

+ ReplicaN *uint32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UpdateRetentionPolicyCommand) ProtoMessage()

+ func (m *UpdateRetentionPolicyCommand) GetDatabase() string

+ func (m *UpdateRetentionPolicyCommand) GetDuration() int64

+ func (m *UpdateRetentionPolicyCommand) GetName() string

+ func (m *UpdateRetentionPolicyCommand) GetNewName() string

+ func (m *UpdateRetentionPolicyCommand) GetReplicaN() uint32

+ func (m *UpdateRetentionPolicyCommand) Reset()

+ func (m *UpdateRetentionPolicyCommand) String() string

+ func (m *UpdateRetentionPolicyCommand) XXX_DiscardUnknown()

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

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

+ func (m *UpdateRetentionPolicyCommand) XXX_Size() int

+ func (m *UpdateRetentionPolicyCommand) XXX_Unmarshal(b []byte) error

+ type UpdateUserCommand struct

+ Hash *string

+ Name *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UpdateUserCommand) ProtoMessage()

+ func (m *UpdateUserCommand) GetHash() string

+ func (m *UpdateUserCommand) GetName() string

+ func (m *UpdateUserCommand) Reset()

+ func (m *UpdateUserCommand) String() string

+ func (m *UpdateUserCommand) XXX_DiscardUnknown()

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

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

+ func (m *UpdateUserCommand) XXX_Size() int

+ func (m *UpdateUserCommand) XXX_Unmarshal(b []byte) error

+ type UserInfo struct

+ Admin *bool

+ Hash *string

+ Name *string

+ Privileges []*UserPrivilege

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UserInfo) ProtoMessage()

+ func (m *UserInfo) GetAdmin() bool

+ func (m *UserInfo) GetHash() string

+ func (m *UserInfo) GetName() string

+ func (m *UserInfo) GetPrivileges() []*UserPrivilege

+ func (m *UserInfo) Reset()

+ func (m *UserInfo) String() string

+ func (m *UserInfo) XXX_DiscardUnknown()

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

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

+ func (m *UserInfo) XXX_Size() int

+ func (m *UserInfo) XXX_Unmarshal(b []byte) error

+ type UserPrivilege struct

+ Database *string

+ Privilege *int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*UserPrivilege) ProtoMessage()

+ func (m *UserPrivilege) GetDatabase() string

+ func (m *UserPrivilege) GetPrivilege() int32

+ func (m *UserPrivilege) Reset()

+ func (m *UserPrivilege) String() string

+ func (m *UserPrivilege) XXX_DiscardUnknown()

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

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

+ func (m *UserPrivilege) XXX_Size() int

+ func (m *UserPrivilege) XXX_Unmarshal(b []byte) error

v2.1.0-rc2

Jul 22, 2021

v2.1.0-rc1

Jul 19, 2021

v2.1.0-rc0

Jul 19, 2021

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