Versions in this module Expand all Collapse all v0 v0.4.6 Jun 16, 2022 Changes in this version + var File_protocol_proto protoreflect.FileDescriptor + var Master_ServiceDesc = grpc.ServiceDesc + var NodeType_name = map[int32]string + var NodeType_value = map[string]int32 + func RegisterMasterServer(s grpc.ServiceRegistrar, srv MasterServer) + func UnmarshalClickModel(receiver Master_GetClickModelClient) (click.FactorizationMachine, error) + func UnmarshalRankingModel(receiver Master_GetRankingModelClient) (ranking.MatrixFactorization, error) + type Fragment struct + Data []byte + func (*Fragment) Descriptor() ([]byte, []int) + func (*Fragment) ProtoMessage() + func (x *Fragment) GetData() []byte + func (x *Fragment) ProtoReflect() protoreflect.Message + func (x *Fragment) Reset() + func (x *Fragment) String() string + type MasterClient interface + GetClickModel func(ctx context.Context, in *VersionInfo, opts ...grpc.CallOption) (Master_GetClickModelClient, error) + GetMeta func(ctx context.Context, in *NodeInfo, opts ...grpc.CallOption) (*Meta, error) + GetRankingModel func(ctx context.Context, in *VersionInfo, opts ...grpc.CallOption) (Master_GetRankingModelClient, error) + PushTaskInfo func(ctx context.Context, in *PushTaskInfoRequest, opts ...grpc.CallOption) (*PushTaskInfoResponse, error) + func NewMasterClient(cc grpc.ClientConnInterface) MasterClient + type MasterServer interface + GetClickModel func(*VersionInfo, Master_GetClickModelServer) error + GetMeta func(context.Context, *NodeInfo) (*Meta, error) + GetRankingModel func(*VersionInfo, Master_GetRankingModelServer) error + PushTaskInfo func(context.Context, *PushTaskInfoRequest) (*PushTaskInfoResponse, error) + type Master_GetClickModelClient interface + Recv func() (*Fragment, error) + type Master_GetClickModelServer interface + Send func(*Fragment) error + type Master_GetRankingModelClient interface + Recv func() (*Fragment, error) + type Master_GetRankingModelServer interface + Send func(*Fragment) error + type Meta struct + ClickModelVersion int64 + Config string + Me string + RankingModelVersion int64 + Servers []string + Workers []string + func (*Meta) Descriptor() ([]byte, []int) + func (*Meta) ProtoMessage() + func (x *Meta) GetClickModelVersion() int64 + func (x *Meta) GetConfig() string + func (x *Meta) GetMe() string + func (x *Meta) GetRankingModelVersion() int64 + func (x *Meta) GetServers() []string + func (x *Meta) GetWorkers() []string + func (x *Meta) ProtoReflect() protoreflect.Message + func (x *Meta) Reset() + func (x *Meta) String() string + type NodeInfo struct + BinaryVersion string + HttpPort int64 + NodeName string + NodeType NodeType + func (*NodeInfo) Descriptor() ([]byte, []int) + func (*NodeInfo) ProtoMessage() + func (x *NodeInfo) GetBinaryVersion() string + func (x *NodeInfo) GetHttpPort() int64 + func (x *NodeInfo) GetNodeName() string + func (x *NodeInfo) GetNodeType() NodeType + func (x *NodeInfo) ProtoReflect() protoreflect.Message + func (x *NodeInfo) Reset() + func (x *NodeInfo) String() string + type NodeType int32 + const NodeType_ClientNode + const NodeType_ServerNode + const NodeType_WorkerNode + func (NodeType) Descriptor() protoreflect.EnumDescriptor + func (NodeType) EnumDescriptor() ([]byte, []int) + func (NodeType) Type() protoreflect.EnumType + func (x NodeType) Enum() *NodeType + func (x NodeType) Number() protoreflect.EnumNumber + func (x NodeType) String() string + type PushTaskInfoRequest struct + Done int64 + Error string + FinishTime int64 + Name string + StartTime int64 + Status string + Total int64 + func (*PushTaskInfoRequest) Descriptor() ([]byte, []int) + func (*PushTaskInfoRequest) ProtoMessage() + func (x *PushTaskInfoRequest) GetDone() int64 + func (x *PushTaskInfoRequest) GetError() string + func (x *PushTaskInfoRequest) GetFinishTime() int64 + func (x *PushTaskInfoRequest) GetName() string + func (x *PushTaskInfoRequest) GetStartTime() int64 + func (x *PushTaskInfoRequest) GetStatus() string + func (x *PushTaskInfoRequest) GetTotal() int64 + func (x *PushTaskInfoRequest) ProtoReflect() protoreflect.Message + func (x *PushTaskInfoRequest) Reset() + func (x *PushTaskInfoRequest) String() string + type PushTaskInfoResponse struct + func (*PushTaskInfoResponse) Descriptor() ([]byte, []int) + func (*PushTaskInfoResponse) ProtoMessage() + func (x *PushTaskInfoResponse) ProtoReflect() protoreflect.Message + func (x *PushTaskInfoResponse) Reset() + func (x *PushTaskInfoResponse) String() string + type UnimplementedMasterServer struct + func (UnimplementedMasterServer) GetClickModel(*VersionInfo, Master_GetClickModelServer) error + func (UnimplementedMasterServer) GetMeta(context.Context, *NodeInfo) (*Meta, error) + func (UnimplementedMasterServer) GetRankingModel(*VersionInfo, Master_GetRankingModelServer) error + func (UnimplementedMasterServer) PushTaskInfo(context.Context, *PushTaskInfoRequest) (*PushTaskInfoResponse, error) + type UnsafeMasterServer interface + type VersionInfo struct + Version int64 + func (*VersionInfo) Descriptor() ([]byte, []int) + func (*VersionInfo) ProtoMessage() + func (x *VersionInfo) GetVersion() int64 + func (x *VersionInfo) ProtoReflect() protoreflect.Message + func (x *VersionInfo) Reset() + func (x *VersionInfo) String() string