syntax = "proto3";
package emerwen.workercontrol;

import "shared/target.proto";

service WorkerControlService {
    rpc WorkerStream(stream WorkerMessage) returns (stream ServerCommand) {}
}

message WorkerMessage {
    oneof payload {
        RegistrationMessage registration = 1;
        TargetStateMessage target_state = 2;
    }
}

message RegistrationMessage {}

message TargetStateMessage {
    string target_id = 1;
    shared.TargetState state = 2;
}

message ServerCommand {
    oneof payload {
        TargetsCommand targets = 1;
    }
}

message TargetsCommand {
    repeated shared.Target targets = 1;
}