grpc

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

type ClientOptions struct {
	// Address is the gRPC server address (e.g., "grpc.spooled.cloud:443")
	Address string
	// APIKey is the API key for authentication
	APIKey string
	// UseTLS enables TLS (default: true for port 443)
	UseTLS *bool
	// TLSConfig is custom TLS configuration (optional)
	TLSConfig *tls.Config
	// DialOptions are additional gRPC dial options
	DialOptions []grpc.DialOption
	// Timeout is the connection timeout
	Timeout time.Duration
}

type CompleteRequest struct {
	JobID    string
	WorkerID string
	Result   map[string]any
}

type DequeueRequest struct {
	QueueName        string
	WorkerID         string
	BatchSize        int32
	LeaseDurationSec int32
}

type DequeueResponse struct {
	Jobs []*Job
}

type EnqueueRequest struct {
	QueueName      string
	Payload        map[string]any
	Priority       int32
	MaxRetries     int32
	TimeoutSeconds int32
	ScheduledAt    *time.Time
	IdempotencyKey string
}

type EnqueueResponse struct {
	JobID   string
	Created bool
}

type FailRequest struct {
	JobID    string
	WorkerID string
	Error    string
	Retry    bool
}

type Job struct {
	ID             string
	QueueName      string
	Payload        map[string]any
	Priority       int32
	RetryCount     int32
	MaxRetries     int32
	TimeoutSeconds int32
	LeaseExpiresAt *time.Time
}

type QueueStats struct {
	QueueName  string
	Pending    int64
	Scheduled  int64
	Processing int64
	Completed  int64
	Failed     int64
	Deadletter int64
	Total      int64
	MaxAgeMs   int64
}

type RegisterWorkerRequest struct {
	QueueName      string
	Hostname       string
	MaxConcurrency int32
	Version        string
	Metadata       map[string]string
}

type RegisterWorkerResponse struct {
	WorkerID             string
	HeartbeatIntervalSec int32
	LeaseDurationSec     int32
}

type RenewLeaseRequest struct {
	JobID         string
	WorkerID      string
	ExtensionSecs int32
}

type RenewLeaseResponse struct {
	Success      bool
	NewExpiresAt *time.Time
}

type WorkerHeartbeatRequest struct {
	WorkerID    string
	CurrentJobs int32
	Status      string
}