meta

package

Go to main page

Versions in this module

v2

v2.7.10

Aug 15, 2024

v2.7.9

Aug 9, 2024

v2.7.8

Jul 25, 2024

v2.7.7

Jul 1, 2024

v2.7.6

Apr 12, 2024

v2.7.5

Jan 5, 2024

v2.7.4

Nov 8, 2023

v2.7.3

Oct 17, 2023

v2.7.2

Oct 12, 2023

v2.7.1

Apr 27, 2023

v2.7.0

Apr 5, 2023

v2.6.1

Dec 29, 2022

v2.6.0

Dec 15, 2022

v2.5.1

Nov 2, 2022

v2.5.0

Nov 1, 2022

v2.4.0

Aug 18, 2022

v2.3.0

Jun 16, 2022

v2.2.0

Mar 29, 2022

Changes in this version

+ var File_internal_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

Nov 8, 2021

v2.1.0

Nov 3, 2021

v2.0.9

Sep 24, 2021

v2.0.8

Aug 13, 2021

v2.0.7

Jun 4, 2021

v2.0.6

Apr 29, 2021

v2.0.5

Apr 27, 2021

Changes in this version

type Command

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ 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.0.4

Feb 8, 2021

v2.0.3

Dec 15, 2020

v2.0.2

Nov 19, 2020

v2.0.1

Nov 11, 2020

v2.0.0

Nov 10, 2020

Changes in this version

+ 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

+ type Command struct

+ Type *Command_Type

+ 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

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

+ type CreateContinuousQueryCommand struct

+ Database *string

+ Name *string

+ Query *string

+ 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

+ type CreateDataNodeCommand struct

+ HTTPAddr *string

+ TCPAddr *string

+ 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

+ type CreateDatabaseCommand struct

+ Name *string

+ RetentionPolicy *RetentionPolicyInfo

+ 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

+ type CreateMetaNodeCommand struct

+ HTTPAddr *string

+ Rand *uint64

+ TCPAddr *string

+ 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

+ type CreateNodeCommand struct

+ Host *string

+ Rand *uint64

+ 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

+ type CreateRetentionPolicyCommand struct

+ Database *string

+ RetentionPolicy *RetentionPolicyInfo

+ 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

+ type CreateShardGroupCommand struct

+ Database *string

+ Policy *string

+ Timestamp *int64

+ 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

+ type CreateSubscriptionCommand struct

+ Database *string

+ Destinations []string

+ Mode *string

+ Name *string

+ RetentionPolicy *string

+ 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

+ type CreateUserCommand struct

+ Admin *bool

+ Hash *string

+ Name *string

+ 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

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

+ type DatabaseInfo struct

+ ContinuousQueries []*ContinuousQueryInfo

+ DefaultRetentionPolicy *string

+ Name *string

+ RetentionPolicies []*RetentionPolicyInfo

+ 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

+ type DeleteDataNodeCommand struct

+ ID *uint64

+ 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

+ type DeleteMetaNodeCommand struct

+ ID *uint64

+ 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

+ type DeleteNodeCommand struct

+ Force *bool

+ ID *uint64

+ 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

+ type DeleteShardGroupCommand struct

+ Database *string

+ Policy *string

+ ShardGroupID *uint64

+ 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

+ type DropContinuousQueryCommand struct

+ Database *string

+ Name *string

+ 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

+ type DropDatabaseCommand struct

+ Name *string

+ 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

+ type DropRetentionPolicyCommand struct

+ Database *string

+ Name *string

+ 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

+ type DropShardCommand struct

+ ID *uint64

+ 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

+ type DropSubscriptionCommand struct

+ Database *string

+ Name *string

+ RetentionPolicy *string

+ 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

+ type DropUserCommand struct

+ Name *string

+ 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

+ type NodeInfo struct

+ Host *string

+ ID *uint64

+ TCPHost *string

+ 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

+ type RemovePeerCommand struct

+ Addr *string

+ ID *uint64

+ 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

+ type Response struct

+ Error *string

+ Index *uint64

+ OK *bool

+ 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

+ type RetentionPolicyInfo struct

+ Duration *int64

+ Name *string

+ ReplicaN *uint32

+ ShardGroupDuration *int64

+ ShardGroups []*ShardGroupInfo

+ Subscriptions []*SubscriptionInfo

+ 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

+ type RetentionPolicySpec struct

+ Duration *int64

+ Name *string

+ ReplicaN *uint32

+ ShardGroupDuration *int64

+ 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

+ type SetAdminPrivilegeCommand struct

+ Admin *bool

+ Username *string

+ 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

+ type SetDataCommand struct

+ Data *Data

+ 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

+ type SetDefaultRetentionPolicyCommand struct

+ Database *string

+ Name *string

+ 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

+ type SetMetaNodeCommand struct

+ HTTPAddr *string

+ Rand *uint64

+ TCPAddr *string

+ 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

+ type SetPrivilegeCommand struct

+ Database *string

+ Privilege *int32

+ Username *string

+ 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

+ type ShardGroupInfo struct

+ DeletedAt *int64

+ EndTime *int64

+ ID *uint64

+ Shards []*ShardInfo

+ StartTime *int64

+ TruncatedAt *int64

+ 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

+ type ShardInfo struct

+ ID *uint64

+ OwnerIDs []uint64

+ Owners []*ShardOwner

+ 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

+ type ShardOwner struct

+ NodeID *uint64

+ 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

+ type SubscriptionInfo struct

+ Destinations []string

+ Mode *string

+ Name *string

+ 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

+ type UpdateDataNodeCommand struct

+ Host *string

+ ID *uint64

+ TCPHost *string

+ 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

+ type UpdateNodeCommand struct

+ Host *string

+ ID *uint64

+ 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

+ type UpdateRetentionPolicyCommand struct

+ Database *string

+ Duration *int64

+ Name *string

+ NewName *string

+ ReplicaN *uint32

+ 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

+ type UpdateUserCommand struct

+ Hash *string

+ Name *string

+ 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

+ type UserInfo struct

+ Admin *bool

+ Hash *string

+ Name *string

+ Privileges []*UserPrivilege

+ 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

+ type UserPrivilege struct

+ Database *string

+ Privilege *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

v2.0.0-rc.4

Nov 6, 2020

v2.0.0-rc.3

Oct 29, 2020

v2.0.0-rc.2

Oct 21, 2020

v2.0.0-rc.1

Oct 14, 2020

v2.0.0-rc.0

Sep 29, 2020

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