Documentation ¶
Index ¶
- type MasterNode
- func (m *MasterNode) CreateFile(args ipc.CreateFileArgs, response *ipc.CreateFileResponse) error
- func (m *MasterNode) DeleteFile(args ipc.DeleteFileArgs, response *ipc.DeleteFileResponse) error
- func (m *MasterNode) ExpireCheck() error
- func (m *MasterNode) GetBlockInfo(args ipc.GetBlockInfoArgs, response *ipc.GetBlockInfoResponse) error
- func (m *MasterNode) GetFileMetadata(args ipc.GetMetadataArgs, response *ipc.GetMetadataResponse) error
- func (m *MasterNode) HeartbeatResponse(args ipc.HeartBeatArgs, response *ipc.HeartBeatResponse) error
- func (m *MasterNode) ListKeys(args ipc.ListKeysArgs, response *ipc.ListKeysResponse) error
- func (m *MasterNode) NodeStatus(args ipc.NodeStatusArgs, response *ipc.NodeStatusResponse) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MasterNode ¶
type MasterNode struct { Address common.NodeAddress RootDir string // contains filtered or unexported fields }
func Run ¶
func Run(address common.NodeAddress, rootDir string) *MasterNode
func (*MasterNode) CreateFile ¶
func (m *MasterNode) CreateFile(args ipc.CreateFileArgs, response *ipc.CreateFileResponse) error
func (*MasterNode) DeleteFile ¶
func (m *MasterNode) DeleteFile(args ipc.DeleteFileArgs, response *ipc.DeleteFileResponse) error
func (*MasterNode) ExpireCheck ¶
func (m *MasterNode) ExpireCheck() error
func (*MasterNode) GetBlockInfo ¶
func (m *MasterNode) GetBlockInfo(args ipc.GetBlockInfoArgs, response *ipc.GetBlockInfoResponse) error
func (*MasterNode) GetFileMetadata ¶
func (m *MasterNode) GetFileMetadata(args ipc.GetMetadataArgs, response *ipc.GetMetadataResponse) error
func (*MasterNode) HeartbeatResponse ¶
func (m *MasterNode) HeartbeatResponse(args ipc.HeartBeatArgs, response *ipc.HeartBeatResponse) error
func (*MasterNode) ListKeys ¶
func (m *MasterNode) ListKeys(args ipc.ListKeysArgs, response *ipc.ListKeysResponse) error
for debug
func (*MasterNode) NodeStatus ¶
func (m *MasterNode) NodeStatus(args ipc.NodeStatusArgs, response *ipc.NodeStatusResponse) error
Click to show internal directories.
Click to hide internal directories.