task.proto

syntax = "proto3";

import "google/protobuf/empty.proto";

message Task {
	string video_name = 1;
	string video_cid = 2;
}

message HandlerStatus {
	enum Status {
		ACTIVE = 0;
		INACTIVE = 1;
		WORKING = 2;
	}
	Status status = 1;
}

message TaskStatus {
	enum Status {
		DONE = 0;
		WORKING = 1;
		ASSIGNED = 2;
		UNASSIGNED = 3;
		FAILED = 4;
	}
	Status status = 1;
}

message Handler {
	string Addr = 1; 
}

message Response {
	bool storeInDb = 1; 
}

service TaskInitService {
	rpc SubmitTask (Task) returns (google.protobuf.Empty);
}

service TaskAllocationService {
	rpc AllocateTask (Task) returns (google.protobuf.Empty);
	rpc GetTaskStatus (google.protobuf.Empty) returns (TaskStatus);
}

service RegisterHandlerService {
	rpc RegisterTaskComplete (Handler) returns (Response); 
	rpc RegisterHandler(Handler) returns (google.protobuf.Empty); 
}