task

type ClientInfo struct {

	// ClientId the client id
	ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// Labels the client labels that are used to match tasks
	Labels []string `protobuf:"bytes,2,rep,name=labels,proto3" json:"labels,omitempty"`
	// contains filtered or unexported fields
}

type Dispatcher interface {
	// Acquire try to acquire a task
	Acquire(client *ClientInfo, ip string) (task *TaskInfo, err error)
}

type TaskInfo struct {

	// Name the unique task name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Ext the extension type of the task config content
	Ext string `protobuf:"bytes,2,opt,name=ext,proto3" json:"ext,omitempty"`
	// Content the task config content
	Content string `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

type TaskServiceClient interface {
	// SubscribeTask register a task client to the task server and wait to receive task
	SubscribeTask(ctx context.Context, in *ClientInfo, opts ...grpc.CallOption) (TaskService_SubscribeTaskClient, error)
}

type TaskServiceServer interface {
	// SubscribeTask register a task client to the task server and wait to receive task
	SubscribeTask(*ClientInfo, TaskService_SubscribeTaskServer) error
	// contains filtered or unexported methods
}

type TaskService_SubscribeTaskClient interface {
	Recv() (*TaskInfo, error)
	grpc.ClientStream
}

type TaskService_SubscribeTaskServer interface {
	Send(*TaskInfo) error
	grpc.ServerStream
}

type UnimplementedTaskServiceServer struct {
}

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