pb

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Aug 4, 2023 License: LGPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	BlockInfo_BlockType_name = map[int32]string{
		0: "UNKNOWN",
		1: "DATA",
		2: "HEADER",
	}
	BlockInfo_BlockType_value = map[string]int32{
		"UNKNOWN": 0,
		"DATA":    1,
		"HEADER":  2,
	}
)

Enum value maps for BlockInfo_BlockType.

View Source 
var (
	NodeRole_name = map[int32]string{
		0: "UNKNOWN_ROLE",
		1: "WRITERM",
		2: "WRITERB",
		3: "READER",
	}
	NodeRole_value = map[string]int32{
		"UNKNOWN_ROLE": 0,
		"WRITERM":      1,
		"WRITERB":      2,
		"READER":       3,
	}
)

Enum value maps for NodeRole.

View Source 
var (
	NodeStatus_name = map[int32]string{
		0: "UNKNOWN_STATUS",
		1: "SYNCED",
		2: "SYNCING",
		3: "UNHEALTHY",
	}
	NodeStatus_value = map[string]int32{
		"UNKNOWN_STATUS": 0,
		"SYNCED":         1,
		"SYNCING":        2,
		"UNHEALTHY":      3,
	}
)

Enum value maps for NodeStatus.

View Source 
var (
	WriterEvent_name = map[int32]string{
		0: "UNKNOWN_WRITE_EVENT",
		1: "ROLE_CHANGED",
		2: "OUT_OF_SYNC",
	}
	WriterEvent_value = map[string]int32{
		"UNKNOWN_WRITE_EVENT": 0,
		"ROLE_CHANGED":        1,
		"OUT_OF_SYNC":         2,
	}
)

Enum value maps for WriterEvent.

View Source 
var File_pkg_pb_block_proto protoreflect.FileDescriptor
View Source 
var File_pkg_pb_heartbeat_proto protoreflect.FileDescriptor
View Source 
var File_pkg_pb_node_proto protoreflect.FileDescriptor
View Source 
var File_pkg_pb_remote_proto protoreflect.FileDescriptor
View Source 
var File_pkg_pb_store_proto protoreflect.FileDescriptor
View Source 
var File_pkg_pb_subscribe_proto protoreflect.FileDescriptor
View Source 
var HeartbeatService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.HeartbeatService",
	HandlerType: (*HeartbeatServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SetRole",
			Handler:    _HeartbeatService_SetRole_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Report",
			Handler:       _HeartbeatService_Report_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "pkg/pb/heartbeat.proto",
}

HeartbeatService_ServiceDesc is the grpc.ServiceDesc for HeartbeatService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Remote_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.Remote",
	HandlerType: (*RemoteServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "open",
			Handler:    _Remote_Open_Handler,
		},
		{
			MethodName: "get",
			Handler:    _Remote_Get_Handler,
		},
		{
			MethodName: "has",
			Handler:    _Remote_Has_Handler,
		},
		{
			MethodName: "put",
			Handler:    _Remote_Put_Handler,
		},
		{
			MethodName: "del",
			Handler:    _Remote_Del_Handler,
		},
		{
			MethodName: "stat",
			Handler:    _Remote_Stat_Handler,
		},
		{
			MethodName: "stats",
			Handler:    _Remote_Stats_Handler,
		},
		{
			MethodName: "compact",
			Handler:    _Remote_Compact_Handler,
		},
		{
			MethodName: "batch",
			Handler:    _Remote_Batch_Handler,
		},
		{
			MethodName: "close",
			Handler:    _Remote_Close_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "iter",
			Handler:       _Remote_Iter_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "snapshot",
			Handler:       _Remote_Snapshot_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "sync",
			Handler:       _Remote_Sync_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pkg/pb/remote.proto",
}

Remote_ServiceDesc is the grpc.ServiceDesc for Remote service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var S3Proxy_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.S3Proxy",
	HandlerType: (*S3ProxyServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetFile",
			Handler:    _S3Proxy_GetFile_Handler,
		},
		{
			MethodName: "PutFile",
			Handler:    _S3Proxy_PutFile_Handler,
		},
		{
			MethodName: "ListHeaderStartAt",
			Handler:    _S3Proxy_ListHeaderStartAt_Handler,
		},
		{
			MethodName: "RemoveFiles",
			Handler:    _S3Proxy_RemoveFiles_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetBlock",
			Handler:       _S3Proxy_GetBlock_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "PutBlock",
			Handler:       _S3Proxy_PutBlock_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "pkg/pb/store.proto",
}

S3Proxy_ServiceDesc is the grpc.ServiceDesc for S3Proxy service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var SubscribeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pb.SubscribeService",
	HandlerType: (*SubscribeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListReader",
			Handler:    _SubscribeService_ListReader_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WatchWriterEvent",
			Handler:       _SubscribeService_WatchWriterEvent_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pkg/pb/subscribe.proto",
}

SubscribeService_ServiceDesc is the grpc.ServiceDesc for SubscribeService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterHeartbeatServiceServer 

func RegisterHeartbeatServiceServer(s grpc.ServiceRegistrar, srv HeartbeatServiceServer)

func RegisterRemoteServer 

func RegisterRemoteServer(s grpc.ServiceRegistrar, srv RemoteServer)

func RegisterS3ProxyServer 

func RegisterS3ProxyServer(s grpc.ServiceRegistrar, srv S3ProxyServer)

func RegisterSubscribeServiceServer 

func RegisterSubscribeServiceServer(s grpc.ServiceRegistrar, srv SubscribeServiceServer)

Types

type Account 

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

func (*Account) Descriptor deprecated 

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

Deprecated: Use Account.ProtoReflect.Descriptor instead.

func (*Account) GetAddress 

func (x *Account) GetAddress() string

func (*Account) GetData 

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

func (*Account) ProtoMessage 

func (*Account) ProtoMessage()

func (*Account) ProtoReflect 

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

func (*Account) Reset 

func (x *Account) Reset()

func (*Account) String 

func (x *Account) String() string

type Accounts 

type Accounts struct {
	Accounts []*Account `protobuf:"bytes,1,rep,name=accounts,proto3" json:"accounts,omitempty"`
	// contains filtered or unexported fields
}

func (*Accounts) Descriptor deprecated 

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

Deprecated: Use Accounts.ProtoReflect.Descriptor instead.

func (*Accounts) GetAccounts 

func (x *Accounts) GetAccounts() []*Account

func (*Accounts) ProtoMessage 

func (*Accounts) ProtoMessage()

func (*Accounts) ProtoReflect 

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

func (*Accounts) Reset 

func (x *Accounts) Reset()

func (*Accounts) String 

func (x *Accounts) String() string

type BatchReply 

type BatchReply struct {
	// contains filtered or unexported fields
}

func (*BatchReply) Descriptor deprecated 

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

Deprecated: Use BatchReply.ProtoReflect.Descriptor instead.

func (*BatchReply) ProtoMessage 

func (*BatchReply) ProtoMessage()

func (*BatchReply) ProtoReflect 

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

func (*BatchReply) Reset 

func (x *BatchReply) Reset()

func (*BatchReply) String 

func (x *BatchReply) String() string

type BatchRequest 

type BatchRequest struct {
	Id    int32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Data  []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Async bool   `protobuf:"varint,3,opt,name=async,proto3" json:"async,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchRequest) Descriptor deprecated 

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

Deprecated: Use BatchRequest.ProtoReflect.Descriptor instead.

func (*BatchRequest) GetAsync 

func (x *BatchRequest) GetAsync() bool

func (*BatchRequest) GetData 

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

func (*BatchRequest) GetId 

func (x *BatchRequest) GetId() int32

func (*BatchRequest) ProtoMessage 

func (*BatchRequest) ProtoMessage()

func (*BatchRequest) ProtoReflect 

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

func (*BatchRequest) Reset 

func (x *BatchRequest) Reset()

func (*BatchRequest) String 

func (x *BatchRequest) String() string

type Block 

type Block struct {
	Info       *BlockInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	BatchItems []*Data    `protobuf:"bytes,2,rep,name=batch_items,json=batchItems,proto3" json:"batch_items,omitempty"`
	// contains filtered or unexported fields
}

func (*Block) Descriptor deprecated 

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

Deprecated: Use Block.ProtoReflect.Descriptor instead.

func (*Block) GetBatchItems 

func (x *Block) GetBatchItems() []*Data

func (*Block) GetInfo 

func (x *Block) GetInfo() *BlockInfo

func (*Block) ProtoMessage 

func (*Block) ProtoMessage()

func (*Block) ProtoReflect 

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

func (*Block) Reset 

func (x *Block) Reset()

func (*Block) String 

func (x *Block) String() string

type BlockChunk 

type BlockChunk struct {
	Info  *BlockInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	Chunk []byte     `protobuf:"bytes,2,opt,name=chunk,proto3" json:"chunk,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockChunk) Descriptor deprecated 

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

Deprecated: Use BlockChunk.ProtoReflect.Descriptor instead.

func (*BlockChunk) GetChunk 

func (x *BlockChunk) GetChunk() []byte

func (*BlockChunk) GetInfo 

func (x *BlockChunk) GetInfo() *BlockInfo

func (*BlockChunk) ProtoMessage 

func (*BlockChunk) ProtoMessage()

func (*BlockChunk) ProtoReflect 

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

func (*BlockChunk) Reset 

func (x *BlockChunk) Reset()

func (*BlockChunk) String 

func (x *BlockChunk) String() string

type BlockInfo 

type BlockInfo struct {
	ChainId   string              `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	Env       string              `protobuf:"bytes,2,opt,name=env,proto3" json:"env,omitempty"`
	Role      string              `protobuf:"bytes,3,opt,name=role,proto3" json:"role,omitempty"`
	BlockNum  int64               `protobuf:"varint,4,opt,name=block_num,json=blockNum,proto3" json:"block_num,omitempty"`
	BlockHash string              `protobuf:"bytes,5,opt,name=block_hash,json=blockHash,proto3" json:"block_hash,omitempty"`
	BlockRoot string              `protobuf:"bytes,6,opt,name=block_root,json=blockRoot,proto3" json:"block_root,omitempty"`
	MsgOffset int64               `protobuf:"varint,7,opt,name=msg_offset,json=msgOffset,proto3" json:"msg_offset,omitempty"`
	BlockType BlockInfo_BlockType `protobuf:"varint,8,opt,name=block_type,json=blockType,proto3,enum=pb.BlockInfo_BlockType" json:"block_type,omitempty"`
	BlockSize int64               `protobuf:"varint,9,opt,name=block_size,json=blockSize,proto3" json:"block_size,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockInfo) Descriptor deprecated 

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

Deprecated: Use BlockInfo.ProtoReflect.Descriptor instead.

func (*BlockInfo) GetBlockHash 

func (x *BlockInfo) GetBlockHash() string

func (*BlockInfo) GetBlockNum 

func (x *BlockInfo) GetBlockNum() int64

func (*BlockInfo) GetBlockRoot 

func (x *BlockInfo) GetBlockRoot() string

func (*BlockInfo) GetBlockSize 

func (x *BlockInfo) GetBlockSize() int64

func (*BlockInfo) GetBlockType 

func (x *BlockInfo) GetBlockType() BlockInfo_BlockType

func (*BlockInfo) GetChainId 

func (x *BlockInfo) GetChainId() string

func (*BlockInfo) GetEnv 

func (x *BlockInfo) GetEnv() string

func (*BlockInfo) GetMsgOffset 

func (x *BlockInfo) GetMsgOffset() int64

func (*BlockInfo) GetRole 

func (x *BlockInfo) GetRole() string

func (*BlockInfo) ProtoMessage 

func (*BlockInfo) ProtoMessage()

func (*BlockInfo) ProtoReflect 

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

func (*BlockInfo) Reset 

func (x *BlockInfo) Reset()

func (*BlockInfo) String 

func (x *BlockInfo) String() string

type BlockInfo_BlockType 

type BlockInfo_BlockType int32
const (
	BlockInfo_UNKNOWN BlockInfo_BlockType = 0
	BlockInfo_DATA    BlockInfo_BlockType = 1
	BlockInfo_HEADER  BlockInfo_BlockType = 2
)

func (BlockInfo_BlockType) Descriptor 

func (BlockInfo_BlockType) Descriptor() protoreflect.EnumDescriptor

func (BlockInfo_BlockType) Enum 

func (x BlockInfo_BlockType) Enum() *BlockInfo_BlockType

func (BlockInfo_BlockType) EnumDescriptor deprecated 

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

Deprecated: Use BlockInfo_BlockType.Descriptor instead.

func (BlockInfo_BlockType) Number 

func (x BlockInfo_BlockType) Number() protoreflect.EnumNumber

func (BlockInfo_BlockType) String 

func (x BlockInfo_BlockType) String() string

func (BlockInfo_BlockType) Type 

func (BlockInfo_BlockType) Type() protoreflect.EnumType

type BlockUpdateInfo 

type BlockUpdateInfo struct {
	BlockNum  int64  `protobuf:"varint,4,opt,name=block_num,json=blockNum,proto3" json:"block_num,omitempty"`
	BlockHash string `protobuf:"bytes,5,opt,name=block_hash,json=blockHash,proto3" json:"block_hash,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockUpdateInfo) Descriptor deprecated 

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

Deprecated: Use BlockUpdateInfo.ProtoReflect.Descriptor instead.

func (*BlockUpdateInfo) GetBlockHash 

func (x *BlockUpdateInfo) GetBlockHash() string

func (*BlockUpdateInfo) GetBlockNum 

func (x *BlockUpdateInfo) GetBlockNum() int64

func (*BlockUpdateInfo) ProtoMessage 

func (*BlockUpdateInfo) ProtoMessage()

func (*BlockUpdateInfo) ProtoReflect 

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

func (*BlockUpdateInfo) Reset 

func (x *BlockUpdateInfo) Reset()

func (*BlockUpdateInfo) String 

func (x *BlockUpdateInfo) String() string

type CloseReply 

type CloseReply struct {
	// contains filtered or unexported fields
}

func (*CloseReply) Descriptor deprecated 

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

Deprecated: Use CloseReply.ProtoReflect.Descriptor instead.

func (*CloseReply) ProtoMessage 

func (*CloseReply) ProtoMessage()

func (*CloseReply) ProtoReflect 

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

func (*CloseReply) Reset 

func (x *CloseReply) Reset()

func (*CloseReply) String 

func (x *CloseReply) String() string

type CloseRequest 

type CloseRequest struct {
	Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseRequest) Descriptor deprecated 

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

Deprecated: Use CloseRequest.ProtoReflect.Descriptor instead.

func (*CloseRequest) GetId 

func (x *CloseRequest) GetId() int32

func (*CloseRequest) ProtoMessage 

func (*CloseRequest) ProtoMessage()

func (*CloseRequest) ProtoReflect 

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

func (*CloseRequest) Reset 

func (x *CloseRequest) Reset()

func (*CloseRequest) String 

func (x *CloseRequest) String() string

type CompactReply 

type CompactReply struct {
	// contains filtered or unexported fields
}

func (*CompactReply) Descriptor deprecated 

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

Deprecated: Use CompactReply.ProtoReflect.Descriptor instead.

func (*CompactReply) ProtoMessage 

func (*CompactReply) ProtoMessage()

func (*CompactReply) ProtoReflect 

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

func (*CompactReply) Reset 

func (x *CompactReply) Reset()

func (*CompactReply) String 

func (x *CompactReply) String() string

type CompactRequest 

type CompactRequest struct {
	Id    int32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Start []byte `protobuf:"bytes,2,opt,name=start,proto3" json:"start,omitempty"`
	Limit []byte `protobuf:"bytes,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*CompactRequest) Descriptor deprecated 

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

Deprecated: Use CompactRequest.ProtoReflect.Descriptor instead.

func (*CompactRequest) GetId 

func (x *CompactRequest) GetId() int32

func (*CompactRequest) GetLimit 

func (x *CompactRequest) GetLimit() []byte

func (*CompactRequest) GetStart 

func (x *CompactRequest) GetStart() []byte

func (*CompactRequest) ProtoMessage 

func (*CompactRequest) ProtoMessage()

func (*CompactRequest) ProtoReflect 

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

func (*CompactRequest) Reset 

func (x *CompactRequest) Reset()

func (*CompactRequest) String 

func (x *CompactRequest) String() string

type DBInfo 

type DBInfo struct {
	Id     int32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	DbType string `protobuf:"bytes,2,opt,name=db_type,json=dbType,proto3" json:"db_type,omitempty"`
	DbPath string `protobuf:"bytes,3,opt,name=db_path,json=dbPath,proto3" json:"db_path,omitempty"`
	IsMeta bool   `protobuf:"varint,4,opt,name=is_meta,json=isMeta,proto3" json:"is_meta,omitempty"`
	// contains filtered or unexported fields
}

func (*DBInfo) Descriptor deprecated 

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

Deprecated: Use DBInfo.ProtoReflect.Descriptor instead.

func (*DBInfo) GetDbPath 

func (x *DBInfo) GetDbPath() string

func (*DBInfo) GetDbType 

func (x *DBInfo) GetDbType() string

func (*DBInfo) GetId 

func (x *DBInfo) GetId() int32

func (*DBInfo) GetIsMeta 

func (x *DBInfo) GetIsMeta() bool

func (*DBInfo) ProtoMessage 

func (*DBInfo) ProtoMessage()

func (*DBInfo) ProtoReflect 

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

func (*DBInfo) Reset 

func (x *DBInfo) Reset()

func (*DBInfo) String 

func (x *DBInfo) String() string

type DBInfoList 

type DBInfoList struct {
	DbInfos []*DBInfo `protobuf:"bytes,1,rep,name=db_infos,json=dbInfos,proto3" json:"db_infos,omitempty"`
	// contains filtered or unexported fields
}

func (*DBInfoList) Descriptor deprecated 

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

Deprecated: Use DBInfoList.ProtoReflect.Descriptor instead.

func (*DBInfoList) GetDbInfos 

func (x *DBInfoList) GetDbInfos() []*DBInfo

func (*DBInfoList) ProtoMessage 

func (*DBInfoList) ProtoMessage()

func (*DBInfoList) ProtoReflect 

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

func (*DBInfoList) Reset 

func (x *DBInfoList) Reset()

func (*DBInfoList) String 

func (x *DBInfoList) String() string

type Data 

type Data struct {
	Id   int32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Data) Descriptor deprecated 

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

Deprecated: Use Data.ProtoReflect.Descriptor instead.

func (*Data) GetData 

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

func (*Data) GetId 

func (x *Data) GetId() int32

func (*Data) ProtoMessage 

func (*Data) ProtoMessage()

func (*Data) ProtoReflect 

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

func (*Data) Reset 

func (x *Data) Reset()

func (*Data) String 

func (x *Data) String() string

type DelReply 

type DelReply struct {
	// contains filtered or unexported fields
}

func (*DelReply) Descriptor deprecated 

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

Deprecated: Use DelReply.ProtoReflect.Descriptor instead.

func (*DelReply) ProtoMessage 

func (*DelReply) ProtoMessage()

func (*DelReply) ProtoReflect 

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

func (*DelReply) Reset 

func (x *DelReply) Reset()

func (*DelReply) String 

func (x *DelReply) String() string

type DelRequest 

type DelRequest struct {
	Id    int32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Key   []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Async bool   `protobuf:"varint,3,opt,name=async,proto3" json:"async,omitempty"`
	// contains filtered or unexported fields
}

func (*DelRequest) Descriptor deprecated 

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

Deprecated: Use DelRequest.ProtoReflect.Descriptor instead.

func (*DelRequest) GetAsync 

func (x *DelRequest) GetAsync() bool

func (*DelRequest) GetId 

func (x *DelRequest) GetId() int32

func (*DelRequest) GetKey 

func (x *DelRequest) GetKey() []byte

func (*DelRequest) ProtoMessage 

func (*DelRequest) ProtoMessage()

func (*DelRequest) ProtoReflect 

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

func (*DelRequest) Reset 

func (x *DelRequest) Reset()

func (*DelRequest) String 

func (x *DelRequest) String() string

type GetBlockRequest 

type GetBlockRequest struct {
	Info    *BlockInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	NoCache bool       `protobuf:"varint,2,opt,name=no_cache,json=noCache,proto3" json:"no_cache,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBlockRequest) Descriptor deprecated 

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

Deprecated: Use GetBlockRequest.ProtoReflect.Descriptor instead.

func (*GetBlockRequest) GetInfo 

func (x *GetBlockRequest) GetInfo() *BlockInfo

func (*GetBlockRequest) GetNoCache 

func (x *GetBlockRequest) GetNoCache() bool

func (*GetBlockRequest) ProtoMessage 

func (*GetBlockRequest) ProtoMessage()

func (*GetBlockRequest) ProtoReflect 

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

func (*GetBlockRequest) Reset 

func (x *GetBlockRequest) Reset()

func (*GetBlockRequest) String 

func (x *GetBlockRequest) String() string

type GetFileReply 

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

func (*GetFileReply) Descriptor deprecated 

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

Deprecated: Use GetFileReply.ProtoReflect.Descriptor instead.

func (*GetFileReply) GetData 

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

func (*GetFileReply) ProtoMessage 

func (*GetFileReply) ProtoMessage()

func (*GetFileReply) ProtoReflect 

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

func (*GetFileReply) Reset 

func (x *GetFileReply) Reset()

func (*GetFileReply) String 

func (x *GetFileReply) String() string

type GetFileRequest 

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

func (*GetFileRequest) Descriptor deprecated 

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

Deprecated: Use GetFileRequest.ProtoReflect.Descriptor instead.

func (*GetFileRequest) GetPath 

func (x *GetFileRequest) GetPath() string

func (*GetFileRequest) ProtoMessage 

func (*GetFileRequest) ProtoMessage()

func (*GetFileRequest) ProtoReflect 

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

func (*GetFileRequest) Reset 

func (x *GetFileRequest) Reset()

func (*GetFileRequest) String 

func (x *GetFileRequest) String() string

type GetReply 

type GetReply struct {
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	Exist bool   `protobuf:"varint,2,opt,name=exist,proto3" json:"exist,omitempty"`
	// contains filtered or unexported fields
}

func (*GetReply) Descriptor deprecated 

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

Deprecated: Use GetReply.ProtoReflect.Descriptor instead.

func (*GetReply) GetExist 

func (x *GetReply) GetExist() bool

func (*GetReply) GetValue 

func (x *GetReply) GetValue() []byte

func (*GetReply) ProtoMessage 

func (*GetReply) ProtoMessage()

func (*GetReply) ProtoReflect 

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

func (*GetReply) Reset 

func (x *GetReply) Reset()

func (*GetReply) String 

func (x *GetReply) String() string

type GetRequest 

type GetRequest struct {
	Id  int32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor deprecated 

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetId 

func (x *GetRequest) GetId() int32

func (*GetRequest) GetKey 

func (x *GetRequest) GetKey() []byte

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

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

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

type HasReply 

type HasReply struct {
	Exist bool `protobuf:"varint,1,opt,name=exist,proto3" json:"exist,omitempty"`
	// contains filtered or unexported fields
}

func (*HasReply) Descriptor deprecated 

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

Deprecated: Use HasReply.ProtoReflect.Descriptor instead.

func (*HasReply) GetExist 

func (x *HasReply) GetExist() bool

func (*HasReply) ProtoMessage 

func (*HasReply) ProtoMessage()

func (*HasReply) ProtoReflect 

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

func (*HasReply) Reset 

func (x *HasReply) Reset()

func (*HasReply) String 

func (x *HasReply) String() string

type HasRequest 

type HasRequest struct {
	Id  int32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*HasRequest) Descriptor deprecated 

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

Deprecated: Use HasRequest.ProtoReflect.Descriptor instead.

func (*HasRequest) GetId 

func (x *HasRequest) GetId() int32

func (*HasRequest) GetKey 

func (x *HasRequest) GetKey() []byte

func (*HasRequest) ProtoMessage 

func (*HasRequest) ProtoMessage()

func (*HasRequest) ProtoReflect 

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

func (*HasRequest) Reset 

func (x *HasRequest) Reset()

func (*HasRequest) String 

func (x *HasRequest) String() string

type HeartbeatRequest 

type HeartbeatRequest struct {
	Id *NodeId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatRequest) Descriptor deprecated 

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

Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.

func (*HeartbeatRequest) GetId 

func (x *HeartbeatRequest) GetId() *NodeId

func (*HeartbeatRequest) ProtoMessage 

func (*HeartbeatRequest) ProtoMessage()

func (*HeartbeatRequest) ProtoReflect 

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

func (*HeartbeatRequest) Reset 

func (x *HeartbeatRequest) Reset()

func (*HeartbeatRequest) String 

func (x *HeartbeatRequest) String() string

type HeartbeatResponse 

type HeartbeatResponse struct {
	// contains filtered or unexported fields
}

func (*HeartbeatResponse) Descriptor deprecated 

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

Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.

func (*HeartbeatResponse) ProtoMessage 

func (*HeartbeatResponse) ProtoMessage()

func (*HeartbeatResponse) ProtoReflect 

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

func (*HeartbeatResponse) Reset 

func (x *HeartbeatResponse) Reset()

func (*HeartbeatResponse) String 

func (x *HeartbeatResponse) String() string

type HeartbeatServiceClient 

type HeartbeatServiceClient interface {
	Report(ctx context.Context, opts ...grpc.CallOption) (HeartbeatService_ReportClient, error)
	SetRole(ctx context.Context, in *SetRoleRequest, opts ...grpc.CallOption) (*SetRoleResponse, error)
}

HeartbeatServiceClient is the client API for HeartbeatService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewHeartbeatServiceClient 

func NewHeartbeatServiceClient(cc grpc.ClientConnInterface) HeartbeatServiceClient

type HeartbeatServiceServer 

type HeartbeatServiceServer interface {
	Report(HeartbeatService_ReportServer) error
	SetRole(context.Context, *SetRoleRequest) (*SetRoleResponse, error)
	// contains filtered or unexported methods
}

HeartbeatServiceServer is the server API for HeartbeatService service. All implementations must embed UnimplementedHeartbeatServiceServer for forward compatibility

type HeartbeatService_ReportClient 

type HeartbeatService_ReportClient interface {
	Send(*HeartbeatRequest) error
	CloseAndRecv() (*HeartbeatResponse, error)
	grpc.ClientStream
}

type HeartbeatService_ReportServer 

type HeartbeatService_ReportServer interface {
	SendAndClose(*HeartbeatResponse) error
	Recv() (*HeartbeatRequest, error)
	grpc.ServerStream
}

type IterReply 

type IterReply struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	IsEnd bool   `protobuf:"varint,3,opt,name=is_end,json=isEnd,proto3" json:"is_end,omitempty"`
	Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*IterReply) Descriptor deprecated 

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

Deprecated: Use IterReply.ProtoReflect.Descriptor instead.

func (*IterReply) GetError 

func (x *IterReply) GetError() string

func (*IterReply) GetIsEnd 

func (x *IterReply) GetIsEnd() bool

func (*IterReply) GetKey 

func (x *IterReply) GetKey() []byte

func (*IterReply) GetValue 

func (x *IterReply) GetValue() []byte

func (*IterReply) ProtoMessage 

func (*IterReply) ProtoMessage()

func (*IterReply) ProtoReflect 

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

func (*IterReply) Reset 

func (x *IterReply) Reset()

func (*IterReply) String 

func (x *IterReply) String() string

type IterRequest 

type IterRequest struct {
	Id      int32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Start   []byte `protobuf:"bytes,2,opt,name=start,proto3" json:"start,omitempty"`
	Limit   []byte `protobuf:"bytes,3,opt,name=limit,proto3" json:"limit,omitempty"`
	Reverse bool   `protobuf:"varint,4,opt,name=reverse,proto3" json:"reverse,omitempty"`
	// contains filtered or unexported fields
}

func (*IterRequest) Descriptor deprecated 

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

Deprecated: Use IterRequest.ProtoReflect.Descriptor instead.

func (*IterRequest) GetId 

func (x *IterRequest) GetId() int32

func (*IterRequest) GetLimit 

func (x *IterRequest) GetLimit() []byte

func (*IterRequest) GetReverse 

func (x *IterRequest) GetReverse() bool

func (*IterRequest) GetStart 

func (x *IterRequest) GetStart() []byte

func (*IterRequest) ProtoMessage 

func (*IterRequest) ProtoMessage()

func (*IterRequest) ProtoReflect 

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

func (*IterRequest) Reset 

func (x *IterRequest) Reset()

func (*IterRequest) String 

func (x *IterRequest) String() string

type KV 

type KV struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*KV) Descriptor deprecated 

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

Deprecated: Use KV.ProtoReflect.Descriptor instead.

func (*KV) GetKey 

func (x *KV) GetKey() []byte

func (*KV) GetValue 

func (x *KV) GetValue() []byte

func (*KV) ProtoMessage 

func (*KV) ProtoMessage()

func (*KV) ProtoReflect 

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

func (*KV) Reset 

func (x *KV) Reset()

func (*KV) String 

func (x *KV) String() string

type ListHeaderStartAtReply 

type ListHeaderStartAtReply struct {
	Infos []*BlockInfo `protobuf:"bytes,1,rep,name=infos,proto3" json:"infos,omitempty"`
	// contains filtered or unexported fields
}

func (*ListHeaderStartAtReply) Descriptor deprecated 

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

Deprecated: Use ListHeaderStartAtReply.ProtoReflect.Descriptor instead.

func (*ListHeaderStartAtReply) GetInfos 

func (x *ListHeaderStartAtReply) GetInfos() []*BlockInfo

func (*ListHeaderStartAtReply) ProtoMessage 

func (*ListHeaderStartAtReply) ProtoMessage()

func (*ListHeaderStartAtReply) ProtoReflect 

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

func (*ListHeaderStartAtReply) Reset 

func (x *ListHeaderStartAtReply) Reset()

func (*ListHeaderStartAtReply) String 

func (x *ListHeaderStartAtReply) String() string

type ListHeaderStartAtRequest 

type ListHeaderStartAtRequest struct {
	Env            string `protobuf:"bytes,1,opt,name=env,proto3" json:"env,omitempty"`
	ChainId        string `protobuf:"bytes,2,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	Role           string `protobuf:"bytes,3,opt,name=role,proto3" json:"role,omitempty"`
	BlockNum       int64  `protobuf:"varint,4,opt,name=block_num,json=blockNum,proto3" json:"block_num,omitempty"`
	CountNum       int64  `protobuf:"varint,5,opt,name=count_num,json=countNum,proto3" json:"count_num,omitempty"`
	AfterMsgOffset int64  `protobuf:"varint,6,opt,name=after_msg_offset,json=afterMsgOffset,proto3" json:"after_msg_offset,omitempty"`
	// contains filtered or unexported fields
}

func (*ListHeaderStartAtRequest) Descriptor deprecated 

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

Deprecated: Use ListHeaderStartAtRequest.ProtoReflect.Descriptor instead.

func (*ListHeaderStartAtRequest) GetAfterMsgOffset 

func (x *ListHeaderStartAtRequest) GetAfterMsgOffset() int64

func (*ListHeaderStartAtRequest) GetBlockNum 

func (x *ListHeaderStartAtRequest) GetBlockNum() int64

func (*ListHeaderStartAtRequest) GetChainId 

func (x *ListHeaderStartAtRequest) GetChainId() string

func (*ListHeaderStartAtRequest) GetCountNum 

func (x *ListHeaderStartAtRequest) GetCountNum() int64

func (*ListHeaderStartAtRequest) GetEnv 

func (x *ListHeaderStartAtRequest) GetEnv() string

func (*ListHeaderStartAtRequest) GetRole 

func (x *ListHeaderStartAtRequest) GetRole() string

func (*ListHeaderStartAtRequest) ProtoMessage 

func (*ListHeaderStartAtRequest) ProtoMessage()

func (*ListHeaderStartAtRequest) ProtoReflect 

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

func (*ListHeaderStartAtRequest) Reset 

func (x *ListHeaderStartAtRequest) Reset()

func (*ListHeaderStartAtRequest) String 

func (x *ListHeaderStartAtRequest) String() string

type ListReaderRequest 

type ListReaderRequest struct {
	// contains filtered or unexported fields
}

func (*ListReaderRequest) Descriptor deprecated 

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

Deprecated: Use ListReaderRequest.ProtoReflect.Descriptor instead.

func (*ListReaderRequest) ProtoMessage 

func (*ListReaderRequest) ProtoMessage()

func (*ListReaderRequest) ProtoReflect 

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

func (*ListReaderRequest) Reset 

func (x *ListReaderRequest) Reset()

func (*ListReaderRequest) String 

func (x *ListReaderRequest) String() string

type ListReaderResponse 

type ListReaderResponse struct {
	Readers []*NodeId `protobuf:"bytes,1,rep,name=readers,proto3" json:"readers,omitempty"`
	// contains filtered or unexported fields
}

func (*ListReaderResponse) Descriptor deprecated 

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

Deprecated: Use ListReaderResponse.ProtoReflect.Descriptor instead.

func (*ListReaderResponse) GetReaders 

func (x *ListReaderResponse) GetReaders() []*NodeId

func (*ListReaderResponse) ProtoMessage 

func (*ListReaderResponse) ProtoMessage()

func (*ListReaderResponse) ProtoReflect 

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

func (*ListReaderResponse) Reset 

func (x *ListReaderResponse) Reset()

func (*ListReaderResponse) String 

func (x *ListReaderResponse) String() string

type NodeId 

type NodeId struct {
	Env             string           `protobuf:"bytes,1,opt,name=env,proto3" json:"env,omitempty"`                        // 环境
	ChainId         string           `protobuf:"bytes,2,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` // 对应chain的id
	Role            NodeRole         `protobuf:"varint,3,opt,name=role,proto3,enum=pb.NodeRole" json:"role,omitempty"`
	Uuid            string           `protobuf:"bytes,4,opt,name=uuid,proto3" json:"uuid,omitempty"`                                                // 机器唯一标识
	Endpoint        string           `protobuf:"bytes,5,opt,name=endpoint,proto3" json:"endpoint,omitempty"`                                        // 机器ip:port
	BlockUpdateInfo *BlockUpdateInfo `protobuf:"bytes,6,opt,name=block_update_info,json=blockUpdateInfo,proto3" json:"block_update_info,omitempty"` // 最新区块信息
	// contains filtered or unexported fields
}

func (*NodeId) Descriptor deprecated 

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

Deprecated: Use NodeId.ProtoReflect.Descriptor instead.

func (*NodeId) GetBlockUpdateInfo 

func (x *NodeId) GetBlockUpdateInfo() *BlockUpdateInfo

func (*NodeId) GetChainId 

func (x *NodeId) GetChainId() string

func (*NodeId) GetEndpoint 

func (x *NodeId) GetEndpoint() string

func (*NodeId) GetEnv 

func (x *NodeId) GetEnv() string

func (*NodeId) GetRole 

func (x *NodeId) GetRole() NodeRole

func (*NodeId) GetUuid 

func (x *NodeId) GetUuid() string

func (*NodeId) ProtoMessage 

func (*NodeId) ProtoMessage()

func (*NodeId) ProtoReflect 

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

func (*NodeId) Reset 

func (x *NodeId) Reset()

func (*NodeId) String 

func (x *NodeId) String() string

type NodeRole 

type NodeRole int32
const (
	NodeRole_UNKNOWN_ROLE NodeRole = 0
	NodeRole_WRITERM      NodeRole = 1 // Master Writer
	NodeRole_WRITERB      NodeRole = 2 // Backup Writer
	NodeRole_READER       NodeRole = 3 // Reader
)

func (NodeRole) Descriptor 

func (NodeRole) Descriptor() protoreflect.EnumDescriptor

func (NodeRole) Enum 

func (x NodeRole) Enum() *NodeRole

func (NodeRole) EnumDescriptor deprecated 

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

Deprecated: Use NodeRole.Descriptor instead.

func (NodeRole) Number 

func (x NodeRole) Number() protoreflect.EnumNumber

func (NodeRole) String 

func (x NodeRole) String() string

func (NodeRole) Type 

func (NodeRole) Type() protoreflect.EnumType

type NodeStatus 

type NodeStatus int32
const (
	NodeStatus_UNKNOWN_STATUS NodeStatus = 0
	NodeStatus_SYNCED         NodeStatus = 1 // Blockchain data up-to-date, only for Writer node
	NodeStatus_SYNCING        NodeStatus = 2 // Blockchain date out-of-date, only for Writer node
	NodeStatus_UNHEALTHY      NodeStatus = 3 // Internal unhealthy, either Reader or Writer
)

func (NodeStatus) Descriptor 

func (NodeStatus) Descriptor() protoreflect.EnumDescriptor

func (NodeStatus) Enum 

func (x NodeStatus) Enum() *NodeStatus

func (NodeStatus) EnumDescriptor deprecated 

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

Deprecated: Use NodeStatus.Descriptor instead.

func (NodeStatus) Number 

func (x NodeStatus) Number() protoreflect.EnumNumber

func (NodeStatus) String 

func (x NodeStatus) String() string

func (NodeStatus) Type 

func (NodeStatus) Type() protoreflect.EnumType

type OpenReply 

type OpenReply struct {
	Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*OpenReply) Descriptor deprecated 

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

Deprecated: Use OpenReply.ProtoReflect.Descriptor instead.

func (*OpenReply) GetId 

func (x *OpenReply) GetId() int32

func (*OpenReply) ProtoMessage 

func (*OpenReply) ProtoMessage()

func (*OpenReply) ProtoReflect 

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

func (*OpenReply) Reset 

func (x *OpenReply) Reset()

func (*OpenReply) String 

func (x *OpenReply) String() string

type OpenRequest 

type OpenRequest struct {
	Type     string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Path     string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	IsMetaDB bool   `protobuf:"varint,3,opt,name=isMetaDB,proto3" json:"isMetaDB,omitempty"`
	// contains filtered or unexported fields
}

func (*OpenRequest) Descriptor deprecated 

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

Deprecated: Use OpenRequest.ProtoReflect.Descriptor instead.

func (*OpenRequest) GetIsMetaDB 

func (x *OpenRequest) GetIsMetaDB() bool

func (*OpenRequest) GetPath 

func (x *OpenRequest) GetPath() string

func (*OpenRequest) GetType 

func (x *OpenRequest) GetType() string

func (*OpenRequest) ProtoMessage 

func (*OpenRequest) ProtoMessage()

func (*OpenRequest) ProtoReflect 

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

func (*OpenRequest) Reset 

func (x *OpenRequest) Reset()

func (*OpenRequest) String 

func (x *OpenRequest) String() string

type PutBlockReply 

type PutBlockReply struct {
	// contains filtered or unexported fields
}

func (*PutBlockReply) Descriptor deprecated 

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

Deprecated: Use PutBlockReply.ProtoReflect.Descriptor instead.

func (*PutBlockReply) ProtoMessage 

func (*PutBlockReply) ProtoMessage()

func (*PutBlockReply) ProtoReflect 

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

func (*PutBlockReply) Reset 

func (x *PutBlockReply) Reset()

func (*PutBlockReply) String 

func (x *PutBlockReply) String() string

type PutFileReply 

type PutFileReply struct {
	// contains filtered or unexported fields
}

func (*PutFileReply) Descriptor deprecated 

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

Deprecated: Use PutFileReply.ProtoReflect.Descriptor instead.

func (*PutFileReply) ProtoMessage 

func (*PutFileReply) ProtoMessage()

func (*PutFileReply) ProtoReflect 

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

func (*PutFileReply) Reset 

func (x *PutFileReply) Reset()

func (*PutFileReply) String 

func (x *PutFileReply) String() string

type PutFileRequest 

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

func (*PutFileRequest) Descriptor deprecated 

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

Deprecated: Use PutFileRequest.ProtoReflect.Descriptor instead.

func (*PutFileRequest) GetData 

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

func (*PutFileRequest) GetPath 

func (x *PutFileRequest) GetPath() string

func (*PutFileRequest) ProtoMessage 

func (*PutFileRequest) ProtoMessage()

func (*PutFileRequest) ProtoReflect 

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

func (*PutFileRequest) Reset 

func (x *PutFileRequest) Reset()

func (*PutFileRequest) String 

func (x *PutFileRequest) String() string

type PutReply 

type PutReply struct {
	// contains filtered or unexported fields
}

func (*PutReply) Descriptor deprecated 

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

Deprecated: Use PutReply.ProtoReflect.Descriptor instead.

func (*PutReply) ProtoMessage 

func (*PutReply) ProtoMessage()

func (*PutReply) ProtoReflect 

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

func (*PutReply) Reset 

func (x *PutReply) Reset()

func (*PutReply) String 

func (x *PutReply) String() string

type PutRequest 

type PutRequest struct {
	Id    int32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Key   []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Async bool   `protobuf:"varint,4,opt,name=async,proto3" json:"async,omitempty"`
	// contains filtered or unexported fields
}

func (*PutRequest) Descriptor deprecated 

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

Deprecated: Use PutRequest.ProtoReflect.Descriptor instead.

func (*PutRequest) GetAsync 

func (x *PutRequest) GetAsync() bool

func (*PutRequest) GetId 

func (x *PutRequest) GetId() int32

func (*PutRequest) GetKey 

func (x *PutRequest) GetKey() []byte

func (*PutRequest) GetValue 

func (x *PutRequest) GetValue() []byte

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) ProtoReflect 

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

func (*PutRequest) Reset 

func (x *PutRequest) Reset()

func (*PutRequest) String 

func (x *PutRequest) String() string

type RemoteClient 

type RemoteClient interface {
	Open(ctx context.Context, in *OpenRequest, opts ...grpc.CallOption) (*OpenReply, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetReply, error)
	Has(ctx context.Context, in *HasRequest, opts ...grpc.CallOption) (*HasReply, error)
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutReply, error)
	Del(ctx context.Context, in *DelRequest, opts ...grpc.CallOption) (*DelReply, error)
	Stat(ctx context.Context, in *StatRequest, opts ...grpc.CallOption) (*StatReply, error)
	Stats(ctx context.Context, in *StatsRequest, opts ...grpc.CallOption) (*StatsReply, error)
	Compact(ctx context.Context, in *CompactRequest, opts ...grpc.CallOption) (*CompactReply, error)
	Batch(ctx context.Context, in *BatchRequest, opts ...grpc.CallOption) (*BatchReply, error)
	Close(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseReply, error)
	Iter(ctx context.Context, in *IterRequest, opts ...grpc.CallOption) (Remote_IterClient, error)
	Snapshot(ctx context.Context, opts ...grpc.CallOption) (Remote_SnapshotClient, error)
	Sync(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (Remote_SyncClient, error)
}

RemoteClient is the client API for Remote service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewRemoteClient 

func NewRemoteClient(cc grpc.ClientConnInterface) RemoteClient

type RemoteServer 

type RemoteServer interface {
	Open(context.Context, *OpenRequest) (*OpenReply, error)
	Get(context.Context, *GetRequest) (*GetReply, error)
	Has(context.Context, *HasRequest) (*HasReply, error)
	Put(context.Context, *PutRequest) (*PutReply, error)
	Del(context.Context, *DelRequest) (*DelReply, error)
	Stat(context.Context, *StatRequest) (*StatReply, error)
	Stats(context.Context, *StatsRequest) (*StatsReply, error)
	Compact(context.Context, *CompactRequest) (*CompactReply, error)
	Batch(context.Context, *BatchRequest) (*BatchReply, error)
	Close(context.Context, *CloseRequest) (*CloseReply, error)
	Iter(*IterRequest, Remote_IterServer) error
	Snapshot(Remote_SnapshotServer) error
	Sync(*SyncRequest, Remote_SyncServer) error
	// contains filtered or unexported methods
}

RemoteServer is the server API for Remote service. All implementations must embed UnimplementedRemoteServer for forward compatibility

type Remote_IterClient 

type Remote_IterClient interface {
	Recv() (*IterReply, error)
	grpc.ClientStream
}

type Remote_IterServer 

type Remote_IterServer interface {
	Send(*IterReply) error
	grpc.ServerStream
}

type Remote_SnapshotClient 

type Remote_SnapshotClient interface {
	Send(*SnapshotRequest) error
	Recv() (*SnapshotReply, error)
	grpc.ClientStream
}

type Remote_SnapshotServer 

type Remote_SnapshotServer interface {
	Send(*SnapshotReply) error
	Recv() (*SnapshotRequest, error)
	grpc.ServerStream
}

type Remote_SyncClient 

type Remote_SyncClient interface {
	Recv() (*SyncyReply, error)
	grpc.ClientStream
}

type Remote_SyncServer 

type Remote_SyncServer interface {
	Send(*SyncyReply) error
	grpc.ServerStream
}

type RemoveFilesReply 

type RemoveFilesReply struct {
	// contains filtered or unexported fields
}

func (*RemoveFilesReply) Descriptor deprecated 

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

Deprecated: Use RemoveFilesReply.ProtoReflect.Descriptor instead.

func (*RemoveFilesReply) ProtoMessage 

func (*RemoveFilesReply) ProtoMessage()

func (*RemoveFilesReply) ProtoReflect 

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

func (*RemoveFilesReply) Reset 

func (x *RemoveFilesReply) Reset()

func (*RemoveFilesReply) String 

func (x *RemoveFilesReply) String() string

type RemoveFilesRequest 

type RemoveFilesRequest struct {
	Infos []*BlockInfo `protobuf:"bytes,1,rep,name=infos,proto3" json:"infos,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveFilesRequest) Descriptor deprecated 

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

Deprecated: Use RemoveFilesRequest.ProtoReflect.Descriptor instead.

func (*RemoveFilesRequest) GetInfos 

func (x *RemoveFilesRequest) GetInfos() []*BlockInfo

func (*RemoveFilesRequest) ProtoMessage 

func (*RemoveFilesRequest) ProtoMessage()

func (*RemoveFilesRequest) ProtoReflect 

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

func (*RemoveFilesRequest) Reset 

func (x *RemoveFilesRequest) Reset()

func (*RemoveFilesRequest) String 

func (x *RemoveFilesRequest) String() string

type S3ProxyClient 

type S3ProxyClient interface {
	GetBlock(ctx context.Context, in *GetBlockRequest, opts ...grpc.CallOption) (S3Proxy_GetBlockClient, error)
	PutBlock(ctx context.Context, opts ...grpc.CallOption) (S3Proxy_PutBlockClient, error)
	GetFile(ctx context.Context, in *GetFileRequest, opts ...grpc.CallOption) (*GetFileReply, error)
	PutFile(ctx context.Context, in *PutFileRequest, opts ...grpc.CallOption) (*PutFileReply, error)
	ListHeaderStartAt(ctx context.Context, in *ListHeaderStartAtRequest, opts ...grpc.CallOption) (*ListHeaderStartAtReply, error)
	RemoveFiles(ctx context.Context, in *RemoveFilesRequest, opts ...grpc.CallOption) (*RemoveFilesReply, error)
}

S3ProxyClient is the client API for S3Proxy service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewS3ProxyClient 

func NewS3ProxyClient(cc grpc.ClientConnInterface) S3ProxyClient

type S3ProxyServer 

type S3ProxyServer interface {
	GetBlock(*GetBlockRequest, S3Proxy_GetBlockServer) error
	PutBlock(S3Proxy_PutBlockServer) error
	GetFile(context.Context, *GetFileRequest) (*GetFileReply, error)
	PutFile(context.Context, *PutFileRequest) (*PutFileReply, error)
	ListHeaderStartAt(context.Context, *ListHeaderStartAtRequest) (*ListHeaderStartAtReply, error)
	RemoveFiles(context.Context, *RemoveFilesRequest) (*RemoveFilesReply, error)
	// contains filtered or unexported methods
}

S3ProxyServer is the server API for S3Proxy service. All implementations must embed UnimplementedS3ProxyServer for forward compatibility

type S3Proxy_GetBlockClient 

type S3Proxy_GetBlockClient interface {
	Recv() (*BlockChunk, error)
	grpc.ClientStream
}

type S3Proxy_GetBlockServer 

type S3Proxy_GetBlockServer interface {
	Send(*BlockChunk) error
	grpc.ServerStream
}

type S3Proxy_PutBlockClient 

type S3Proxy_PutBlockClient interface {
	Send(*BlockChunk) error
	CloseAndRecv() (*PutBlockReply, error)
	grpc.ClientStream
}

type S3Proxy_PutBlockServer 

type S3Proxy_PutBlockServer interface {
	SendAndClose(*PutBlockReply) error
	Recv() (*BlockChunk, error)
	grpc.ServerStream
}

type SetRoleRequest 

type SetRoleRequest struct {
	Id *NodeId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*SetRoleRequest) Descriptor deprecated 

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

Deprecated: Use SetRoleRequest.ProtoReflect.Descriptor instead.

func (*SetRoleRequest) GetId 

func (x *SetRoleRequest) GetId() *NodeId

func (*SetRoleRequest) ProtoMessage 

func (*SetRoleRequest) ProtoMessage()

func (*SetRoleRequest) ProtoReflect 

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

func (*SetRoleRequest) Reset 

func (x *SetRoleRequest) Reset()

func (*SetRoleRequest) String 

func (x *SetRoleRequest) String() string

type SetRoleResponse 

type SetRoleResponse struct {
	// contains filtered or unexported fields
}

func (*SetRoleResponse) Descriptor deprecated 

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

Deprecated: Use SetRoleResponse.ProtoReflect.Descriptor instead.

func (*SetRoleResponse) ProtoMessage 

func (*SetRoleResponse) ProtoMessage()

func (*SetRoleResponse) ProtoReflect 

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

func (*SetRoleResponse) Reset 

func (x *SetRoleResponse) Reset()

func (*SetRoleResponse) String 

func (x *SetRoleResponse) String() string

type SnapshotOpenReply 

type SnapshotOpenReply struct {
	// contains filtered or unexported fields
}

func (*SnapshotOpenReply) Descriptor deprecated 

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

Deprecated: Use SnapshotOpenReply.ProtoReflect.Descriptor instead.

func (*SnapshotOpenReply) ProtoMessage 

func (*SnapshotOpenReply) ProtoMessage()

func (*SnapshotOpenReply) ProtoReflect 

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

func (*SnapshotOpenReply) Reset 

func (x *SnapshotOpenReply) Reset()

func (*SnapshotOpenReply) String 

func (x *SnapshotOpenReply) String() string

type SnapshotOpenRequest 

type SnapshotOpenRequest struct {
	// contains filtered or unexported fields
}

func (*SnapshotOpenRequest) Descriptor deprecated 

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

Deprecated: Use SnapshotOpenRequest.ProtoReflect.Descriptor instead.

func (*SnapshotOpenRequest) ProtoMessage 

func (*SnapshotOpenRequest) ProtoMessage()

func (*SnapshotOpenRequest) ProtoReflect 

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

func (*SnapshotOpenRequest) Reset 

func (x *SnapshotOpenRequest) Reset()

func (*SnapshotOpenRequest) String 

func (x *SnapshotOpenRequest) String() string

type SnapshotReply 

type SnapshotReply struct {

	// Types that are assignable to Reply:
	//
	//	*SnapshotReply_Open
	//	*SnapshotReply_Get
	//	*SnapshotReply_Has
	//	*SnapshotReply_Close
	Reply isSnapshotReply_Reply `protobuf_oneof:"reply"`
	// contains filtered or unexported fields
}

func (*SnapshotReply) Descriptor deprecated 

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

Deprecated: Use SnapshotReply.ProtoReflect.Descriptor instead.

func (*SnapshotReply) GetClose 

func (x *SnapshotReply) GetClose() *CloseReply

func (*SnapshotReply) GetGet 

func (x *SnapshotReply) GetGet() *GetReply

func (*SnapshotReply) GetHas 

func (x *SnapshotReply) GetHas() *HasReply

func (*SnapshotReply) GetOpen 

func (x *SnapshotReply) GetOpen() *SnapshotOpenReply

func (*SnapshotReply) GetReply 

func (m *SnapshotReply) GetReply() isSnapshotReply_Reply

func (*SnapshotReply) ProtoMessage 

func (*SnapshotReply) ProtoMessage()

func (*SnapshotReply) ProtoReflect 

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

func (*SnapshotReply) Reset 

func (x *SnapshotReply) Reset()

func (*SnapshotReply) String 

func (x *SnapshotReply) String() string

type SnapshotReply_Close 

type SnapshotReply_Close struct {
	Close *CloseReply `protobuf:"bytes,5,opt,name=close,proto3,oneof"`
}

type SnapshotReply_Get 

type SnapshotReply_Get struct {
	Get *GetReply `protobuf:"bytes,3,opt,name=get,proto3,oneof"`
}

type SnapshotReply_Has 

type SnapshotReply_Has struct {
	Has *HasReply `protobuf:"bytes,4,opt,name=has,proto3,oneof"`
}

type SnapshotReply_Open 

type SnapshotReply_Open struct {
	Open *SnapshotOpenReply `protobuf:"bytes,2,opt,name=open,proto3,oneof"`
}

type SnapshotRequest 

type SnapshotRequest struct {
	Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Req:
	//
	//	*SnapshotRequest_Open
	//	*SnapshotRequest_Get
	//	*SnapshotRequest_Has
	//	*SnapshotRequest_Close
	Req isSnapshotRequest_Req `protobuf_oneof:"req"`
	// contains filtered or unexported fields
}

func (*SnapshotRequest) Descriptor deprecated 

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

Deprecated: Use SnapshotRequest.ProtoReflect.Descriptor instead.

func (*SnapshotRequest) GetClose 

func (x *SnapshotRequest) GetClose() *CloseRequest

func (*SnapshotRequest) GetGet 

func (x *SnapshotRequest) GetGet() *GetRequest

func (*SnapshotRequest) GetHas 

func (x *SnapshotRequest) GetHas() *HasRequest

func (*SnapshotRequest) GetId 

func (x *SnapshotRequest) GetId() int32

func (*SnapshotRequest) GetOpen 

func (x *SnapshotRequest) GetOpen() *SnapshotOpenRequest

func (*SnapshotRequest) GetReq 

func (m *SnapshotRequest) GetReq() isSnapshotRequest_Req

func (*SnapshotRequest) ProtoMessage 

func (*SnapshotRequest) ProtoMessage()

func (*SnapshotRequest) ProtoReflect 

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

func (*SnapshotRequest) Reset 

func (x *SnapshotRequest) Reset()

func (*SnapshotRequest) String 

func (x *SnapshotRequest) String() string

type SnapshotRequest_Close 

type SnapshotRequest_Close struct {
	Close *CloseRequest `protobuf:"bytes,5,opt,name=close,proto3,oneof"`
}

type SnapshotRequest_Get 

type SnapshotRequest_Get struct {
	Get *GetRequest `protobuf:"bytes,3,opt,name=get,proto3,oneof"`
}

type SnapshotRequest_Has 

type SnapshotRequest_Has struct {
	Has *HasRequest `protobuf:"bytes,4,opt,name=has,proto3,oneof"`
}

type SnapshotRequest_Open 

type SnapshotRequest_Open struct {
	Open *SnapshotOpenRequest `protobuf:"bytes,2,opt,name=open,proto3,oneof"`
}

type StatReply 

type StatReply struct {
	Stat string `protobuf:"bytes,2,opt,name=stat,proto3" json:"stat,omitempty"`
	// contains filtered or unexported fields
}

func (*StatReply) Descriptor deprecated 

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

Deprecated: Use StatReply.ProtoReflect.Descriptor instead.

func (*StatReply) GetStat 

func (x *StatReply) GetStat() string

func (*StatReply) ProtoMessage 

func (*StatReply) ProtoMessage()

func (*StatReply) ProtoReflect 

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

func (*StatReply) Reset 

func (x *StatReply) Reset()

func (*StatReply) String 

func (x *StatReply) String() string

type StatRequest 

type StatRequest struct {
	Id       int32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Property string `protobuf:"bytes,2,opt,name=property,proto3" json:"property,omitempty"`
	// contains filtered or unexported fields
}

func (*StatRequest) Descriptor deprecated 

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

Deprecated: Use StatRequest.ProtoReflect.Descriptor instead.

func (*StatRequest) GetId 

func (x *StatRequest) GetId() int32

func (*StatRequest) GetProperty 

func (x *StatRequest) GetProperty() string

func (*StatRequest) ProtoMessage 

func (*StatRequest) ProtoMessage()

func (*StatRequest) ProtoReflect 

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

func (*StatRequest) Reset 

func (x *StatRequest) Reset()

func (*StatRequest) String 

func (x *StatRequest) String() string

type StatsReply 

type StatsReply struct {
	Data   map[string]string `` /* 149-byte string literal not displayed */
	TimeAt int64             `protobuf:"varint,2,opt,name=time_at,json=timeAt,proto3" json:"time_at,omitempty"`
	// contains filtered or unexported fields
}

func (*StatsReply) Descriptor deprecated 

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

Deprecated: Use StatsReply.ProtoReflect.Descriptor instead.

func (*StatsReply) GetData 

func (x *StatsReply) GetData() map[string]string

func (*StatsReply) GetTimeAt 

func (x *StatsReply) GetTimeAt() int64

func (*StatsReply) ProtoMessage 

func (*StatsReply) ProtoMessage()

func (*StatsReply) ProtoReflect 

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

func (*StatsReply) Reset 

func (x *StatsReply) Reset()

func (*StatsReply) String 

func (x *StatsReply) String() string

type StatsRequest 

type StatsRequest struct {
	Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*StatsRequest) Descriptor deprecated 

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

Deprecated: Use StatsRequest.ProtoReflect.Descriptor instead.

func (*StatsRequest) GetId 

func (x *StatsRequest) GetId() int32

func (*StatsRequest) ProtoMessage 

func (*StatsRequest) ProtoMessage()

func (*StatsRequest) ProtoReflect 

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

func (*StatsRequest) Reset 

func (x *StatsRequest) Reset()

func (*StatsRequest) String 

func (x *StatsRequest) String() string

type SubscribeServiceClient 

type SubscribeServiceClient interface {
	WatchWriterEvent(ctx context.Context, in *WriterEventSubcribeRequest, opts ...grpc.CallOption) (SubscribeService_WatchWriterEventClient, error)
	ListReader(ctx context.Context, in *ListReaderRequest, opts ...grpc.CallOption) (*ListReaderResponse, error)
}

SubscribeServiceClient is the client API for SubscribeService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewSubscribeServiceClient 

func NewSubscribeServiceClient(cc grpc.ClientConnInterface) SubscribeServiceClient

type SubscribeServiceServer 

type SubscribeServiceServer interface {
	WatchWriterEvent(*WriterEventSubcribeRequest, SubscribeService_WatchWriterEventServer) error
	ListReader(context.Context, *ListReaderRequest) (*ListReaderResponse, error)
	// contains filtered or unexported methods
}

SubscribeServiceServer is the server API for SubscribeService service. All implementations must embed UnimplementedSubscribeServiceServer for forward compatibility

type SubscribeService_WatchWriterEventClient 

type SubscribeService_WatchWriterEventClient interface {
	Recv() (*WriterEventResponse, error)
	grpc.ClientStream
}

type SubscribeService_WatchWriterEventServer 

type SubscribeService_WatchWriterEventServer interface {
	Send(*WriterEventResponse) error
	grpc.ServerStream
}

type SyncRequest 

type SyncRequest struct {
	// contains filtered or unexported fields
}

func (*SyncRequest) Descriptor deprecated 

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

Deprecated: Use SyncRequest.ProtoReflect.Descriptor instead.

func (*SyncRequest) ProtoMessage 

func (*SyncRequest) ProtoMessage()

func (*SyncRequest) ProtoReflect 

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

func (*SyncRequest) Reset 

func (x *SyncRequest) Reset()

func (*SyncRequest) String 

func (x *SyncRequest) String() string

type SyncyReply 

type SyncyReply struct {
	Data *Block `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncyReply) Descriptor deprecated 

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

Deprecated: Use SyncyReply.ProtoReflect.Descriptor instead.

func (*SyncyReply) GetData 

func (x *SyncyReply) GetData() *Block

func (*SyncyReply) ProtoMessage 

func (*SyncyReply) ProtoMessage()

func (*SyncyReply) ProtoReflect 

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

func (*SyncyReply) Reset 

func (x *SyncyReply) Reset()

func (*SyncyReply) String 

func (x *SyncyReply) String() string

type UnimplementedHeartbeatServiceServer 

type UnimplementedHeartbeatServiceServer struct {
}

UnimplementedHeartbeatServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedHeartbeatServiceServer) Report 

func (UnimplementedHeartbeatServiceServer) Report(HeartbeatService_ReportServer) error

func (UnimplementedHeartbeatServiceServer) SetRole 

func (UnimplementedHeartbeatServiceServer) SetRole(context.Context, *SetRoleRequest) (*SetRoleResponse, error)

type UnimplementedRemoteServer 

type UnimplementedRemoteServer struct {
}

UnimplementedRemoteServer must be embedded to have forward compatible implementations.

func (UnimplementedRemoteServer) Batch 

func (UnimplementedRemoteServer) Batch(context.Context, *BatchRequest) (*BatchReply, error)

func (UnimplementedRemoteServer) Close 

func (UnimplementedRemoteServer) Close(context.Context, *CloseRequest) (*CloseReply, error)

func (UnimplementedRemoteServer) Compact 

func (UnimplementedRemoteServer) Compact(context.Context, *CompactRequest) (*CompactReply, error)

func (UnimplementedRemoteServer) Del 

func (UnimplementedRemoteServer) Del(context.Context, *DelRequest) (*DelReply, error)

func (UnimplementedRemoteServer) Get 

func (UnimplementedRemoteServer) Get(context.Context, *GetRequest) (*GetReply, error)

func (UnimplementedRemoteServer) Has 

func (UnimplementedRemoteServer) Has(context.Context, *HasRequest) (*HasReply, error)

func (UnimplementedRemoteServer) Iter 

func (UnimplementedRemoteServer) Iter(*IterRequest, Remote_IterServer) error

func (UnimplementedRemoteServer) Open 

func (UnimplementedRemoteServer) Open(context.Context, *OpenRequest) (*OpenReply, error)

func (UnimplementedRemoteServer) Put 

func (UnimplementedRemoteServer) Put(context.Context, *PutRequest) (*PutReply, error)

func (UnimplementedRemoteServer) Snapshot 

func (UnimplementedRemoteServer) Snapshot(Remote_SnapshotServer) error

func (UnimplementedRemoteServer) Stat 

func (UnimplementedRemoteServer) Stat(context.Context, *StatRequest) (*StatReply, error)

func (UnimplementedRemoteServer) Stats 

func (UnimplementedRemoteServer) Stats(context.Context, *StatsRequest) (*StatsReply, error)

func (UnimplementedRemoteServer) Sync 

func (UnimplementedRemoteServer) Sync(*SyncRequest, Remote_SyncServer) error

type UnimplementedS3ProxyServer 

type UnimplementedS3ProxyServer struct {
}

UnimplementedS3ProxyServer must be embedded to have forward compatible implementations.

func (UnimplementedS3ProxyServer) GetBlock 

func (UnimplementedS3ProxyServer) GetBlock(*GetBlockRequest, S3Proxy_GetBlockServer) error

func (UnimplementedS3ProxyServer) GetFile 

func (UnimplementedS3ProxyServer) GetFile(context.Context, *GetFileRequest) (*GetFileReply, error)

func (UnimplementedS3ProxyServer) ListHeaderStartAt 

func (UnimplementedS3ProxyServer) ListHeaderStartAt(context.Context, *ListHeaderStartAtRequest) (*ListHeaderStartAtReply, error)

func (UnimplementedS3ProxyServer) PutBlock 

func (UnimplementedS3ProxyServer) PutBlock(S3Proxy_PutBlockServer) error

func (UnimplementedS3ProxyServer) PutFile 

func (UnimplementedS3ProxyServer) PutFile(context.Context, *PutFileRequest) (*PutFileReply, error)

func (UnimplementedS3ProxyServer) RemoveFiles 

func (UnimplementedS3ProxyServer) RemoveFiles(context.Context, *RemoveFilesRequest) (*RemoveFilesReply, error)

type UnimplementedSubscribeServiceServer 

type UnimplementedSubscribeServiceServer struct {
}

UnimplementedSubscribeServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSubscribeServiceServer) ListReader 

func (UnimplementedSubscribeServiceServer) ListReader(context.Context, *ListReaderRequest) (*ListReaderResponse, error)

func (UnimplementedSubscribeServiceServer) WatchWriterEvent 

func (UnimplementedSubscribeServiceServer) WatchWriterEvent(*WriterEventSubcribeRequest, SubscribeService_WatchWriterEventServer) error

type UnsafeHeartbeatServiceServer 

type UnsafeHeartbeatServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeHeartbeatServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HeartbeatServiceServer will result in compilation errors.

type UnsafeRemoteServer 

type UnsafeRemoteServer interface {
	// contains filtered or unexported methods
}

UnsafeRemoteServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RemoteServer will result in compilation errors.

type UnsafeS3ProxyServer 

type UnsafeS3ProxyServer interface {
	// contains filtered or unexported methods
}

UnsafeS3ProxyServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to S3ProxyServer will result in compilation errors.

type UnsafeSubscribeServiceServer 

type UnsafeSubscribeServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeSubscribeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SubscribeServiceServer will result in compilation errors.

type WriterEvent 

type WriterEvent int32
const (
	WriterEvent_UNKNOWN_WRITE_EVENT WriterEvent = 0
	WriterEvent_ROLE_CHANGED        WriterEvent = 1
	WriterEvent_OUT_OF_SYNC         WriterEvent = 2
)

func (WriterEvent) Descriptor 

func (WriterEvent) Descriptor() protoreflect.EnumDescriptor

func (WriterEvent) Enum 

func (x WriterEvent) Enum() *WriterEvent

func (WriterEvent) EnumDescriptor deprecated 

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

Deprecated: Use WriterEvent.Descriptor instead.

func (WriterEvent) Number 

func (x WriterEvent) Number() protoreflect.EnumNumber

func (WriterEvent) String 

func (x WriterEvent) String() string

func (WriterEvent) Type 

func (WriterEvent) Type() protoreflect.EnumType

type WriterEventResponse 

type WriterEventResponse struct {
	Event  WriterEvent `protobuf:"varint,1,opt,name=event,proto3,enum=pb.WriterEvent" json:"event,omitempty"`
	Leader *NodeId     `protobuf:"bytes,2,opt,name=leader,proto3" json:"leader,omitempty"`
	// contains filtered or unexported fields
}

func (*WriterEventResponse) Descriptor deprecated 

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

Deprecated: Use WriterEventResponse.ProtoReflect.Descriptor instead.

func (*WriterEventResponse) GetEvent 

func (x *WriterEventResponse) GetEvent() WriterEvent

func (*WriterEventResponse) GetLeader 

func (x *WriterEventResponse) GetLeader() *NodeId

func (*WriterEventResponse) ProtoMessage 

func (*WriterEventResponse) ProtoMessage()

func (*WriterEventResponse) ProtoReflect 

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

func (*WriterEventResponse) Reset 

func (x *WriterEventResponse) Reset()

func (*WriterEventResponse) String 

func (x *WriterEventResponse) String() string

type WriterEventSubcribeRequest 

type WriterEventSubcribeRequest struct {
	Timeout int64 `protobuf:"varint,1,opt,name=timeout,proto3" json:"timeout,omitempty"` // optional, watch timeout, watch permanently if timeout is zero.
	// contains filtered or unexported fields
}

func (*WriterEventSubcribeRequest) Descriptor deprecated 

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

Deprecated: Use WriterEventSubcribeRequest.ProtoReflect.Descriptor instead.

func (*WriterEventSubcribeRequest) GetTimeout 

func (x *WriterEventSubcribeRequest) GetTimeout() int64

func (*WriterEventSubcribeRequest) ProtoMessage 

func (*WriterEventSubcribeRequest) ProtoMessage()

func (*WriterEventSubcribeRequest) ProtoReflect 

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

func (*WriterEventSubcribeRequest) Reset 

func (x *WriterEventSubcribeRequest) Reset()

func (*WriterEventSubcribeRequest) String 

func (x *WriterEventSubcribeRequest) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.