Documentation ¶
Index ¶
- func Multi(addrs []common.NodeAddress, procedure string, args interface{}) []error
- func Single(addr common.NodeAddress, procedure string, args interface{}, ...) error
- type CreateBlockArgs
- type CreateBlockResponse
- type CreateFileArgs
- type CreateFileResponse
- type DeleteFileArgs
- type DeleteFileResponse
- type ForwardDataArgs
- type ForwardDataResponse
- type GetBlockInfoArgs
- type GetBlockInfoResponse
- type GetMetadataArgs
- type GetMetadataResponse
- type HeartBeatArgs
- type HeartBeatResponse
- type ListKeysArgs
- type ListKeysResponse
- type NodeStatusArgs
- type NodeStatusResponse
- type ReadBlockArgs
- type ReadBlockResponse
- type WriteBlockArgs
- type WriteBlockResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type CreateBlockArgs ¶
type CreateBlockArgs struct { //handle common.BlockHandle Handles []common.BlockHandle }
type CreateBlockResponse ¶
type CreateFileArgs ¶
type CreateFileArgs struct {
Length uint64
}
type DeleteFileArgs ¶
type DeleteFileResponse ¶
type ForwardDataArgs ¶
type ForwardDataArgs struct { Handle common.BlockHandle //Data []byte Target []common.NodeAddress }
type ForwardDataResponse ¶
type GetBlockInfoArgs ¶
type GetBlockInfoArgs struct {
Handle common.BlockHandle
}
type GetBlockInfoResponse ¶
type GetBlockInfoResponse struct { // locations Locations []common.NodeAddress Primary common.NodeAddress }
type GetMetadataArgs ¶
type GetMetadataResponse ¶
type GetMetadataResponse struct { // blocks BlockHandles []common.BlockHandle // length Length int64 }
type HeartBeatArgs ¶
type HeartBeatArgs struct { Address common.NodeAddress DNType common.NodeType }
type HeartBeatResponse ¶
type HeartBeatResponse struct {
Garbage []common.BlockHandle
}
type ListKeysArgs ¶
type ListKeysArgs struct {
Limit int // how many keys
}
type ListKeysResponse ¶
type NodeStatusResponse ¶
type NodeStatusResponse struct {
Nodes map[common.NodeAddress]*common.Node
}
type ReadBlockArgs ¶
type ReadBlockArgs struct { Handle common.BlockHandle Offset common.Offset Length int }
type ReadBlockResponse ¶
type WriteBlockArgs ¶
type WriteBlockArgs struct { Handle common.BlockHandle Data []byte Offset common.Offset Secondaries []common.NodeAddress }
type WriteBlockResponse ¶
Click to show internal directories.
Click to hide internal directories.