worker

type CreateJobInput struct {
	Type   string            `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Inputs map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

type CreateJobOutput struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

type DescribeJobInput struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

type DescribeJobOutput struct {
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

type Job struct {
	Id         string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type       string                 `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Inputs     map[string]string      `` /* 153-byte string literal not displayed */
	CreatedAt  *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	StartedAt  *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	ProgressAt *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=progress_at,json=progressAt,proto3" json:"progress_at,omitempty"`
	CompleteAt *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=complete_at,json=completeAt,proto3" json:"complete_at,omitempty"`
	// progress is a number from 0 to `total`, showing amount of work complete
	Progress uint32            `protobuf:"varint,20,opt,name=progress,proto3" json:"progress,omitempty"`
	Total    uint32            `protobuf:"varint,21,opt,name=total,proto3" json:"total,omitempty"`
	Status   Job_Status        `protobuf:"varint,30,opt,name=status,proto3,enum=eolymp.worker.Job_Status" json:"status,omitempty"`
	Outputs  map[string]string `` /* 156-byte string literal not displayed */
	Logs     string            `protobuf:"bytes,100,opt,name=logs,proto3" json:"logs,omitempty"`
	// contains filtered or unexported fields
}

type JobTriggerEvent struct {
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

type Job_Status int32

type ListJobsInput struct {

	// pagination
	Offset int32 `protobuf:"varint,10,opt,name=offset,proto3" json:"offset,omitempty"`
	Size   int32 `protobuf:"varint,11,opt,name=size,proto3" json:"size,omitempty"`
	// data filters
	Filters *ListJobsInput_Filter `protobuf:"bytes,40,opt,name=filters,proto3" json:"filters,omitempty"`
	// contains filtered or unexported fields
}

type ListJobsInput_Filter struct {
	Id     []*wellknown.ExpressionID   `protobuf:"bytes,1,rep,name=id,proto3" json:"id,omitempty"`
	Type   []*wellknown.ExpressionEnum `protobuf:"bytes,2,rep,name=type,proto3" json:"type,omitempty"`
	Status []*wellknown.ExpressionEnum `protobuf:"bytes,3,rep,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type ListJobsOutput struct {
	Total int32  `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	Items []*Job `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedWorkerServer struct {
}

type UnimplementedWorkerServiceServer struct {
}

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

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

type WorkerClient interface {
	CreateJob(ctx context.Context, in *CreateJobInput, opts ...grpc.CallOption) (*CreateJobOutput, error)
	DescribeJob(ctx context.Context, in *DescribeJobInput, opts ...grpc.CallOption) (*DescribeJobOutput, error)
	ListJobs(ctx context.Context, in *ListJobsInput, opts ...grpc.CallOption) (*ListJobsOutput, error)
}

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

type WorkerServer interface {
	CreateJob(context.Context, *CreateJobInput) (*CreateJobOutput, error)
	DescribeJob(context.Context, *DescribeJobInput) (*DescribeJobOutput, error)
	ListJobs(context.Context, *ListJobsInput) (*ListJobsOutput, error)
}

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

type WorkerServiceClient interface {
	CreateJob(ctx context.Context, in *CreateJobInput, opts ...grpc.CallOption) (*CreateJobOutput, error)
	DescribeJob(ctx context.Context, in *DescribeJobInput, opts ...grpc.CallOption) (*DescribeJobOutput, error)
	ListJobs(ctx context.Context, in *ListJobsInput, opts ...grpc.CallOption) (*ListJobsOutput, error)
}

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

type WorkerServiceServer interface {
	CreateJob(context.Context, *CreateJobInput) (*CreateJobOutput, error)
	DescribeJob(context.Context, *DescribeJobInput) (*DescribeJobOutput, error)
	ListJobs(context.Context, *ListJobsInput) (*ListJobsOutput, error)
}

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