Versions in this module Expand all Collapse all v1 v1.0.0 Dec 11, 2021 Changes in this version + var WorkerState_State_name = map[int32]string + var WorkerState_State_value = map[string]int32 + type JSONKVs struct + Kvs string + func (*JSONKVs) Descriptor() ([]byte, []int) + func (*JSONKVs) ProtoMessage() + func (x *JSONKVs) GetKvs() string + func (x *JSONKVs) ProtoReflect() protoreflect.Message + func (x *JSONKVs) Reset() + func (x *JSONKVs) String() string type UnimplementedWorkerServer + func (UnimplementedWorkerServer) Health(context.Context, *Empty) (*WorkerState, error) type WorkerClient + Health func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*WorkerState, error) type WorkerServer + Health func(context.Context, *Empty) (*WorkerState, error) + type WorkerState struct + State WorkerState_State + func (*WorkerState) Descriptor() ([]byte, []int) + func (*WorkerState) ProtoMessage() + func (x *WorkerState) GetState() WorkerState_State + func (x *WorkerState) ProtoReflect() protoreflect.Message + func (x *WorkerState) Reset() + func (x *WorkerState) String() string + type WorkerState_State int32 + const WorkerState_BUSY + const WorkerState_IDLE + func (WorkerState_State) Descriptor() protoreflect.EnumDescriptor + func (WorkerState_State) EnumDescriptor() ([]byte, []int) + func (WorkerState_State) Type() protoreflect.EnumType + func (x WorkerState_State) Enum() *WorkerState_State + func (x WorkerState_State) Number() protoreflect.EnumNumber + func (x WorkerState_State) String() string v0 v0.1.0 Nov 22, 2021 Changes in this version + var File_rpc_master_proto protoreflect.FileDescriptor + var File_rpc_worker_proto protoreflect.FileDescriptor + var Master_ServiceDesc = grpc.ServiceDesc + var Worker_ServiceDesc = grpc.ServiceDesc + func RegisterMasterServer(s grpc.ServiceRegistrar, srv MasterServer) + func RegisterWorkerServer(s grpc.ServiceRegistrar, srv WorkerServer) + type Empty struct + func (*Empty) Descriptor() ([]byte, []int) + func (*Empty) ProtoMessage() + func (x *Empty) ProtoReflect() protoreflect.Message + func (x *Empty) Reset() + func (x *Empty) String() string + type IMDInfo struct + Filenames []string + Uuid string + func (*IMDInfo) Descriptor() ([]byte, []int) + func (*IMDInfo) ProtoMessage() + func (x *IMDInfo) GetFilenames() []string + func (x *IMDInfo) GetUuid() string + func (x *IMDInfo) ProtoReflect() protoreflect.Message + func (x *IMDInfo) Reset() + func (x *IMDInfo) String() string + type IMDLoc struct + Filename string + func (*IMDLoc) Descriptor() ([]byte, []int) + func (*IMDLoc) ProtoMessage() + func (x *IMDLoc) GetFilename() string + func (x *IMDLoc) ProtoReflect() protoreflect.Message + func (x *IMDLoc) Reset() + func (x *IMDLoc) String() string + type KV struct + Key string + Value string + func (*KV) Descriptor() ([]byte, []int) + func (*KV) ProtoMessage() + func (x *KV) GetKey() string + func (x *KV) GetValue() string + func (x *KV) ProtoReflect() protoreflect.Message + func (x *KV) Reset() + func (x *KV) String() string + type KVs struct + Kvs []*KV + func (*KVs) Descriptor() ([]byte, []int) + func (*KVs) ProtoMessage() + func (x *KVs) GetKvs() []*KV + func (x *KVs) ProtoReflect() protoreflect.Message + func (x *KVs) Reset() + func (x *KVs) String() string + type MapFileInfo struct + FileName string + From int64 + To int64 + func (*MapFileInfo) Descriptor() ([]byte, []int) + func (*MapFileInfo) ProtoMessage() + func (x *MapFileInfo) GetFileName() string + func (x *MapFileInfo) GetFrom() int64 + func (x *MapFileInfo) GetTo() int64 + func (x *MapFileInfo) ProtoReflect() protoreflect.Message + func (x *MapFileInfo) Reset() + func (x *MapFileInfo) String() string + type MapInfo struct + Files []*MapFileInfo + func (*MapInfo) Descriptor() ([]byte, []int) + func (*MapInfo) ProtoMessage() + func (x *MapInfo) GetFiles() []*MapFileInfo + func (x *MapInfo) ProtoReflect() protoreflect.Message + func (x *MapInfo) Reset() + func (x *MapInfo) String() string + type MasterClient interface + UpdateIMDInfo func(ctx context.Context, in *IMDInfo, opts ...grpc.CallOption) (*UpdateResult, error) + WorkerRegister func(ctx context.Context, in *WorkerInfo, opts ...grpc.CallOption) (*RegisterResult, error) + func NewMasterClient(cc grpc.ClientConnInterface) MasterClient + type MasterServer interface + UpdateIMDInfo func(context.Context, *IMDInfo) (*UpdateResult, error) + WorkerRegister func(context.Context, *WorkerInfo) (*RegisterResult, error) + type ReduceFileInfo struct + Filename string + Ip string + func (*ReduceFileInfo) Descriptor() ([]byte, []int) + func (*ReduceFileInfo) ProtoMessage() + func (x *ReduceFileInfo) GetFilename() string + func (x *ReduceFileInfo) GetIp() string + func (x *ReduceFileInfo) ProtoReflect() protoreflect.Message + func (x *ReduceFileInfo) Reset() + func (x *ReduceFileInfo) String() string + type ReduceInfo struct + Files []*ReduceFileInfo + func (*ReduceInfo) Descriptor() ([]byte, []int) + func (*ReduceInfo) ProtoMessage() + func (x *ReduceInfo) GetFiles() []*ReduceFileInfo + func (x *ReduceInfo) ProtoReflect() protoreflect.Message + func (x *ReduceInfo) Reset() + func (x *ReduceInfo) String() string + type RegisterResult struct + Id int64 + Result bool + func (*RegisterResult) Descriptor() ([]byte, []int) + func (*RegisterResult) ProtoMessage() + func (x *RegisterResult) GetId() int64 + func (x *RegisterResult) GetResult() bool + func (x *RegisterResult) ProtoReflect() protoreflect.Message + func (x *RegisterResult) Reset() + func (x *RegisterResult) String() string + type Result struct + Result bool + Uuid string + func (*Result) Descriptor() ([]byte, []int) + func (*Result) ProtoMessage() + func (x *Result) GetResult() bool + func (x *Result) GetUuid() string + func (x *Result) ProtoReflect() protoreflect.Message + func (x *Result) Reset() + func (x *Result) String() string + type UnimplementedMasterServer struct + func (UnimplementedMasterServer) UpdateIMDInfo(context.Context, *IMDInfo) (*UpdateResult, error) + func (UnimplementedMasterServer) WorkerRegister(context.Context, *WorkerInfo) (*RegisterResult, error) + type UnimplementedWorkerServer struct + func (UnimplementedWorkerServer) End(context.Context, *Empty) (*Empty, error) + func (UnimplementedWorkerServer) GetIMDData(context.Context, *IMDLoc) (*KVs, error) + func (UnimplementedWorkerServer) Map(context.Context, *MapInfo) (*Result, error) + func (UnimplementedWorkerServer) Reduce(context.Context, *ReduceInfo) (*Result, error) + type UnsafeMasterServer interface + type UnsafeWorkerServer interface + type UpdateResult struct + Result bool + func (*UpdateResult) Descriptor() ([]byte, []int) + func (*UpdateResult) ProtoMessage() + func (x *UpdateResult) GetResult() bool + func (x *UpdateResult) ProtoReflect() protoreflect.Message + func (x *UpdateResult) Reset() + func (x *UpdateResult) String() string + type WorkerClient interface + End func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) + GetIMDData func(ctx context.Context, in *IMDLoc, opts ...grpc.CallOption) (*KVs, error) + Map func(ctx context.Context, in *MapInfo, opts ...grpc.CallOption) (*Result, error) + Reduce func(ctx context.Context, in *ReduceInfo, opts ...grpc.CallOption) (*Result, error) + func NewWorkerClient(cc grpc.ClientConnInterface) WorkerClient + type WorkerInfo struct + Ip string + Uuid string + func (*WorkerInfo) Descriptor() ([]byte, []int) + func (*WorkerInfo) ProtoMessage() + func (x *WorkerInfo) GetIp() string + func (x *WorkerInfo) GetUuid() string + func (x *WorkerInfo) ProtoReflect() protoreflect.Message + func (x *WorkerInfo) Reset() + func (x *WorkerInfo) String() string + type WorkerServer interface + End func(context.Context, *Empty) (*Empty, error) + GetIMDData func(context.Context, *IMDLoc) (*KVs, error) + Map func(context.Context, *MapInfo) (*Result, error) + Reduce func(context.Context, *ReduceInfo) (*Result, error)
Go to main page