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.