worker

type ExecReply struct {
}

type ExecRequest struct {
	Function string               `protobuf:"bytes,1,opt,name=function" json:"function,omitempty"`
	Args     *google_protobuf.Any `protobuf:"bytes,2,opt,name=args" json:"args,omitempty"`
	Data     *google_protobuf.Any `protobuf:"bytes,3,opt,name=data" json:"data,omitempty"`
}

type InfoReply struct {
	Id           string   `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	Version      string   `protobuf:"bytes,2,opt,name=version" json:"version,omitempty"`
	MaxParallel  int32    `protobuf:"varint,3,opt,name=max_parallel,json=maxParallel" json:"max_parallel,omitempty"`
	Capabilities []string `protobuf:"bytes,4,rep,name=capabilities" json:"capabilities,omitempty"`
}

type InfoRequest struct {
}

type WorkerClient interface {
	// Request client informations
	Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoReply, error)
	Exec(ctx context.Context, in *ExecRequest, opts ...grpc.CallOption) (*ExecReply, error)
}

type WorkerServer interface {
	// Request client informations
	Info(context.Context, *InfoRequest) (*InfoReply, error)
	Exec(context.Context, *ExecRequest) (*ExecReply, error)
}