protocol

package
v0.2.6 Latest Latest
Warning

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

 Go to latest Published: Sep 26, 2021 License: Apache-2.0 Imports: 9 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

Functions

func RegisterMasterServer 

func RegisterMasterServer(s grpc.ServiceRegistrar, srv MasterServer)

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 MasterClient 

type MasterClient interface {
	// meta distribute
	GetMeta(ctx context.Context, in *NodeInfo, opts ...grpc.CallOption) (*Meta, error)
	// data distribute
	GetUserIndex(ctx context.Context, in *NodeInfo, opts ...grpc.CallOption) (*UserIndex, error)
	GetRankingModel(ctx context.Context, in *NodeInfo, opts ...grpc.CallOption) (*Model, error)
	GetClickModel(ctx context.Context, in *NodeInfo, opts ...grpc.CallOption) (*Model, 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
	GetUserIndex(context.Context, *NodeInfo) (*UserIndex, error)
	GetRankingModel(context.Context, *NodeInfo) (*Model, error)
	GetClickModel(context.Context, *NodeInfo) (*Model, 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 Meta 

type Meta struct {
	Config              string   `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	UserIndexVersion    int64    `protobuf:"varint,2,opt,name=user_index_version,json=userIndexVersion,proto3" json:"user_index_version,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) GetUserIndexVersion 

func (x *Meta) GetUserIndexVersion() int64

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 Model 

type Model struct {
	Version int64  `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"` // model version
	Name    string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`        // model name
	Model   []byte `protobuf:"bytes,3,opt,name=model,proto3" json:"model,omitempty"`      // model data
	// contains filtered or unexported fields
}

func (*Model) Descriptor deprecated 

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

Deprecated: Use Model.ProtoReflect.Descriptor instead.

func (*Model) GetModel 

func (x *Model) GetModel() []byte

func (*Model) GetName 

func (x *Model) GetName() string

func (*Model) GetVersion 

func (x *Model) GetVersion() int64

func (*Model) ProtoMessage 

func (*Model) ProtoMessage()

func (*Model) ProtoReflect 

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

func (*Model) Reset 

func (x *Model) Reset()

func (*Model) String 

func (x *Model) 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(context.Context, *NodeInfo) (*Model, error)

func (UnimplementedMasterServer) GetMeta 

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

func (UnimplementedMasterServer) GetRankingModel 

func (UnimplementedMasterServer) GetRankingModel(context.Context, *NodeInfo) (*Model, error)

func (UnimplementedMasterServer) GetUserIndex 

func (UnimplementedMasterServer) GetUserIndex(context.Context, *NodeInfo) (*UserIndex, 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 UserIndex 

type UserIndex struct {
	Version   int64  `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`                     // user index version
	UserIndex []byte `protobuf:"bytes,2,opt,name=user_index,json=userIndex,proto3" json:"user_index,omitempty"` // user index data
	// contains filtered or unexported fields
}

func (*UserIndex) Descriptor deprecated 

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

Deprecated: Use UserIndex.ProtoReflect.Descriptor instead.

func (*UserIndex) GetUserIndex 

func (x *UserIndex) GetUserIndex() []byte

func (*UserIndex) GetVersion 

func (x *UserIndex) GetVersion() int64

func (*UserIndex) ProtoMessage 

func (*UserIndex) ProtoMessage()

func (*UserIndex) ProtoReflect 

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

func (*UserIndex) Reset 

func (x *UserIndex) Reset()

func (*UserIndex) String 

func (x *UserIndex) 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.