跳到主要内容

tophant.benjamin.x.manager

Services​

service Manager​

Manager 定义了内部其他组件与 Manager 进行通信的接口【仅供 Benjamin 内部使用，外部包禁止调用】

rpc GetTask​

用于 Worker 询问任务状态

rpc GetTask ( GetTaskRequest ) returns ( GetTaskResponse )
message GetTaskRequest {
    string id = 1;
    string worker_id = 2;
}
message GetTaskResponse {
}

rpc Ping​

rpc Ping ( PingMessage ) returns ( PongMessage )
message PingMessage {
    // no fields
}
message PongMessage {
    // no fields
}

rpc RefreshAuth​

用于上层 API 告知刷新 Auth

rpc RefreshAuth ( RefreshAuthRequest ) returns ( RefreshAuthResponse )
message RefreshAuthRequest {
}
message RefreshAuthResponse {
    // no fields
}

rpc RegisterWorker​

用于 Worker 注册自己

rpc RegisterWorker ( RegisterWorkerRequest ) returns ( RegisterWorkerResponse )
message RegisterWorkerRequest {
}
message RegisterWorkerResponse {
    // no fields
}

rpc ReportEvent​

用于 Worker 通知有新的 Event

rpc ReportEvent ( ReportEventRequest ) returns ( ReportEventResponse )
message ReportEventRequest {
}
message ReportEventResponse {
    // no fields
}

rpc Stop​

用于上层 API 告知停止任务

rpc Stop ( StopRequest ) returns ( StopResponse )
message StopRequest {
    // no fields
}
message StopResponse {
    // no fields
}

rpc WorkerExit​

用于 Worker 发送退出状态

rpc WorkerExit ( WorkerExitRequest ) returns ( WorkerExitResponse )
message WorkerExitRequest {
    string worker_id = 1;
}
message WorkerExitResponse {
    // no fields
}

rpc WorkerListenEvent​

用于 Worker 监听 Manager 事件

rpc WorkerListenEvent ( stream W1Event ) returns ( stream W1Event )
message W1Event {
    oneof event {
        W1Event.RefreshAuth refresh_auth = 21;
    }
}
message W1Event {
    oneof event {
        W1Event.RefreshAuth refresh_auth = 21;
    }
}

rpc WorkerTick​

用于 Worker 发送 tick

rpc WorkerTick ( WorkerTickRequest ) returns ( WorkerTickResponse )
message WorkerTickRequest {
    string worker_id = 1;
}
message WorkerTickResponse {
    // no fields
}

Messages​

message Event​

message Event {
}

message GetTaskRequest​

message GetTaskRequest {
    string id = 1;
    string worker_id = 2;
}

message GetTaskResponse​

message GetTaskResponse {
}

message PingMessage​

message PingMessage {
    // no fields
}

message PongMessage​

message PongMessage {
    // no fields
}

message RefreshAuthRequest​

message RefreshAuthRequest {
}

message RefreshAuthResponse​

message RefreshAuthResponse {
    // no fields
}

message RegisterWorkerRequest​

message RegisterWorkerRequest {
}

message RegisterWorkerResponse​

message RegisterWorkerResponse {
    // no fields
}

message ReportEventRequest​

message ReportEventRequest {
}

message ReportEventResponse​

message ReportEventResponse {
    // no fields
}

message StopRequest​

message StopRequest {
    // no fields
}

message StopResponse​

message StopResponse {
    // no fields
}

message W1Event​

W1 Event 用于 Worker 监听 Manager 发送的通知 string request_id = 1;

message W1Event {
    oneof event {
        W1Event.RefreshAuth refresh_auth = 21;
    }
}

message W1Event.RefreshAuth​

message RefreshAuth {
    RefreshAuthRequest request = 1;
}

message WorkerExitRequest​

message WorkerExitRequest {
    string worker_id = 1;
}

message WorkerExitResponse​

message WorkerExitResponse {
    // no fields
}

message WorkerTickRequest​

message WorkerTickRequest {
    string worker_id = 1;
}

message WorkerTickResponse​

message WorkerTickResponse {
    // no fields
}