aftmapreduce

package

v0.0.0-...-6968735 Latest Latest Go to latest Published: Oct 2, 2019 License: MIT Imports: 2 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/andreag93/sdcc-project-workernode

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func MakeRPCCall(serviceMethod string, internetAddress string, input interface{}, ...) error
func StartAcceptingRPCRequest(serviceTypeRequest interface{}, address string)

Constants ¶

View Source

const (
	WordCountMapTaskRPCBasePort    = 2000
	WordCountReduceTaskRPCBasePort = 3000
	WordCountReceiveRPCBasePort    = 4000
	WordCountRequestRPCBasePort    = 5000
	WordCountSendRPCBasePort       = 6000
	WordCountRetrieverRPCBasePort  = 7000
)

Variables ¶

This section is empty.

Functions ¶

func MakeRPCCall ¶

func MakeRPCCall(serviceMethod string, internetAddress string, input interface{}, output interface{}, replyChannel chan interface{}) error

func StartAcceptingRPCRequest ¶

func StartAcceptingRPCRequest(serviceTypeRequest interface{}, address string)

Types ¶

This section is empty.

Source Files ¶

View all Source files

rpc.go

Directories ¶

Path	Synopsis
data
main
membership
process
client
client/main
logger
primary
property
worker
replyregister
storage
amazons3
system
zookeeper
utility
wordcount
DataStructures/WordToken
DataStructures/WordTokenHashTable
DataStructures/WordTokenList

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL