Documentation ¶
Index ¶
- Constants
- func AddFile(ctx context.Context, node *core.IpfsNode, filePath string) (cid.Cid, error)
- func GetFile(ctx context.Context, node *core.IpfsNode, fileCid string) (files.Node, error)
- func GetInTmpFile(ctx context.Context, node *core.IpfsNode, fileCid string) (*os.File, error)
- func GetPeerFromId(peerId string) (peerstore.AddrInfo, error)
- func GetPlugin(ctx context.Context, node *core.IpfsNode, fileCid string) (*plugin.Plugin, error)
- func Ihash(key string) int
- func WriteToTmp(ctx context.Context, rootNode files.Node) (*os.File, error)
- type Empty
- type KeyValue
- type MapInput
- type MapOutput
- type ReduceInput
- type ReduceOutput
Constants ¶
View Source
const ( ProtocolID = "/ipfs/mapreduce" MaxRetries = 3 MaxGoRoutines = 250 // Master NoOfProviders = 5 MasterMapOutputFuncName = "ProcessMapOutput" MasterReduceOutputFuncName = "ProcessReduceOutput" MasterServiceName = "Master" // Mapper MapFuncName = "Map" MapServiceName = "MapService" // Reducer ReduceFuncName = "Reduce" ReduceServiceName = "ReduceService" )
Variables ¶
This section is empty.
Functions ¶
func GetInTmpFile ¶
Types ¶
type ReduceInput ¶
type ReduceOutput ¶
Click to show internal directories.
Click to hide internal directories.