protobuf

type ExecuteTaskRequest struct {
	Request []byte `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

type ExecuteTaskResponse struct {
	Url    string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	ErrMsg string `protobuf:"bytes,2,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	// contains filtered or unexported fields
}

type GetTaskDescriptionRequest struct {
	// contains filtered or unexported fields
}

type GetTaskDescriptionResponse struct {
	Description string `protobuf:"bytes,1,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

type JobClient interface {
	InvokeService(ctx context.Context, in *JobInvokeServiceRequest, opts ...grpc.CallOption) (*JobInvokeServiceResponse, error)
	UpdateProgress(ctx context.Context, in *JobUpdateProgressRequest, opts ...grpc.CallOption) (*JobUpdateProgressResponse, error)
	CreateAttachment(ctx context.Context, in *JobCreateAttachmentRequest, opts ...grpc.CallOption) (*JobCreateAttachmentResponse, error)
}

type JobCreateAttachmentRequest struct {
	JobName  string `protobuf:"bytes,1,opt,name=jobName,proto3" json:"jobName,omitempty"`
	Filename string `protobuf:"bytes,2,opt,name=filename,proto3" json:"filename,omitempty"`
	Data     []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type JobCreateAttachmentResponse struct {
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

type JobInvokeServiceRequest struct {
	App     string `protobuf:"bytes,1,opt,name=app,proto3" json:"app,omitempty"`
	Version int32  `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	Module  string `protobuf:"bytes,3,opt,name=module,proto3" json:"module,omitempty"`
	Method  string `protobuf:"bytes,4,opt,name=method,proto3" json:"method,omitempty"`
	Request []byte `protobuf:"bytes,5,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

type JobInvokeServiceResponse struct {
	Response []byte `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

type JobServer interface {
	InvokeService(context.Context, *JobInvokeServiceRequest) (*JobInvokeServiceResponse, error)
	UpdateProgress(context.Context, *JobUpdateProgressRequest) (*JobUpdateProgressResponse, error)
	CreateAttachment(context.Context, *JobCreateAttachmentRequest) (*JobCreateAttachmentResponse, error)
	// contains filtered or unexported methods
}

type JobUpdateProgressRequest struct {
	Id       int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Progress int32 `protobuf:"varint,2,opt,name=progress,proto3" json:"progress,omitempty"`
	// contains filtered or unexported fields
}

type JobUpdateProgressResponse struct {
	// contains filtered or unexported fields
}

type TaskClient interface {
	Execute(ctx context.Context, in *ExecuteTaskRequest, opts ...grpc.CallOption) (*ExecuteTaskResponse, error)
	GetDescription(ctx context.Context, in *GetTaskDescriptionRequest, opts ...grpc.CallOption) (*GetTaskDescriptionResponse, error)
}

type TaskServer interface {
	Execute(context.Context, *ExecuteTaskRequest) (*ExecuteTaskResponse, error)
	GetDescription(context.Context, *GetTaskDescriptionRequest) (*GetTaskDescriptionResponse, error)
	// contains filtered or unexported methods
}

type UnimplementedJobServer struct{}

type UnimplementedTaskServer struct{}

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

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