pb

type CompleteRequest struct {
	JobId    string           `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	WorkerId string           `protobuf:"bytes,2,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	Result   *structpb.Struct `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	// Lease fencing token from the dequeued Job. When set, the completion
	// succeeds only if it matches the job's current lease.
	LeaseId string `protobuf:"bytes,4,opt,name=lease_id,json=leaseId,proto3" json:"lease_id,omitempty"`
	// contains filtered or unexported fields
}

type CompleteResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

type DequeueRequest struct {
	QueueName         string `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
	WorkerId          string `protobuf:"bytes,2,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	LeaseDurationSecs int32  `protobuf:"varint,3,opt,name=lease_duration_secs,json=leaseDurationSecs,proto3" json:"lease_duration_secs,omitempty"`
	BatchSize         int32  `protobuf:"varint,4,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"` // How many jobs to dequeue at once
	// contains filtered or unexported fields
}

type DequeueResponse struct {
	Jobs []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

type DeregisterRequest struct {
	WorkerId string `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	// contains filtered or unexported fields
}

type DeregisterResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

type EnqueueRequest struct {
	QueueName      string                 `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
	Payload        *structpb.Struct       `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	Priority       int32                  `protobuf:"varint,3,opt,name=priority,proto3" json:"priority,omitempty"`
	MaxRetries     int32                  `protobuf:"varint,4,opt,name=max_retries,json=maxRetries,proto3" json:"max_retries,omitempty"`
	TimeoutSeconds int32                  `protobuf:"varint,5,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`
	ScheduledAt    *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=scheduled_at,json=scheduledAt,proto3" json:"scheduled_at,omitempty"`
	IdempotencyKey string                 `protobuf:"bytes,7,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	Tags           map[string]string      `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

type EnqueueResponse struct {
	JobId   string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Created bool   `protobuf:"varint,2,opt,name=created,proto3" json:"created,omitempty"` // false if idempotent (existing job)
	// contains filtered or unexported fields
}

type ErrorResponse struct {
	Code    string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type FailRequest struct {
	JobId    string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	WorkerId string `protobuf:"bytes,2,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	Error    string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	Retry    bool   `protobuf:"varint,4,opt,name=retry,proto3" json:"retry,omitempty"` // Whether to retry or move to DLQ
	// Lease fencing token from the dequeued Job. When set, the failure
	// succeeds only if it matches the job's current lease.
	LeaseId string `protobuf:"bytes,5,opt,name=lease_id,json=leaseId,proto3" json:"lease_id,omitempty"`
	// contains filtered or unexported fields
}

type FailResponse struct {
	Success            bool  `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	WillRetry          bool  `protobuf:"varint,2,opt,name=will_retry,json=willRetry,proto3" json:"will_retry,omitempty"`
	NextRetryDelaySecs int32 `protobuf:"varint,3,opt,name=next_retry_delay_secs,json=nextRetryDelaySecs,proto3" json:"next_retry_delay_secs,omitempty"`
	// contains filtered or unexported fields
}

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

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

type GetQueueStatsRequest struct {
	QueueName string `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
	// contains filtered or unexported fields
}

type GetQueueStatsResponse struct {
	QueueName  string `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
	Pending    int64  `protobuf:"varint,2,opt,name=pending,proto3" json:"pending,omitempty"`
	Scheduled  int64  `protobuf:"varint,3,opt,name=scheduled,proto3" json:"scheduled,omitempty"`
	Processing int64  `protobuf:"varint,4,opt,name=processing,proto3" json:"processing,omitempty"`
	Completed  int64  `protobuf:"varint,5,opt,name=completed,proto3" json:"completed,omitempty"`
	Failed     int64  `protobuf:"varint,6,opt,name=failed,proto3" json:"failed,omitempty"`
	Deadletter int64  `protobuf:"varint,7,opt,name=deadletter,proto3" json:"deadletter,omitempty"`
	Total      int64  `protobuf:"varint,8,opt,name=total,proto3" json:"total,omitempty"`
	MaxAgeMs   int64  `protobuf:"varint,9,opt,name=max_age_ms,json=maxAgeMs,proto3" json:"max_age_ms,omitempty"` // Age of oldest pending job
	// contains filtered or unexported fields
}

type HeartbeatRequest struct {
	WorkerId    string            `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	CurrentJobs int32             `protobuf:"varint,2,opt,name=current_jobs,json=currentJobs,proto3" json:"current_jobs,omitempty"`
	Status      string            `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	Metadata    map[string]string `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

type HeartbeatResponse struct {
	Acknowledged bool `protobuf:"varint,1,opt,name=acknowledged,proto3" json:"acknowledged,omitempty"`
	ShouldDrain  bool `protobuf:"varint,2,opt,name=should_drain,json=shouldDrain,proto3" json:"should_drain,omitempty"` // Signal to worker to stop accepting new jobs
	// contains filtered or unexported fields
}

type Job struct {
	Id               string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	OrganizationId   string                 `protobuf:"bytes,2,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"`
	QueueName        string                 `protobuf:"bytes,3,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
	Status           JobStatus              `protobuf:"varint,4,opt,name=status,proto3,enum=spooled.v1.JobStatus" json:"status,omitempty"`
	Payload          *structpb.Struct       `protobuf:"bytes,5,opt,name=payload,proto3" json:"payload,omitempty"`
	Result           *structpb.Struct       `protobuf:"bytes,6,opt,name=result,proto3" json:"result,omitempty"`
	RetryCount       int32                  `protobuf:"varint,7,opt,name=retry_count,json=retryCount,proto3" json:"retry_count,omitempty"`
	MaxRetries       int32                  `protobuf:"varint,8,opt,name=max_retries,json=maxRetries,proto3" json:"max_retries,omitempty"`
	LastError        string                 `protobuf:"bytes,9,opt,name=last_error,json=lastError,proto3" json:"last_error,omitempty"`
	Priority         int32                  `protobuf:"varint,10,opt,name=priority,proto3" json:"priority,omitempty"`
	TimeoutSeconds   int32                  `protobuf:"varint,11,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`
	CreatedAt        *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	ScheduledAt      *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=scheduled_at,json=scheduledAt,proto3" json:"scheduled_at,omitempty"`
	StartedAt        *timestamppb.Timestamp `protobuf:"bytes,14,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	CompletedAt      *timestamppb.Timestamp `protobuf:"bytes,15,opt,name=completed_at,json=completedAt,proto3" json:"completed_at,omitempty"`
	LeaseExpiresAt   *timestamppb.Timestamp `protobuf:"bytes,16,opt,name=lease_expires_at,json=leaseExpiresAt,proto3" json:"lease_expires_at,omitempty"`
	AssignedWorkerId string                 `protobuf:"bytes,17,opt,name=assigned_worker_id,json=assignedWorkerId,proto3" json:"assigned_worker_id,omitempty"`
	IdempotencyKey   string                 `protobuf:"bytes,18,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	// Fencing token for the current lease. Returned on dequeue; echo it back
	// in Complete/Fail/RenewLease to guarantee the operation applies only to
	// the lease this worker actually holds (empty = legacy worker_id fence).
	LeaseId string `protobuf:"bytes,19,opt,name=lease_id,json=leaseId,proto3" json:"lease_id,omitempty"`
	// contains filtered or unexported fields
}

type JobStatus int32

type ProcessRequest struct {

	// Types that are valid to be assigned to Request:
	//
	//	*ProcessRequest_Dequeue
	//	*ProcessRequest_Complete
	//	*ProcessRequest_Fail
	//	*ProcessRequest_RenewLease
	Request isProcessRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

type ProcessRequest_Complete struct {
	Complete *CompleteRequest `protobuf:"bytes,2,opt,name=complete,proto3,oneof"`
}

type ProcessRequest_Dequeue struct {
	Dequeue *DequeueRequest `protobuf:"bytes,1,opt,name=dequeue,proto3,oneof"`
}

type ProcessRequest_Fail struct {
	Fail *FailRequest `protobuf:"bytes,3,opt,name=fail,proto3,oneof"`
}

type ProcessRequest_RenewLease struct {
	RenewLease *RenewLeaseRequest `protobuf:"bytes,4,opt,name=renew_lease,json=renewLease,proto3,oneof"`
}

type ProcessResponse struct {

	// Types that are valid to be assigned to Response:
	//
	//	*ProcessResponse_Job
	//	*ProcessResponse_Complete
	//	*ProcessResponse_Fail
	//	*ProcessResponse_RenewLease
	//	*ProcessResponse_Error
	Response isProcessResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

type ProcessResponse_Complete struct {
	Complete *CompleteResponse `protobuf:"bytes,2,opt,name=complete,proto3,oneof"`
}

type ProcessResponse_Error struct {
	Error *ErrorResponse `protobuf:"bytes,5,opt,name=error,proto3,oneof"`
}

type ProcessResponse_Fail struct {
	Fail *FailResponse `protobuf:"bytes,3,opt,name=fail,proto3,oneof"`
}

type ProcessResponse_Job struct {
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3,oneof"`
}

type ProcessResponse_RenewLease struct {
	RenewLease *RenewLeaseResponse `protobuf:"bytes,4,opt,name=renew_lease,json=renewLease,proto3,oneof"`
}

type QueueServiceClient interface {
	// Enqueue a new job
	Enqueue(ctx context.Context, in *EnqueueRequest, opts ...grpc.CallOption) (*EnqueueResponse, error)
	// Dequeue a job (for workers)
	Dequeue(ctx context.Context, in *DequeueRequest, opts ...grpc.CallOption) (*DequeueResponse, error)
	// Complete a job
	Complete(ctx context.Context, in *CompleteRequest, opts ...grpc.CallOption) (*CompleteResponse, error)
	// Fail a job
	Fail(ctx context.Context, in *FailRequest, opts ...grpc.CallOption) (*FailResponse, error)
	// Renew job lease
	RenewLease(ctx context.Context, in *RenewLeaseRequest, opts ...grpc.CallOption) (*RenewLeaseResponse, error)
	// Get job status
	GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*GetJobResponse, error)
	// Get queue statistics
	GetQueueStats(ctx context.Context, in *GetQueueStatsRequest, opts ...grpc.CallOption) (*GetQueueStatsResponse, error)
	// Stream jobs to workers (server-side streaming)
	// Note: Streaming is implemented via REST API WebSocket/SSE endpoints:
	//   - GET /api/v1/ws (WebSocket for bidirectional real-time updates)
	//   - GET /api/v1/events (SSE for job event streaming)
	//   - GET /api/v1/events/jobs/{id} (SSE for single job updates)
	//   - GET /api/v1/events/queues/{name} (SSE for queue updates)
	StreamJobs(ctx context.Context, in *StreamJobsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Job], error)
	// Bidirectional streaming for real-time job processing
	// Note: Use WebSocket endpoint /api/v1/ws for bidirectional communication
	ProcessJobs(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[ProcessRequest, ProcessResponse], error)
}

type QueueServiceServer interface {
	// Enqueue a new job
	Enqueue(context.Context, *EnqueueRequest) (*EnqueueResponse, error)
	// Dequeue a job (for workers)
	Dequeue(context.Context, *DequeueRequest) (*DequeueResponse, error)
	// Complete a job
	Complete(context.Context, *CompleteRequest) (*CompleteResponse, error)
	// Fail a job
	Fail(context.Context, *FailRequest) (*FailResponse, error)
	// Renew job lease
	RenewLease(context.Context, *RenewLeaseRequest) (*RenewLeaseResponse, error)
	// Get job status
	GetJob(context.Context, *GetJobRequest) (*GetJobResponse, error)
	// Get queue statistics
	GetQueueStats(context.Context, *GetQueueStatsRequest) (*GetQueueStatsResponse, error)
	// Stream jobs to workers (server-side streaming)
	// Note: Streaming is implemented via REST API WebSocket/SSE endpoints:
	//   - GET /api/v1/ws (WebSocket for bidirectional real-time updates)
	//   - GET /api/v1/events (SSE for job event streaming)
	//   - GET /api/v1/events/jobs/{id} (SSE for single job updates)
	//   - GET /api/v1/events/queues/{name} (SSE for queue updates)
	StreamJobs(*StreamJobsRequest, grpc.ServerStreamingServer[Job]) error
	// Bidirectional streaming for real-time job processing
	// Note: Use WebSocket endpoint /api/v1/ws for bidirectional communication
	ProcessJobs(grpc.BidiStreamingServer[ProcessRequest, ProcessResponse]) error
	// contains filtered or unexported methods
}

type QueueService_ProcessJobsClient = grpc.BidiStreamingClient[ProcessRequest, ProcessResponse]

type QueueService_ProcessJobsServer = grpc.BidiStreamingServer[ProcessRequest, ProcessResponse]

type QueueService_StreamJobsClient = grpc.ServerStreamingClient[Job]

type QueueService_StreamJobsServer = grpc.ServerStreamingServer[Job]

type RegisterWorkerRequest struct {
	QueueName      string            `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
	Hostname       string            `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	WorkerType     string            `protobuf:"bytes,3,opt,name=worker_type,json=workerType,proto3" json:"worker_type,omitempty"`
	MaxConcurrency int32             `protobuf:"varint,4,opt,name=max_concurrency,json=maxConcurrency,proto3" json:"max_concurrency,omitempty"`
	Version        string            `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	Metadata       map[string]string `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

type RegisterWorkerResponse struct {
	WorkerId              string `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	LeaseDurationSecs     int32  `protobuf:"varint,2,opt,name=lease_duration_secs,json=leaseDurationSecs,proto3" json:"lease_duration_secs,omitempty"`
	HeartbeatIntervalSecs int32  `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

type RenewLeaseRequest struct {
	JobId         string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	WorkerId      string `protobuf:"bytes,2,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	ExtensionSecs int32  `protobuf:"varint,3,opt,name=extension_secs,json=extensionSecs,proto3" json:"extension_secs,omitempty"`
	// Lease fencing token from the dequeued Job. When set, the renewal
	// succeeds only if it matches the job's current lease.
	LeaseId string `protobuf:"bytes,4,opt,name=lease_id,json=leaseId,proto3" json:"lease_id,omitempty"`
	// contains filtered or unexported fields
}

type RenewLeaseResponse struct {
	Success      bool                   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	NewExpiresAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=new_expires_at,json=newExpiresAt,proto3" json:"new_expires_at,omitempty"`
	// contains filtered or unexported fields
}

type StreamJobsRequest struct {
	QueueName         string `protobuf:"bytes,1,opt,name=queue_name,json=queueName,proto3" json:"queue_name,omitempty"`
	WorkerId          string `protobuf:"bytes,2,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	LeaseDurationSecs int32  `protobuf:"varint,3,opt,name=lease_duration_secs,json=leaseDurationSecs,proto3" json:"lease_duration_secs,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedQueueServiceServer struct{}

type UnimplementedWorkerServiceServer struct{}

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

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

type WorkerServiceClient interface {
	// Register a new worker
	Register(ctx context.Context, in *RegisterWorkerRequest, opts ...grpc.CallOption) (*RegisterWorkerResponse, error)
	// Send heartbeat
	Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error)
	// Deregister worker
	Deregister(ctx context.Context, in *DeregisterRequest, opts ...grpc.CallOption) (*DeregisterResponse, error)
}

type WorkerServiceServer interface {
	// Register a new worker
	Register(context.Context, *RegisterWorkerRequest) (*RegisterWorkerResponse, error)
	// Send heartbeat
	Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
	// Deregister worker
	Deregister(context.Context, *DeregisterRequest) (*DeregisterResponse, error)
	// contains filtered or unexported methods
}