Versions in this module Expand all Collapse all v1 v1.0.0 Aug 4, 2023 Changes in this version + var BlockInfo_BlockType_name = map[int32]string + var BlockInfo_BlockType_value = map[string]int32 + var File_pkg_pb_block_proto protoreflect.FileDescriptor + var File_pkg_pb_heartbeat_proto protoreflect.FileDescriptor + var File_pkg_pb_node_proto protoreflect.FileDescriptor + var File_pkg_pb_remote_proto protoreflect.FileDescriptor + var File_pkg_pb_store_proto protoreflect.FileDescriptor + var File_pkg_pb_subscribe_proto protoreflect.FileDescriptor + var HeartbeatService_ServiceDesc = grpc.ServiceDesc + var NodeRole_name = map[int32]string + var NodeRole_value = map[string]int32 + var NodeStatus_name = map[int32]string + var NodeStatus_value = map[string]int32 + var Remote_ServiceDesc = grpc.ServiceDesc + var S3Proxy_ServiceDesc = grpc.ServiceDesc + var SubscribeService_ServiceDesc = grpc.ServiceDesc + var WriterEvent_name = map[int32]string + var WriterEvent_value = map[string]int32 + func RegisterHeartbeatServiceServer(s grpc.ServiceRegistrar, srv HeartbeatServiceServer) + func RegisterRemoteServer(s grpc.ServiceRegistrar, srv RemoteServer) + func RegisterS3ProxyServer(s grpc.ServiceRegistrar, srv S3ProxyServer) + func RegisterSubscribeServiceServer(s grpc.ServiceRegistrar, srv SubscribeServiceServer) + type Account struct + Address string + Data []byte + func (*Account) Descriptor() ([]byte, []int) + func (*Account) ProtoMessage() + func (x *Account) GetAddress() string + func (x *Account) GetData() []byte + func (x *Account) ProtoReflect() protoreflect.Message + func (x *Account) Reset() + func (x *Account) String() string + type Accounts struct + Accounts []*Account + func (*Accounts) Descriptor() ([]byte, []int) + func (*Accounts) ProtoMessage() + func (x *Accounts) GetAccounts() []*Account + func (x *Accounts) ProtoReflect() protoreflect.Message + func (x *Accounts) Reset() + func (x *Accounts) String() string + type BatchReply struct + func (*BatchReply) Descriptor() ([]byte, []int) + func (*BatchReply) ProtoMessage() + func (x *BatchReply) ProtoReflect() protoreflect.Message + func (x *BatchReply) Reset() + func (x *BatchReply) String() string + type BatchRequest struct + Async bool + Data []byte + Id int32 + func (*BatchRequest) Descriptor() ([]byte, []int) + func (*BatchRequest) ProtoMessage() + func (x *BatchRequest) GetAsync() bool + func (x *BatchRequest) GetData() []byte + func (x *BatchRequest) GetId() int32 + func (x *BatchRequest) ProtoReflect() protoreflect.Message + func (x *BatchRequest) Reset() + func (x *BatchRequest) String() string + type Block struct + BatchItems []*Data + Info *BlockInfo + func (*Block) Descriptor() ([]byte, []int) + func (*Block) ProtoMessage() + func (x *Block) GetBatchItems() []*Data + func (x *Block) GetInfo() *BlockInfo + func (x *Block) ProtoReflect() protoreflect.Message + func (x *Block) Reset() + func (x *Block) String() string + type BlockChunk struct + Chunk []byte + Info *BlockInfo + func (*BlockChunk) Descriptor() ([]byte, []int) + func (*BlockChunk) ProtoMessage() + func (x *BlockChunk) GetChunk() []byte + func (x *BlockChunk) GetInfo() *BlockInfo + func (x *BlockChunk) ProtoReflect() protoreflect.Message + func (x *BlockChunk) Reset() + func (x *BlockChunk) String() string + type BlockInfo struct + BlockHash string + BlockNum int64 + BlockRoot string + BlockSize int64 + BlockType BlockInfo_BlockType + ChainId string + Env string + MsgOffset int64 + Role string + func (*BlockInfo) Descriptor() ([]byte, []int) + func (*BlockInfo) ProtoMessage() + func (x *BlockInfo) GetBlockHash() string + func (x *BlockInfo) GetBlockNum() int64 + func (x *BlockInfo) GetBlockRoot() string + func (x *BlockInfo) GetBlockSize() int64 + func (x *BlockInfo) GetBlockType() BlockInfo_BlockType + func (x *BlockInfo) GetChainId() string + func (x *BlockInfo) GetEnv() string + func (x *BlockInfo) GetMsgOffset() int64 + func (x *BlockInfo) GetRole() string + func (x *BlockInfo) ProtoReflect() protoreflect.Message + func (x *BlockInfo) Reset() + func (x *BlockInfo) String() string + type BlockInfo_BlockType int32 + const BlockInfo_DATA + const BlockInfo_HEADER + const BlockInfo_UNKNOWN + func (BlockInfo_BlockType) Descriptor() protoreflect.EnumDescriptor + func (BlockInfo_BlockType) EnumDescriptor() ([]byte, []int) + func (BlockInfo_BlockType) Type() protoreflect.EnumType + func (x BlockInfo_BlockType) Enum() *BlockInfo_BlockType + func (x BlockInfo_BlockType) Number() protoreflect.EnumNumber + func (x BlockInfo_BlockType) String() string + type BlockUpdateInfo struct + BlockHash string + BlockNum int64 + func (*BlockUpdateInfo) Descriptor() ([]byte, []int) + func (*BlockUpdateInfo) ProtoMessage() + func (x *BlockUpdateInfo) GetBlockHash() string + func (x *BlockUpdateInfo) GetBlockNum() int64 + func (x *BlockUpdateInfo) ProtoReflect() protoreflect.Message + func (x *BlockUpdateInfo) Reset() + func (x *BlockUpdateInfo) String() string + type CloseReply struct + func (*CloseReply) Descriptor() ([]byte, []int) + func (*CloseReply) ProtoMessage() + func (x *CloseReply) ProtoReflect() protoreflect.Message + func (x *CloseReply) Reset() + func (x *CloseReply) String() string + type CloseRequest struct + Id int32 + func (*CloseRequest) Descriptor() ([]byte, []int) + func (*CloseRequest) ProtoMessage() + func (x *CloseRequest) GetId() int32 + func (x *CloseRequest) ProtoReflect() protoreflect.Message + func (x *CloseRequest) Reset() + func (x *CloseRequest) String() string + type CompactReply struct + func (*CompactReply) Descriptor() ([]byte, []int) + func (*CompactReply) ProtoMessage() + func (x *CompactReply) ProtoReflect() protoreflect.Message + func (x *CompactReply) Reset() + func (x *CompactReply) String() string + type CompactRequest struct + Id int32 + Limit []byte + Start []byte + func (*CompactRequest) Descriptor() ([]byte, []int) + func (*CompactRequest) ProtoMessage() + func (x *CompactRequest) GetId() int32 + func (x *CompactRequest) GetLimit() []byte + func (x *CompactRequest) GetStart() []byte + func (x *CompactRequest) ProtoReflect() protoreflect.Message + func (x *CompactRequest) Reset() + func (x *CompactRequest) String() string + type DBInfo struct + DbPath string + DbType string + Id int32 + IsMeta bool + func (*DBInfo) Descriptor() ([]byte, []int) + func (*DBInfo) ProtoMessage() + func (x *DBInfo) GetDbPath() string + func (x *DBInfo) GetDbType() string + func (x *DBInfo) GetId() int32 + func (x *DBInfo) GetIsMeta() bool + func (x *DBInfo) ProtoReflect() protoreflect.Message + func (x *DBInfo) Reset() + func (x *DBInfo) String() string + type DBInfoList struct + DbInfos []*DBInfo + func (*DBInfoList) Descriptor() ([]byte, []int) + func (*DBInfoList) ProtoMessage() + func (x *DBInfoList) GetDbInfos() []*DBInfo + func (x *DBInfoList) ProtoReflect() protoreflect.Message + func (x *DBInfoList) Reset() + func (x *DBInfoList) String() string + type Data struct + Data []byte + Id int32 + func (*Data) Descriptor() ([]byte, []int) + func (*Data) ProtoMessage() + func (x *Data) GetData() []byte + func (x *Data) GetId() int32 + func (x *Data) ProtoReflect() protoreflect.Message + func (x *Data) Reset() + func (x *Data) String() string + type DelReply struct + func (*DelReply) Descriptor() ([]byte, []int) + func (*DelReply) ProtoMessage() + func (x *DelReply) ProtoReflect() protoreflect.Message + func (x *DelReply) Reset() + func (x *DelReply) String() string + type DelRequest struct + Async bool + Id int32 + Key []byte + func (*DelRequest) Descriptor() ([]byte, []int) + func (*DelRequest) ProtoMessage() + func (x *DelRequest) GetAsync() bool + func (x *DelRequest) GetId() int32 + func (x *DelRequest) GetKey() []byte + func (x *DelRequest) ProtoReflect() protoreflect.Message + func (x *DelRequest) Reset() + func (x *DelRequest) String() string + type GetBlockRequest struct + Info *BlockInfo + NoCache bool + func (*GetBlockRequest) Descriptor() ([]byte, []int) + func (*GetBlockRequest) ProtoMessage() + func (x *GetBlockRequest) GetInfo() *BlockInfo + func (x *GetBlockRequest) GetNoCache() bool + func (x *GetBlockRequest) ProtoReflect() protoreflect.Message + func (x *GetBlockRequest) Reset() + func (x *GetBlockRequest) String() string + type GetFileReply struct + Data []byte + func (*GetFileReply) Descriptor() ([]byte, []int) + func (*GetFileReply) ProtoMessage() + func (x *GetFileReply) GetData() []byte + func (x *GetFileReply) ProtoReflect() protoreflect.Message + func (x *GetFileReply) Reset() + func (x *GetFileReply) String() string + type GetFileRequest struct + Path string + func (*GetFileRequest) Descriptor() ([]byte, []int) + func (*GetFileRequest) ProtoMessage() + func (x *GetFileRequest) GetPath() string + func (x *GetFileRequest) ProtoReflect() protoreflect.Message + func (x *GetFileRequest) Reset() + func (x *GetFileRequest) String() string + type GetReply struct + Exist bool + Value []byte + func (*GetReply) Descriptor() ([]byte, []int) + func (*GetReply) ProtoMessage() + func (x *GetReply) GetExist() bool + func (x *GetReply) GetValue() []byte + func (x *GetReply) ProtoReflect() protoreflect.Message + func (x *GetReply) Reset() + func (x *GetReply) String() string + type GetRequest struct + Id int32 + Key []byte + func (*GetRequest) Descriptor() ([]byte, []int) + func (*GetRequest) ProtoMessage() + func (x *GetRequest) GetId() int32 + func (x *GetRequest) GetKey() []byte + func (x *GetRequest) ProtoReflect() protoreflect.Message + func (x *GetRequest) Reset() + func (x *GetRequest) String() string + type HasReply struct + Exist bool + func (*HasReply) Descriptor() ([]byte, []int) + func (*HasReply) ProtoMessage() + func (x *HasReply) GetExist() bool + func (x *HasReply) ProtoReflect() protoreflect.Message + func (x *HasReply) Reset() + func (x *HasReply) String() string + type HasRequest struct + Id int32 + Key []byte + func (*HasRequest) Descriptor() ([]byte, []int) + func (*HasRequest) ProtoMessage() + func (x *HasRequest) GetId() int32 + func (x *HasRequest) GetKey() []byte + func (x *HasRequest) ProtoReflect() protoreflect.Message + func (x *HasRequest) Reset() + func (x *HasRequest) String() string + type HeartbeatRequest struct + Id *NodeId + func (*HeartbeatRequest) Descriptor() ([]byte, []int) + func (*HeartbeatRequest) ProtoMessage() + func (x *HeartbeatRequest) GetId() *NodeId + func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message + func (x *HeartbeatRequest) Reset() + func (x *HeartbeatRequest) String() string + type HeartbeatResponse struct + func (*HeartbeatResponse) Descriptor() ([]byte, []int) + func (*HeartbeatResponse) ProtoMessage() + func (x *HeartbeatResponse) ProtoReflect() protoreflect.Message + func (x *HeartbeatResponse) Reset() + func (x *HeartbeatResponse) String() string + type HeartbeatServiceClient interface + Report func(ctx context.Context, opts ...grpc.CallOption) (HeartbeatService_ReportClient, error) + SetRole func(ctx context.Context, in *SetRoleRequest, opts ...grpc.CallOption) (*SetRoleResponse, error) + func NewHeartbeatServiceClient(cc grpc.ClientConnInterface) HeartbeatServiceClient + type HeartbeatServiceServer interface + Report func(HeartbeatService_ReportServer) error + SetRole func(context.Context, *SetRoleRequest) (*SetRoleResponse, error) + type HeartbeatService_ReportClient interface + CloseAndRecv func() (*HeartbeatResponse, error) + Send func(*HeartbeatRequest) error + type HeartbeatService_ReportServer interface + Recv func() (*HeartbeatRequest, error) + SendAndClose func(*HeartbeatResponse) error + type IterReply struct + Error string + IsEnd bool + Key []byte + Value []byte + func (*IterReply) Descriptor() ([]byte, []int) + func (*IterReply) ProtoMessage() + func (x *IterReply) GetError() string + func (x *IterReply) GetIsEnd() bool + func (x *IterReply) GetKey() []byte + func (x *IterReply) GetValue() []byte + func (x *IterReply) ProtoReflect() protoreflect.Message + func (x *IterReply) Reset() + func (x *IterReply) String() string + type IterRequest struct + Id int32 + Limit []byte + Reverse bool + Start []byte + func (*IterRequest) Descriptor() ([]byte, []int) + func (*IterRequest) ProtoMessage() + func (x *IterRequest) GetId() int32 + func (x *IterRequest) GetLimit() []byte + func (x *IterRequest) GetReverse() bool + func (x *IterRequest) GetStart() []byte + func (x *IterRequest) ProtoReflect() protoreflect.Message + func (x *IterRequest) Reset() + func (x *IterRequest) String() string + type KV struct + Key []byte + Value []byte + func (*KV) Descriptor() ([]byte, []int) + func (*KV) ProtoMessage() + func (x *KV) GetKey() []byte + func (x *KV) GetValue() []byte + func (x *KV) ProtoReflect() protoreflect.Message + func (x *KV) Reset() + func (x *KV) String() string + type ListHeaderStartAtReply struct + Infos []*BlockInfo + func (*ListHeaderStartAtReply) Descriptor() ([]byte, []int) + func (*ListHeaderStartAtReply) ProtoMessage() + func (x *ListHeaderStartAtReply) GetInfos() []*BlockInfo + func (x *ListHeaderStartAtReply) ProtoReflect() protoreflect.Message + func (x *ListHeaderStartAtReply) Reset() + func (x *ListHeaderStartAtReply) String() string + type ListHeaderStartAtRequest struct + AfterMsgOffset int64 + BlockNum int64 + ChainId string + CountNum int64 + Env string + Role string + func (*ListHeaderStartAtRequest) Descriptor() ([]byte, []int) + func (*ListHeaderStartAtRequest) ProtoMessage() + func (x *ListHeaderStartAtRequest) GetAfterMsgOffset() int64 + func (x *ListHeaderStartAtRequest) GetBlockNum() int64 + func (x *ListHeaderStartAtRequest) GetChainId() string + func (x *ListHeaderStartAtRequest) GetCountNum() int64 + func (x *ListHeaderStartAtRequest) GetEnv() string + func (x *ListHeaderStartAtRequest) GetRole() string + func (x *ListHeaderStartAtRequest) ProtoReflect() protoreflect.Message + func (x *ListHeaderStartAtRequest) Reset() + func (x *ListHeaderStartAtRequest) String() string + type ListReaderRequest struct + func (*ListReaderRequest) Descriptor() ([]byte, []int) + func (*ListReaderRequest) ProtoMessage() + func (x *ListReaderRequest) ProtoReflect() protoreflect.Message + func (x *ListReaderRequest) Reset() + func (x *ListReaderRequest) String() string + type ListReaderResponse struct + Readers []*NodeId + func (*ListReaderResponse) Descriptor() ([]byte, []int) + func (*ListReaderResponse) ProtoMessage() + func (x *ListReaderResponse) GetReaders() []*NodeId + func (x *ListReaderResponse) ProtoReflect() protoreflect.Message + func (x *ListReaderResponse) Reset() + func (x *ListReaderResponse) String() string + type NodeId struct + BlockUpdateInfo *BlockUpdateInfo + ChainId string + Endpoint string + Env string + Role NodeRole + Uuid string + func (*NodeId) Descriptor() ([]byte, []int) + func (*NodeId) ProtoMessage() + func (x *NodeId) GetBlockUpdateInfo() *BlockUpdateInfo + func (x *NodeId) GetChainId() string + func (x *NodeId) GetEndpoint() string + func (x *NodeId) GetEnv() string + func (x *NodeId) GetRole() NodeRole + func (x *NodeId) GetUuid() string + func (x *NodeId) ProtoReflect() protoreflect.Message + func (x *NodeId) Reset() + func (x *NodeId) String() string + type NodeRole int32 + const NodeRole_READER + const NodeRole_UNKNOWN_ROLE + const NodeRole_WRITERB + const NodeRole_WRITERM + func (NodeRole) Descriptor() protoreflect.EnumDescriptor + func (NodeRole) EnumDescriptor() ([]byte, []int) + func (NodeRole) Type() protoreflect.EnumType + func (x NodeRole) Enum() *NodeRole + func (x NodeRole) Number() protoreflect.EnumNumber + func (x NodeRole) String() string + type NodeStatus int32 + const NodeStatus_SYNCED + const NodeStatus_SYNCING + const NodeStatus_UNHEALTHY + const NodeStatus_UNKNOWN_STATUS + func (NodeStatus) Descriptor() protoreflect.EnumDescriptor + func (NodeStatus) EnumDescriptor() ([]byte, []int) + func (NodeStatus) Type() protoreflect.EnumType + func (x NodeStatus) Enum() *NodeStatus + func (x NodeStatus) Number() protoreflect.EnumNumber + func (x NodeStatus) String() string + type OpenReply struct + Id int32 + func (*OpenReply) Descriptor() ([]byte, []int) + func (*OpenReply) ProtoMessage() + func (x *OpenReply) GetId() int32 + func (x *OpenReply) ProtoReflect() protoreflect.Message + func (x *OpenReply) Reset() + func (x *OpenReply) String() string + type OpenRequest struct + IsMetaDB bool + Path string + Type string + func (*OpenRequest) Descriptor() ([]byte, []int) + func (*OpenRequest) ProtoMessage() + func (x *OpenRequest) GetIsMetaDB() bool + func (x *OpenRequest) GetPath() string + func (x *OpenRequest) GetType() string + func (x *OpenRequest) ProtoReflect() protoreflect.Message + func (x *OpenRequest) Reset() + func (x *OpenRequest) String() string + type PutBlockReply struct + func (*PutBlockReply) Descriptor() ([]byte, []int) + func (*PutBlockReply) ProtoMessage() + func (x *PutBlockReply) ProtoReflect() protoreflect.Message + func (x *PutBlockReply) Reset() + func (x *PutBlockReply) String() string + type PutFileReply struct + func (*PutFileReply) Descriptor() ([]byte, []int) + func (*PutFileReply) ProtoMessage() + func (x *PutFileReply) ProtoReflect() protoreflect.Message + func (x *PutFileReply) Reset() + func (x *PutFileReply) String() string + type PutFileRequest struct + Data []byte + Path string + func (*PutFileRequest) Descriptor() ([]byte, []int) + func (*PutFileRequest) ProtoMessage() + func (x *PutFileRequest) GetData() []byte + func (x *PutFileRequest) GetPath() string + func (x *PutFileRequest) ProtoReflect() protoreflect.Message + func (x *PutFileRequest) Reset() + func (x *PutFileRequest) String() string + type PutReply struct + func (*PutReply) Descriptor() ([]byte, []int) + func (*PutReply) ProtoMessage() + func (x *PutReply) ProtoReflect() protoreflect.Message + func (x *PutReply) Reset() + func (x *PutReply) String() string + type PutRequest struct + Async bool + Id int32 + Key []byte + Value []byte + func (*PutRequest) Descriptor() ([]byte, []int) + func (*PutRequest) ProtoMessage() + func (x *PutRequest) GetAsync() bool + func (x *PutRequest) GetId() int32 + func (x *PutRequest) GetKey() []byte + func (x *PutRequest) GetValue() []byte + func (x *PutRequest) ProtoReflect() protoreflect.Message + func (x *PutRequest) Reset() + func (x *PutRequest) String() string + type RemoteClient interface + Batch func(ctx context.Context, in *BatchRequest, opts ...grpc.CallOption) (*BatchReply, error) + Close func(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseReply, error) + Compact func(ctx context.Context, in *CompactRequest, opts ...grpc.CallOption) (*CompactReply, error) + Del func(ctx context.Context, in *DelRequest, opts ...grpc.CallOption) (*DelReply, error) + Get func(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetReply, error) + Has func(ctx context.Context, in *HasRequest, opts ...grpc.CallOption) (*HasReply, error) + Iter func(ctx context.Context, in *IterRequest, opts ...grpc.CallOption) (Remote_IterClient, error) + Open func(ctx context.Context, in *OpenRequest, opts ...grpc.CallOption) (*OpenReply, error) + Put func(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutReply, error) + Snapshot func(ctx context.Context, opts ...grpc.CallOption) (Remote_SnapshotClient, error) + Stat func(ctx context.Context, in *StatRequest, opts ...grpc.CallOption) (*StatReply, error) + Stats func(ctx context.Context, in *StatsRequest, opts ...grpc.CallOption) (*StatsReply, error) + Sync func(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (Remote_SyncClient, error) + func NewRemoteClient(cc grpc.ClientConnInterface) RemoteClient + type RemoteServer interface + Batch func(context.Context, *BatchRequest) (*BatchReply, error) + Close func(context.Context, *CloseRequest) (*CloseReply, error) + Compact func(context.Context, *CompactRequest) (*CompactReply, error) + Del func(context.Context, *DelRequest) (*DelReply, error) + Get func(context.Context, *GetRequest) (*GetReply, error) + Has func(context.Context, *HasRequest) (*HasReply, error) + Iter func(*IterRequest, Remote_IterServer) error + Open func(context.Context, *OpenRequest) (*OpenReply, error) + Put func(context.Context, *PutRequest) (*PutReply, error) + Snapshot func(Remote_SnapshotServer) error + Stat func(context.Context, *StatRequest) (*StatReply, error) + Stats func(context.Context, *StatsRequest) (*StatsReply, error) + Sync func(*SyncRequest, Remote_SyncServer) error + type Remote_IterClient interface + Recv func() (*IterReply, error) + type Remote_IterServer interface + Send func(*IterReply) error + type Remote_SnapshotClient interface + Recv func() (*SnapshotReply, error) + Send func(*SnapshotRequest) error + type Remote_SnapshotServer interface + Recv func() (*SnapshotRequest, error) + Send func(*SnapshotReply) error + type Remote_SyncClient interface + Recv func() (*SyncyReply, error) + type Remote_SyncServer interface + Send func(*SyncyReply) error + type RemoveFilesReply struct + func (*RemoveFilesReply) Descriptor() ([]byte, []int) + func (*RemoveFilesReply) ProtoMessage() + func (x *RemoveFilesReply) ProtoReflect() protoreflect.Message + func (x *RemoveFilesReply) Reset() + func (x *RemoveFilesReply) String() string + type RemoveFilesRequest struct + Infos []*BlockInfo + func (*RemoveFilesRequest) Descriptor() ([]byte, []int) + func (*RemoveFilesRequest) ProtoMessage() + func (x *RemoveFilesRequest) GetInfos() []*BlockInfo + func (x *RemoveFilesRequest) ProtoReflect() protoreflect.Message + func (x *RemoveFilesRequest) Reset() + func (x *RemoveFilesRequest) String() string + type S3ProxyClient interface + GetBlock func(ctx context.Context, in *GetBlockRequest, opts ...grpc.CallOption) (S3Proxy_GetBlockClient, error) + GetFile func(ctx context.Context, in *GetFileRequest, opts ...grpc.CallOption) (*GetFileReply, error) + ListHeaderStartAt func(ctx context.Context, in *ListHeaderStartAtRequest, opts ...grpc.CallOption) (*ListHeaderStartAtReply, error) + PutBlock func(ctx context.Context, opts ...grpc.CallOption) (S3Proxy_PutBlockClient, error) + PutFile func(ctx context.Context, in *PutFileRequest, opts ...grpc.CallOption) (*PutFileReply, error) + RemoveFiles func(ctx context.Context, in *RemoveFilesRequest, opts ...grpc.CallOption) (*RemoveFilesReply, error) + func NewS3ProxyClient(cc grpc.ClientConnInterface) S3ProxyClient + type S3ProxyServer interface + GetBlock func(*GetBlockRequest, S3Proxy_GetBlockServer) error + GetFile func(context.Context, *GetFileRequest) (*GetFileReply, error) + ListHeaderStartAt func(context.Context, *ListHeaderStartAtRequest) (*ListHeaderStartAtReply, error) + PutBlock func(S3Proxy_PutBlockServer) error + PutFile func(context.Context, *PutFileRequest) (*PutFileReply, error) + RemoveFiles func(context.Context, *RemoveFilesRequest) (*RemoveFilesReply, error) + type S3Proxy_GetBlockClient interface + Recv func() (*BlockChunk, error) + type S3Proxy_GetBlockServer interface + Send func(*BlockChunk) error + type S3Proxy_PutBlockClient interface + CloseAndRecv func() (*PutBlockReply, error) + Send func(*BlockChunk) error + type S3Proxy_PutBlockServer interface + Recv func() (*BlockChunk, error) + SendAndClose func(*PutBlockReply) error + type SetRoleRequest struct + Id *NodeId + func (*SetRoleRequest) Descriptor() ([]byte, []int) + func (*SetRoleRequest) ProtoMessage() + func (x *SetRoleRequest) GetId() *NodeId + func (x *SetRoleRequest) ProtoReflect() protoreflect.Message + func (x *SetRoleRequest) Reset() + func (x *SetRoleRequest) String() string + type SetRoleResponse struct + func (*SetRoleResponse) Descriptor() ([]byte, []int) + func (*SetRoleResponse) ProtoMessage() + func (x *SetRoleResponse) ProtoReflect() protoreflect.Message + func (x *SetRoleResponse) Reset() + func (x *SetRoleResponse) String() string + type SnapshotOpenReply struct + func (*SnapshotOpenReply) Descriptor() ([]byte, []int) + func (*SnapshotOpenReply) ProtoMessage() + func (x *SnapshotOpenReply) ProtoReflect() protoreflect.Message + func (x *SnapshotOpenReply) Reset() + func (x *SnapshotOpenReply) String() string + type SnapshotOpenRequest struct + func (*SnapshotOpenRequest) Descriptor() ([]byte, []int) + func (*SnapshotOpenRequest) ProtoMessage() + func (x *SnapshotOpenRequest) ProtoReflect() protoreflect.Message + func (x *SnapshotOpenRequest) Reset() + func (x *SnapshotOpenRequest) String() string + type SnapshotReply struct + Reply isSnapshotReply_Reply + func (*SnapshotReply) Descriptor() ([]byte, []int) + func (*SnapshotReply) ProtoMessage() + func (m *SnapshotReply) GetReply() isSnapshotReply_Reply + func (x *SnapshotReply) GetClose() *CloseReply + func (x *SnapshotReply) GetGet() *GetReply + func (x *SnapshotReply) GetHas() *HasReply + func (x *SnapshotReply) GetOpen() *SnapshotOpenReply + func (x *SnapshotReply) ProtoReflect() protoreflect.Message + func (x *SnapshotReply) Reset() + func (x *SnapshotReply) String() string + type SnapshotReply_Close struct + Close *CloseReply + type SnapshotReply_Get struct + Get *GetReply + type SnapshotReply_Has struct + Has *HasReply + type SnapshotReply_Open struct + Open *SnapshotOpenReply + type SnapshotRequest struct + Id int32 + Req isSnapshotRequest_Req + func (*SnapshotRequest) Descriptor() ([]byte, []int) + func (*SnapshotRequest) ProtoMessage() + func (m *SnapshotRequest) GetReq() isSnapshotRequest_Req + func (x *SnapshotRequest) GetClose() *CloseRequest + func (x *SnapshotRequest) GetGet() *GetRequest + func (x *SnapshotRequest) GetHas() *HasRequest + func (x *SnapshotRequest) GetId() int32 + func (x *SnapshotRequest) GetOpen() *SnapshotOpenRequest + func (x *SnapshotRequest) ProtoReflect() protoreflect.Message + func (x *SnapshotRequest) Reset() + func (x *SnapshotRequest) String() string + type SnapshotRequest_Close struct + Close *CloseRequest + type SnapshotRequest_Get struct + Get *GetRequest + type SnapshotRequest_Has struct + Has *HasRequest + type SnapshotRequest_Open struct + Open *SnapshotOpenRequest + type StatReply struct + Stat string + func (*StatReply) Descriptor() ([]byte, []int) + func (*StatReply) ProtoMessage() + func (x *StatReply) GetStat() string + func (x *StatReply) ProtoReflect() protoreflect.Message + func (x *StatReply) Reset() + func (x *StatReply) String() string + type StatRequest struct + Id int32 + Property string + func (*StatRequest) Descriptor() ([]byte, []int) + func (*StatRequest) ProtoMessage() + func (x *StatRequest) GetId() int32 + func (x *StatRequest) GetProperty() string + func (x *StatRequest) ProtoReflect() protoreflect.Message + func (x *StatRequest) Reset() + func (x *StatRequest) String() string + type StatsReply struct + Data map[string]string + TimeAt int64 + func (*StatsReply) Descriptor() ([]byte, []int) + func (*StatsReply) ProtoMessage() + func (x *StatsReply) GetData() map[string]string + func (x *StatsReply) GetTimeAt() int64 + func (x *StatsReply) ProtoReflect() protoreflect.Message + func (x *StatsReply) Reset() + func (x *StatsReply) String() string + type StatsRequest struct + Id int32 + func (*StatsRequest) Descriptor() ([]byte, []int) + func (*StatsRequest) ProtoMessage() + func (x *StatsRequest) GetId() int32 + func (x *StatsRequest) ProtoReflect() protoreflect.Message + func (x *StatsRequest) Reset() + func (x *StatsRequest) String() string + type SubscribeServiceClient interface + ListReader func(ctx context.Context, in *ListReaderRequest, opts ...grpc.CallOption) (*ListReaderResponse, error) + WatchWriterEvent func(ctx context.Context, in *WriterEventSubcribeRequest, opts ...grpc.CallOption) (SubscribeService_WatchWriterEventClient, error) + func NewSubscribeServiceClient(cc grpc.ClientConnInterface) SubscribeServiceClient + type SubscribeServiceServer interface + ListReader func(context.Context, *ListReaderRequest) (*ListReaderResponse, error) + WatchWriterEvent func(*WriterEventSubcribeRequest, SubscribeService_WatchWriterEventServer) error + type SubscribeService_WatchWriterEventClient interface + Recv func() (*WriterEventResponse, error) + type SubscribeService_WatchWriterEventServer interface + Send func(*WriterEventResponse) error + type SyncRequest struct + func (*SyncRequest) Descriptor() ([]byte, []int) + func (*SyncRequest) ProtoMessage() + func (x *SyncRequest) ProtoReflect() protoreflect.Message + func (x *SyncRequest) Reset() + func (x *SyncRequest) String() string + type SyncyReply struct + Data *Block + func (*SyncyReply) Descriptor() ([]byte, []int) + func (*SyncyReply) ProtoMessage() + func (x *SyncyReply) GetData() *Block + func (x *SyncyReply) ProtoReflect() protoreflect.Message + func (x *SyncyReply) Reset() + func (x *SyncyReply) String() string + type UnimplementedHeartbeatServiceServer struct + func (UnimplementedHeartbeatServiceServer) Report(HeartbeatService_ReportServer) error + func (UnimplementedHeartbeatServiceServer) SetRole(context.Context, *SetRoleRequest) (*SetRoleResponse, error) + type UnimplementedRemoteServer struct + func (UnimplementedRemoteServer) Batch(context.Context, *BatchRequest) (*BatchReply, error) + func (UnimplementedRemoteServer) Close(context.Context, *CloseRequest) (*CloseReply, error) + func (UnimplementedRemoteServer) Compact(context.Context, *CompactRequest) (*CompactReply, error) + func (UnimplementedRemoteServer) Del(context.Context, *DelRequest) (*DelReply, error) + func (UnimplementedRemoteServer) Get(context.Context, *GetRequest) (*GetReply, error) + func (UnimplementedRemoteServer) Has(context.Context, *HasRequest) (*HasReply, error) + func (UnimplementedRemoteServer) Iter(*IterRequest, Remote_IterServer) error + func (UnimplementedRemoteServer) Open(context.Context, *OpenRequest) (*OpenReply, error) + func (UnimplementedRemoteServer) Put(context.Context, *PutRequest) (*PutReply, error) + func (UnimplementedRemoteServer) Snapshot(Remote_SnapshotServer) error + func (UnimplementedRemoteServer) Stat(context.Context, *StatRequest) (*StatReply, error) + func (UnimplementedRemoteServer) Stats(context.Context, *StatsRequest) (*StatsReply, error) + func (UnimplementedRemoteServer) Sync(*SyncRequest, Remote_SyncServer) error + type UnimplementedS3ProxyServer struct + func (UnimplementedS3ProxyServer) GetBlock(*GetBlockRequest, S3Proxy_GetBlockServer) error + func (UnimplementedS3ProxyServer) GetFile(context.Context, *GetFileRequest) (*GetFileReply, error) + func (UnimplementedS3ProxyServer) ListHeaderStartAt(context.Context, *ListHeaderStartAtRequest) (*ListHeaderStartAtReply, error) + func (UnimplementedS3ProxyServer) PutBlock(S3Proxy_PutBlockServer) error + func (UnimplementedS3ProxyServer) PutFile(context.Context, *PutFileRequest) (*PutFileReply, error) + func (UnimplementedS3ProxyServer) RemoveFiles(context.Context, *RemoveFilesRequest) (*RemoveFilesReply, error) + type UnimplementedSubscribeServiceServer struct + func (UnimplementedSubscribeServiceServer) ListReader(context.Context, *ListReaderRequest) (*ListReaderResponse, error) + func (UnimplementedSubscribeServiceServer) WatchWriterEvent(*WriterEventSubcribeRequest, SubscribeService_WatchWriterEventServer) error + type UnsafeHeartbeatServiceServer interface + type UnsafeRemoteServer interface + type UnsafeS3ProxyServer interface + type UnsafeSubscribeServiceServer interface + type WriterEvent int32 + const WriterEvent_OUT_OF_SYNC + const WriterEvent_ROLE_CHANGED + const WriterEvent_UNKNOWN_WRITE_EVENT + func (WriterEvent) Descriptor() protoreflect.EnumDescriptor + func (WriterEvent) EnumDescriptor() ([]byte, []int) + func (WriterEvent) Type() protoreflect.EnumType + func (x WriterEvent) Enum() *WriterEvent + func (x WriterEvent) Number() protoreflect.EnumNumber + func (x WriterEvent) String() string + type WriterEventResponse struct + Event WriterEvent + Leader *NodeId + func (*WriterEventResponse) Descriptor() ([]byte, []int) + func (*WriterEventResponse) ProtoMessage() + func (x *WriterEventResponse) GetEvent() WriterEvent + func (x *WriterEventResponse) GetLeader() *NodeId + func (x *WriterEventResponse) ProtoReflect() protoreflect.Message + func (x *WriterEventResponse) Reset() + func (x *WriterEventResponse) String() string + type WriterEventSubcribeRequest struct + Timeout int64 + func (*WriterEventSubcribeRequest) Descriptor() ([]byte, []int) + func (*WriterEventSubcribeRequest) ProtoMessage() + func (x *WriterEventSubcribeRequest) GetTimeout() int64 + func (x *WriterEventSubcribeRequest) ProtoReflect() protoreflect.Message + func (x *WriterEventSubcribeRequest) Reset() + func (x *WriterEventSubcribeRequest) String() string