proto

package
v8.24.7 Latest Latest
Warning

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

Go to latest
Published: May 10, 2024 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	Command_Type_name = map[int32]string{
		0:  "COMMAND_TYPE_UNKNOWN",
		1:  "COMMAND_TYPE_GET_NODE_API_URL",
		2:  "COMMAND_TYPE_EXECUTE",
		3:  "COMMAND_TYPE_QUERY",
		4:  "COMMAND_TYPE_BACKUP",
		5:  "COMMAND_TYPE_LOAD",
		6:  "COMMAND_TYPE_REMOVE_NODE",
		7:  "COMMAND_TYPE_NOTIFY",
		8:  "COMMAND_TYPE_JOIN",
		9:  "COMMAND_TYPE_REQUEST",
		10: "COMMAND_TYPE_LOAD_CHUNK",
		11: "COMMAND_TYPE_BACKUP_STREAM",
	}
	Command_Type_value = map[string]int32{
		"COMMAND_TYPE_UNKNOWN":          0,
		"COMMAND_TYPE_GET_NODE_API_URL": 1,
		"COMMAND_TYPE_EXECUTE":          2,
		"COMMAND_TYPE_QUERY":            3,
		"COMMAND_TYPE_BACKUP":           4,
		"COMMAND_TYPE_LOAD":             5,
		"COMMAND_TYPE_REMOVE_NODE":      6,
		"COMMAND_TYPE_NOTIFY":           7,
		"COMMAND_TYPE_JOIN":             8,
		"COMMAND_TYPE_REQUEST":          9,
		"COMMAND_TYPE_LOAD_CHUNK":       10,
		"COMMAND_TYPE_BACKUP_STREAM":    11,
	}
)

Enum value maps for Command_Type.

View Source
var File_message_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Command

type Command struct {
	Type Command_Type `protobuf:"varint,1,opt,name=type,proto3,enum=cluster.Command_Type" json:"type,omitempty"`
	// Types that are assignable to Request:
	//
	//	*Command_ExecuteRequest
	//	*Command_QueryRequest
	//	*Command_BackupRequest
	//	*Command_LoadRequest
	//	*Command_RemoveNodeRequest
	//	*Command_NotifyRequest
	//	*Command_JoinRequest
	//	*Command_ExecuteQueryRequest
	//	*Command_LoadChunkRequest
	Request     isCommand_Request `protobuf_oneof:"request"`
	Credentials *Credentials      `protobuf:"bytes,4,opt,name=credentials,proto3" json:"credentials,omitempty"`
	// contains filtered or unexported fields
}

func (*Command) Descriptor deprecated

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

Deprecated: Use Command.ProtoReflect.Descriptor instead.

func (*Command) GetBackupRequest

func (x *Command) GetBackupRequest() *proto.BackupRequest

func (*Command) GetCredentials

func (x *Command) GetCredentials() *Credentials

func (*Command) GetExecuteQueryRequest

func (x *Command) GetExecuteQueryRequest() *proto.ExecuteQueryRequest

func (*Command) GetExecuteRequest

func (x *Command) GetExecuteRequest() *proto.ExecuteRequest

func (*Command) GetJoinRequest

func (x *Command) GetJoinRequest() *proto.JoinRequest

func (*Command) GetLoadChunkRequest

func (x *Command) GetLoadChunkRequest() *proto.LoadChunkRequest

func (*Command) GetLoadRequest

func (x *Command) GetLoadRequest() *proto.LoadRequest

func (*Command) GetNotifyRequest

func (x *Command) GetNotifyRequest() *proto.NotifyRequest

func (*Command) GetQueryRequest

func (x *Command) GetQueryRequest() *proto.QueryRequest

func (*Command) GetRemoveNodeRequest

func (x *Command) GetRemoveNodeRequest() *proto.RemoveNodeRequest

func (*Command) GetRequest

func (m *Command) GetRequest() isCommand_Request

func (*Command) GetType

func (x *Command) GetType() Command_Type

func (*Command) ProtoMessage

func (*Command) ProtoMessage()

func (*Command) ProtoReflect

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

func (*Command) Reset

func (x *Command) Reset()

func (*Command) String

func (x *Command) String() string

type CommandBackupResponse

type CommandBackupResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Data  []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandBackupResponse) Descriptor deprecated

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

Deprecated: Use CommandBackupResponse.ProtoReflect.Descriptor instead.

func (*CommandBackupResponse) GetData

func (x *CommandBackupResponse) GetData() []byte

func (*CommandBackupResponse) GetError

func (x *CommandBackupResponse) GetError() string

func (*CommandBackupResponse) ProtoMessage

func (*CommandBackupResponse) ProtoMessage()

func (*CommandBackupResponse) ProtoReflect

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

func (*CommandBackupResponse) Reset

func (x *CommandBackupResponse) Reset()

func (*CommandBackupResponse) String

func (x *CommandBackupResponse) String() string

type CommandExecuteResponse

type CommandExecuteResponse struct {
	Error    string                        `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Response []*proto.ExecuteQueryResponse `protobuf:"bytes,2,rep,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandExecuteResponse) Descriptor deprecated

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

Deprecated: Use CommandExecuteResponse.ProtoReflect.Descriptor instead.

func (*CommandExecuteResponse) GetError

func (x *CommandExecuteResponse) GetError() string

func (*CommandExecuteResponse) GetResponse added in v8.23.0

func (*CommandExecuteResponse) ProtoMessage

func (*CommandExecuteResponse) ProtoMessage()

func (*CommandExecuteResponse) ProtoReflect

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

func (*CommandExecuteResponse) Reset

func (x *CommandExecuteResponse) Reset()

func (*CommandExecuteResponse) String

func (x *CommandExecuteResponse) String() string

type CommandJoinResponse

type CommandJoinResponse struct {
	Error  string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Leader string `protobuf:"bytes,2,opt,name=leader,proto3" json:"leader,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandJoinResponse) Descriptor deprecated

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

Deprecated: Use CommandJoinResponse.ProtoReflect.Descriptor instead.

func (*CommandJoinResponse) GetError

func (x *CommandJoinResponse) GetError() string

func (*CommandJoinResponse) GetLeader

func (x *CommandJoinResponse) GetLeader() string

func (*CommandJoinResponse) ProtoMessage

func (*CommandJoinResponse) ProtoMessage()

func (*CommandJoinResponse) ProtoReflect

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

func (*CommandJoinResponse) Reset

func (x *CommandJoinResponse) Reset()

func (*CommandJoinResponse) String

func (x *CommandJoinResponse) String() string

type CommandLoadChunkResponse

type CommandLoadChunkResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandLoadChunkResponse) Descriptor deprecated

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

Deprecated: Use CommandLoadChunkResponse.ProtoReflect.Descriptor instead.

func (*CommandLoadChunkResponse) GetError

func (x *CommandLoadChunkResponse) GetError() string

func (*CommandLoadChunkResponse) ProtoMessage

func (*CommandLoadChunkResponse) ProtoMessage()

func (*CommandLoadChunkResponse) ProtoReflect

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

func (*CommandLoadChunkResponse) Reset

func (x *CommandLoadChunkResponse) Reset()

func (*CommandLoadChunkResponse) String

func (x *CommandLoadChunkResponse) String() string

type CommandLoadResponse

type CommandLoadResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandLoadResponse) Descriptor deprecated

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

Deprecated: Use CommandLoadResponse.ProtoReflect.Descriptor instead.

func (*CommandLoadResponse) GetError

func (x *CommandLoadResponse) GetError() string

func (*CommandLoadResponse) ProtoMessage

func (*CommandLoadResponse) ProtoMessage()

func (*CommandLoadResponse) ProtoReflect

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

func (*CommandLoadResponse) Reset

func (x *CommandLoadResponse) Reset()

func (*CommandLoadResponse) String

func (x *CommandLoadResponse) String() string

type CommandNotifyResponse

type CommandNotifyResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandNotifyResponse) Descriptor deprecated

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

Deprecated: Use CommandNotifyResponse.ProtoReflect.Descriptor instead.

func (*CommandNotifyResponse) GetError

func (x *CommandNotifyResponse) GetError() string

func (*CommandNotifyResponse) ProtoMessage

func (*CommandNotifyResponse) ProtoMessage()

func (*CommandNotifyResponse) ProtoReflect

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

func (*CommandNotifyResponse) Reset

func (x *CommandNotifyResponse) Reset()

func (*CommandNotifyResponse) String

func (x *CommandNotifyResponse) String() string

type CommandQueryResponse

type CommandQueryResponse struct {
	Error string             `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Rows  []*proto.QueryRows `protobuf:"bytes,2,rep,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandQueryResponse) Descriptor deprecated

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

Deprecated: Use CommandQueryResponse.ProtoReflect.Descriptor instead.

func (*CommandQueryResponse) GetError

func (x *CommandQueryResponse) GetError() string

func (*CommandQueryResponse) GetRows

func (x *CommandQueryResponse) GetRows() []*proto.QueryRows

func (*CommandQueryResponse) ProtoMessage

func (*CommandQueryResponse) ProtoMessage()

func (*CommandQueryResponse) ProtoReflect

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

func (*CommandQueryResponse) Reset

func (x *CommandQueryResponse) Reset()

func (*CommandQueryResponse) String

func (x *CommandQueryResponse) String() string

type CommandRemoveNodeResponse

type CommandRemoveNodeResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandRemoveNodeResponse) Descriptor deprecated

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

Deprecated: Use CommandRemoveNodeResponse.ProtoReflect.Descriptor instead.

func (*CommandRemoveNodeResponse) GetError

func (x *CommandRemoveNodeResponse) GetError() string

func (*CommandRemoveNodeResponse) ProtoMessage

func (*CommandRemoveNodeResponse) ProtoMessage()

func (*CommandRemoveNodeResponse) ProtoReflect

func (*CommandRemoveNodeResponse) Reset

func (x *CommandRemoveNodeResponse) Reset()

func (*CommandRemoveNodeResponse) String

func (x *CommandRemoveNodeResponse) String() string

type CommandRequestResponse

type CommandRequestResponse struct {
	Error    string                        `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Response []*proto.ExecuteQueryResponse `protobuf:"bytes,2,rep,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*CommandRequestResponse) Descriptor deprecated

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

Deprecated: Use CommandRequestResponse.ProtoReflect.Descriptor instead.

func (*CommandRequestResponse) GetError

func (x *CommandRequestResponse) GetError() string

func (*CommandRequestResponse) GetResponse

func (*CommandRequestResponse) ProtoMessage

func (*CommandRequestResponse) ProtoMessage()

func (*CommandRequestResponse) ProtoReflect

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

func (*CommandRequestResponse) Reset

func (x *CommandRequestResponse) Reset()

func (*CommandRequestResponse) String

func (x *CommandRequestResponse) String() string

type Command_BackupRequest

type Command_BackupRequest struct {
	BackupRequest *proto.BackupRequest `protobuf:"bytes,5,opt,name=backup_request,json=backupRequest,proto3,oneof"`
}

type Command_ExecuteQueryRequest

type Command_ExecuteQueryRequest struct {
	ExecuteQueryRequest *proto.ExecuteQueryRequest `protobuf:"bytes,10,opt,name=execute_query_request,json=executeQueryRequest,proto3,oneof"`
}

type Command_ExecuteRequest

type Command_ExecuteRequest struct {
	ExecuteRequest *proto.ExecuteRequest `protobuf:"bytes,2,opt,name=execute_request,json=executeRequest,proto3,oneof"`
}

type Command_JoinRequest

type Command_JoinRequest struct {
	JoinRequest *proto.JoinRequest `protobuf:"bytes,9,opt,name=join_request,json=joinRequest,proto3,oneof"`
}

type Command_LoadChunkRequest

type Command_LoadChunkRequest struct {
	LoadChunkRequest *proto.LoadChunkRequest `protobuf:"bytes,11,opt,name=load_chunk_request,json=loadChunkRequest,proto3,oneof"`
}

type Command_LoadRequest

type Command_LoadRequest struct {
	LoadRequest *proto.LoadRequest `protobuf:"bytes,6,opt,name=load_request,json=loadRequest,proto3,oneof"`
}

type Command_NotifyRequest

type Command_NotifyRequest struct {
	NotifyRequest *proto.NotifyRequest `protobuf:"bytes,8,opt,name=notify_request,json=notifyRequest,proto3,oneof"`
}

type Command_QueryRequest

type Command_QueryRequest struct {
	QueryRequest *proto.QueryRequest `protobuf:"bytes,3,opt,name=query_request,json=queryRequest,proto3,oneof"`
}

type Command_RemoveNodeRequest

type Command_RemoveNodeRequest struct {
	RemoveNodeRequest *proto.RemoveNodeRequest `protobuf:"bytes,7,opt,name=remove_node_request,json=removeNodeRequest,proto3,oneof"`
}

type Command_Type

type Command_Type int32
const (
	Command_COMMAND_TYPE_UNKNOWN          Command_Type = 0
	Command_COMMAND_TYPE_GET_NODE_API_URL Command_Type = 1
	Command_COMMAND_TYPE_EXECUTE          Command_Type = 2
	Command_COMMAND_TYPE_QUERY            Command_Type = 3
	Command_COMMAND_TYPE_BACKUP           Command_Type = 4
	Command_COMMAND_TYPE_LOAD             Command_Type = 5
	Command_COMMAND_TYPE_REMOVE_NODE      Command_Type = 6
	Command_COMMAND_TYPE_NOTIFY           Command_Type = 7
	Command_COMMAND_TYPE_JOIN             Command_Type = 8
	Command_COMMAND_TYPE_REQUEST          Command_Type = 9
	Command_COMMAND_TYPE_LOAD_CHUNK       Command_Type = 10
	Command_COMMAND_TYPE_BACKUP_STREAM    Command_Type = 11
)

func (Command_Type) Descriptor

func (Command_Type) Enum

func (x Command_Type) Enum() *Command_Type

func (Command_Type) EnumDescriptor deprecated

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

Deprecated: Use Command_Type.Descriptor instead.

func (Command_Type) Number

func (Command_Type) String

func (x Command_Type) String() string

func (Command_Type) Type

type Credentials

type Credentials struct {
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*Credentials) Descriptor deprecated

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

Deprecated: Use Credentials.ProtoReflect.Descriptor instead.

func (*Credentials) GetPassword

func (x *Credentials) GetPassword() string

func (*Credentials) GetUsername

func (x *Credentials) GetUsername() string

func (*Credentials) ProtoMessage

func (*Credentials) ProtoMessage()

func (*Credentials) ProtoReflect

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

func (*Credentials) Reset

func (x *Credentials) Reset()

func (*Credentials) String

func (x *Credentials) String() string

type NodeMeta added in v8.20.2

type NodeMeta struct {
	Url         string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	CommitIndex uint64 `protobuf:"varint,2,opt,name=commit_index,json=commitIndex,proto3" json:"commit_index,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeMeta) Descriptor deprecated added in v8.20.2

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

Deprecated: Use NodeMeta.ProtoReflect.Descriptor instead.

func (*NodeMeta) GetCommitIndex added in v8.20.2

func (x *NodeMeta) GetCommitIndex() uint64

func (*NodeMeta) GetUrl added in v8.20.2

func (x *NodeMeta) GetUrl() string

func (*NodeMeta) ProtoMessage added in v8.20.2

func (*NodeMeta) ProtoMessage()

func (*NodeMeta) ProtoReflect added in v8.20.2

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

func (*NodeMeta) Reset added in v8.20.2

func (x *NodeMeta) Reset()

func (*NodeMeta) String added in v8.20.2

func (x *NodeMeta) String() string

Jump to

Keyboard shortcuts

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