rpc

Documentation

Index

• Variables
• func Init()
• func MasterAssignTask(ctx context.Context, taskReq *mapreduce.MapReduceTask) (resp *mapreduce.MapReduceTask, err error)
• func MasterTaskCompleted(ctx context.Context, task *mapreduce.MapReduceTask) (resp *mapreduce.MasterTaskCompletedResp, err error)

Variables

var (
	Register *discovery.Resolver

	CancelFunc context.CancelFunc

	MapReduceClient mapreduce.MapReduceServiceClient
)

Functions

func Init

func Init()

func MasterAssignTask

func MasterAssignTask(ctx context.Context, taskReq *mapreduce.MapReduceTask) (resp *mapreduce.MapReduceTask, err error)

MasterAssignTask 通过 master 发送任务

func MasterTaskCompleted

func MasterTaskCompleted(ctx context.Context, task *mapreduce.MapReduceTask) (resp *mapreduce.MasterTaskCompletedResp, err error)

MasterTaskCompleted 通知 master 任务完成的RPC调用