protocol

package
v0.4.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 1, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	NodeType_name = map[int32]string{
		0: "ServerNode",
		1: "WorkerNode",
		2: "ClientNode",
	}
	NodeType_value = map[string]int32{
		"ServerNode": 0,
		"WorkerNode": 1,
		"ClientNode": 2,
	}
)

Enum value maps for NodeType.

View Source 
var File_protocol_proto protoreflect.FileDescriptor
View Source 
var Master_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "protocol.Master",
	HandlerType: (*MasterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetMeta",
			Handler:    _Master_GetMeta_Handler,
		},
		{
			MethodName: "StartTask",
			Handler:    _Master_StartTask_Handler,
		},
		{
			MethodName: "UpdateTask",
			Handler:    _Master_UpdateTask_Handler,
		},
		{
			MethodName: "FinishTask",
			Handler:    _Master_FinishTask_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetRankingModel",
			Handler:       _Master_GetRankingModel_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetClickModel",
			Handler:       _Master_GetClickModel_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "protocol.proto",
}

Master_ServiceDesc is the grpc.ServiceDesc for Master service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterMasterServer 

func RegisterMasterServer(s grpc.ServiceRegistrar, srv MasterServer)

func UnmarshalClickModel added in v0.2.7 

func UnmarshalClickModel(receiver Master_GetClickModelClient) (click.FactorizationMachine, error)

UnmarshalClickModel unmarshal click model from gRPC.

func UnmarshalRankingModel added in v0.2.7 

func UnmarshalRankingModel(receiver Master_GetRankingModelClient) (ranking.MatrixFactorization, error)

UnmarshalRankingModel unmarshal ranking model from gRPC.

Types

type FinishTaskRequest added in v0.2.4 

type FinishTaskRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*FinishTaskRequest) Descriptor deprecated added in v0.2.4 

func (*FinishTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use FinishTaskRequest.ProtoReflect.Descriptor instead.

func (*FinishTaskRequest) GetName added in v0.2.4 

func (x *FinishTaskRequest) GetName() string

func (*FinishTaskRequest) ProtoMessage added in v0.2.4 

func (*FinishTaskRequest) ProtoMessage()

func (*FinishTaskRequest) ProtoReflect added in v0.2.4 

func (x *FinishTaskRequest) ProtoReflect() protoreflect.Message

func (*FinishTaskRequest) Reset added in v0.2.4 

func (x *FinishTaskRequest) Reset()

func (*FinishTaskRequest) String added in v0.2.4 

func (x *FinishTaskRequest) String() string

type FinishTaskResponse added in v0.2.4 

type FinishTaskResponse struct {
	// contains filtered or unexported fields
}

func (*FinishTaskResponse) Descriptor deprecated added in v0.2.4 

func (*FinishTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use FinishTaskResponse.ProtoReflect.Descriptor instead.

func (*FinishTaskResponse) ProtoMessage added in v0.2.4 

func (*FinishTaskResponse) ProtoMessage()

func (*FinishTaskResponse) ProtoReflect added in v0.2.4 

func (x *FinishTaskResponse) ProtoReflect() protoreflect.Message

func (*FinishTaskResponse) Reset added in v0.2.4 

func (x *FinishTaskResponse) Reset()

func (*FinishTaskResponse) String added in v0.2.4 

func (x *FinishTaskResponse) String() string

type Fragment added in v0.2.7 

type Fragment struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Fragment) Descriptor deprecated added in v0.2.7 

func (*Fragment) Descriptor() ([]byte, []int)

Deprecated: Use Fragment.ProtoReflect.Descriptor instead.

func (*Fragment) GetData added in v0.2.7 

func (x *Fragment) GetData() []byte

func (*Fragment) ProtoMessage added in v0.2.7 

func (*Fragment) ProtoMessage()

func (*Fragment) ProtoReflect added in v0.2.7 

func (x *Fragment) ProtoReflect() protoreflect.Message

func (*Fragment) Reset added in v0.2.7 

func (x *Fragment) Reset()

func (*Fragment) String added in v0.2.7 

func (x *Fragment) String() string

type MasterClient 

type MasterClient interface {
	// meta distribute
	GetMeta(ctx context.Context, in *NodeInfo, opts ...grpc.CallOption) (*Meta, error)
	// data distribute
	GetRankingModel(ctx context.Context, in *VersionInfo, opts ...grpc.CallOption) (Master_GetRankingModelClient, error)
	GetClickModel(ctx context.Context, in *VersionInfo, opts ...grpc.CallOption) (Master_GetClickModelClient, error)
	// task management
	StartTask(ctx context.Context, in *StartTaskRequest, opts ...grpc.CallOption) (*StartTaskResponse, error)
	UpdateTask(ctx context.Context, in *UpdateTaskRequest, opts ...grpc.CallOption) (*UpdateTaskResponse, error)
	FinishTask(ctx context.Context, in *FinishTaskRequest, opts ...grpc.CallOption) (*FinishTaskResponse, error)
}

MasterClient is the client API for Master service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewMasterClient 

func NewMasterClient(cc grpc.ClientConnInterface) MasterClient

type MasterServer 

type MasterServer interface {
	// meta distribute
	GetMeta(context.Context, *NodeInfo) (*Meta, error)
	// data distribute
	GetRankingModel(*VersionInfo, Master_GetRankingModelServer) error
	GetClickModel(*VersionInfo, Master_GetClickModelServer) error
	// task management
	StartTask(context.Context, *StartTaskRequest) (*StartTaskResponse, error)
	UpdateTask(context.Context, *UpdateTaskRequest) (*UpdateTaskResponse, error)
	FinishTask(context.Context, *FinishTaskRequest) (*FinishTaskResponse, error)
	// contains filtered or unexported methods
}

MasterServer is the server API for Master service. All implementations must embed UnimplementedMasterServer for forward compatibility

type Master_GetClickModelClient added in v0.2.7 

type Master_GetClickModelClient interface {
	Recv() (*Fragment, error)
	grpc.ClientStream
}

type Master_GetClickModelServer added in v0.2.7 

type Master_GetClickModelServer interface {
	Send(*Fragment) error
	grpc.ServerStream
}

type Master_GetRankingModelClient added in v0.2.7 

type Master_GetRankingModelClient interface {
	Recv() (*Fragment, error)
	grpc.ClientStream
}

type Master_GetRankingModelServer added in v0.2.7 

type Master_GetRankingModelServer interface {
	Send(*Fragment) error
	grpc.ServerStream
}

type Meta 

type Meta struct {
	Config              string   `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	RankingModelVersion int64    `protobuf:"varint,3,opt,name=ranking_model_version,json=rankingModelVersion,proto3" json:"ranking_model_version,omitempty"`
	ClickModelVersion   int64    `protobuf:"varint,4,opt,name=click_model_version,json=clickModelVersion,proto3" json:"click_model_version,omitempty"`
	Me                  string   `protobuf:"bytes,5,opt,name=me,proto3" json:"me,omitempty"`
	Servers             []string `protobuf:"bytes,6,rep,name=servers,proto3" json:"servers,omitempty"`
	Workers             []string `protobuf:"bytes,7,rep,name=workers,proto3" json:"workers,omitempty"`
	// contains filtered or unexported fields
}

func (*Meta) Descriptor deprecated 

func (*Meta) Descriptor() ([]byte, []int)

Deprecated: Use Meta.ProtoReflect.Descriptor instead.

func (*Meta) GetClickModelVersion added in v0.2.2 

func (x *Meta) GetClickModelVersion() int64

func (*Meta) GetConfig 

func (x *Meta) GetConfig() string

func (*Meta) GetMe 

func (x *Meta) GetMe() string

func (*Meta) GetRankingModelVersion 

func (x *Meta) GetRankingModelVersion() int64

func (*Meta) GetServers 

func (x *Meta) GetServers() []string

func (*Meta) GetWorkers 

func (x *Meta) GetWorkers() []string

func (*Meta) ProtoMessage 

func (*Meta) ProtoMessage()

func (*Meta) ProtoReflect 

func (x *Meta) ProtoReflect() protoreflect.Message

func (*Meta) Reset 

func (x *Meta) Reset()

func (*Meta) String 

func (x *Meta) String() string

type NodeInfo 

type NodeInfo struct {
	NodeType NodeType `protobuf:"varint,1,opt,name=node_type,json=nodeType,proto3,enum=protocol.NodeType" json:"node_type,omitempty"`
	NodeName string   `protobuf:"bytes,2,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	HttpPort int64    `protobuf:"varint,3,opt,name=http_port,json=httpPort,proto3" json:"http_port,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeInfo) Descriptor deprecated 

func (*NodeInfo) Descriptor() ([]byte, []int)

Deprecated: Use NodeInfo.ProtoReflect.Descriptor instead.

func (*NodeInfo) GetHttpPort 

func (x *NodeInfo) GetHttpPort() int64

func (*NodeInfo) GetNodeName 

func (x *NodeInfo) GetNodeName() string

func (*NodeInfo) GetNodeType 

func (x *NodeInfo) GetNodeType() NodeType

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) ProtoReflect 

func (x *NodeInfo) ProtoReflect() protoreflect.Message

func (*NodeInfo) Reset 

func (x *NodeInfo) Reset()

func (*NodeInfo) String 

func (x *NodeInfo) String() string

type NodeType 

type NodeType int32
const (
	NodeType_ServerNode NodeType = 0
	NodeType_WorkerNode NodeType = 1
	NodeType_ClientNode NodeType = 2
)

func (NodeType) Descriptor 

func (NodeType) Descriptor() protoreflect.EnumDescriptor

func (NodeType) Enum 

func (x NodeType) Enum() *NodeType

func (NodeType) EnumDescriptor deprecated 

func (NodeType) EnumDescriptor() ([]byte, []int)

Deprecated: Use NodeType.Descriptor instead.

func (NodeType) Number 

func (x NodeType) Number() protoreflect.EnumNumber

func (NodeType) String 

func (x NodeType) String() string

func (NodeType) Type 

func (NodeType) Type() protoreflect.EnumType

type StartTaskRequest added in v0.2.4 

type StartTaskRequest struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Total int64  `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	// contains filtered or unexported fields
}

func (*StartTaskRequest) Descriptor deprecated added in v0.2.4 

func (*StartTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use StartTaskRequest.ProtoReflect.Descriptor instead.

func (*StartTaskRequest) GetName added in v0.2.4 

func (x *StartTaskRequest) GetName() string

func (*StartTaskRequest) GetTotal added in v0.2.4 

func (x *StartTaskRequest) GetTotal() int64

func (*StartTaskRequest) ProtoMessage added in v0.2.4 

func (*StartTaskRequest) ProtoMessage()

func (*StartTaskRequest) ProtoReflect added in v0.2.4 

func (x *StartTaskRequest) ProtoReflect() protoreflect.Message

func (*StartTaskRequest) Reset added in v0.2.4 

func (x *StartTaskRequest) Reset()

func (*StartTaskRequest) String added in v0.2.4 

func (x *StartTaskRequest) String() string

type StartTaskResponse added in v0.2.4 

type StartTaskResponse struct {
	// contains filtered or unexported fields
}

func (*StartTaskResponse) Descriptor deprecated added in v0.2.4 

func (*StartTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use StartTaskResponse.ProtoReflect.Descriptor instead.

func (*StartTaskResponse) ProtoMessage added in v0.2.4 

func (*StartTaskResponse) ProtoMessage()

func (*StartTaskResponse) ProtoReflect added in v0.2.4 

func (x *StartTaskResponse) ProtoReflect() protoreflect.Message

func (*StartTaskResponse) Reset added in v0.2.4 

func (x *StartTaskResponse) Reset()

func (*StartTaskResponse) String added in v0.2.4 

func (x *StartTaskResponse) String() string

type UnimplementedMasterServer 

type UnimplementedMasterServer struct {
}

UnimplementedMasterServer must be embedded to have forward compatible implementations.

func (UnimplementedMasterServer) FinishTask added in v0.2.4 

func (UnimplementedMasterServer) FinishTask(context.Context, *FinishTaskRequest) (*FinishTaskResponse, error)

func (UnimplementedMasterServer) GetClickModel added in v0.2.2 

func (UnimplementedMasterServer) GetClickModel(*VersionInfo, Master_GetClickModelServer) error

func (UnimplementedMasterServer) GetMeta 

func (UnimplementedMasterServer) GetMeta(context.Context, *NodeInfo) (*Meta, error)

func (UnimplementedMasterServer) GetRankingModel 

func (UnimplementedMasterServer) GetRankingModel(*VersionInfo, Master_GetRankingModelServer) error

func (UnimplementedMasterServer) StartTask added in v0.2.4 

func (UnimplementedMasterServer) StartTask(context.Context, *StartTaskRequest) (*StartTaskResponse, error)

func (UnimplementedMasterServer) UpdateTask added in v0.2.4 

func (UnimplementedMasterServer) UpdateTask(context.Context, *UpdateTaskRequest) (*UpdateTaskResponse, error)

type UnsafeMasterServer 

type UnsafeMasterServer interface {
	// contains filtered or unexported methods
}

UnsafeMasterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MasterServer will result in compilation errors.

type UpdateTaskRequest added in v0.2.4 

type UpdateTaskRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Done int64  `protobuf:"varint,2,opt,name=done,proto3" json:"done,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateTaskRequest) Descriptor deprecated added in v0.2.4 

func (*UpdateTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateTaskRequest.ProtoReflect.Descriptor instead.

func (*UpdateTaskRequest) GetDone added in v0.2.4 

func (x *UpdateTaskRequest) GetDone() int64

func (*UpdateTaskRequest) GetName added in v0.2.4 

func (x *UpdateTaskRequest) GetName() string

func (*UpdateTaskRequest) ProtoMessage added in v0.2.4 

func (*UpdateTaskRequest) ProtoMessage()

func (*UpdateTaskRequest) ProtoReflect added in v0.2.4 

func (x *UpdateTaskRequest) ProtoReflect() protoreflect.Message

func (*UpdateTaskRequest) Reset added in v0.2.4 

func (x *UpdateTaskRequest) Reset()

func (*UpdateTaskRequest) String added in v0.2.4 

func (x *UpdateTaskRequest) String() string

type UpdateTaskResponse added in v0.2.4 

type UpdateTaskResponse struct {
	// contains filtered or unexported fields
}

func (*UpdateTaskResponse) Descriptor deprecated added in v0.2.4 

func (*UpdateTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateTaskResponse.ProtoReflect.Descriptor instead.

func (*UpdateTaskResponse) ProtoMessage added in v0.2.4 

func (*UpdateTaskResponse) ProtoMessage()

func (*UpdateTaskResponse) ProtoReflect added in v0.2.4 

func (x *UpdateTaskResponse) ProtoReflect() protoreflect.Message

func (*UpdateTaskResponse) Reset added in v0.2.4 

func (x *UpdateTaskResponse) Reset()

func (*UpdateTaskResponse) String added in v0.2.4 

func (x *UpdateTaskResponse) String() string

type VersionInfo added in v0.2.7 

type VersionInfo struct {
	Version int64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*VersionInfo) Descriptor deprecated added in v0.2.7 

func (*VersionInfo) Descriptor() ([]byte, []int)

Deprecated: Use VersionInfo.ProtoReflect.Descriptor instead.

func (*VersionInfo) GetVersion added in v0.2.7 

func (x *VersionInfo) GetVersion() int64

func (*VersionInfo) ProtoMessage added in v0.2.7 

func (*VersionInfo) ProtoMessage()

func (*VersionInfo) ProtoReflect added in v0.2.7 

func (x *VersionInfo) ProtoReflect() protoreflect.Message

func (*VersionInfo) Reset added in v0.2.7 

func (x *VersionInfo) Reset()

func (*VersionInfo) String added in v0.2.7 

func (x *VersionInfo) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.