worker

type Config struct {
	Database DatabaseConfig `yaml:"database"`

	Concurrency   int             `yaml:"concurrency"`
	BRPopTimeout  config.Duration `yaml:"brpop_timeout"`
	QueueStrategy QueueStrategy   `yaml:"queue_strategy"`

	RetryBackoffBase config.Duration `yaml:"retry_backoff_base"`
	RetryBackoffMax  config.Duration `yaml:"retry_backoff_max"`

	OutcomeWriteTimeout config.Duration `yaml:"outcome_write_timeout"`
	ShutdownGrace       config.Duration `yaml:"shutdown_grace"`

	HeartbeatInterval config.Duration `yaml:"heartbeat_interval"`
	StaleMultiplier   int             `yaml:"stale_multiplier"`

	RegistryInterval config.Duration `yaml:"registry_interval"`
	RegistryTTL      config.Duration `yaml:"registry_ttl"`

	LogFlushInterval  config.Duration `yaml:"log_flush_interval"`
	LogFlushTimeout   config.Duration `yaml:"log_flush_timeout"`
	LogFlushThreshold int             `yaml:"log_flush_threshold"`
	LogBufferCapacity int             `yaml:"log_buffer_capacity"`
}

type DatabaseConfig struct {
	Partitioning PartitioningConfig `yaml:"partitioning"`
	Retention    RetentionConfig    `yaml:"retention"`
}

type HandlerFunc func(ctx context.Context, j Job) (string, error)

type InflightJob struct {
	Name      string             `json:"name"`
	ID        pgtype.UUID        `json:"id"`
	AttemptID pgtype.UUID        `json:"attempt_id"`
	Version   int32              `json:"version"`
	Queue     string             `json:"queue"`
	Handler   string             `json:"handler"`
	StartedAt time.Time          `json:"started_at"`
	Cancel    context.CancelFunc `json:"-"`
}

type Job struct {
	ID         uuid.UUID
	Name       string
	Queue      string
	Handler    string
	Payload    []byte
	RetryCount int32
	MaxRetries int32
	Logs       *JobLogger
}

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

type PartitionInterval string

type PartitioningConfig struct {
	Interval    PartitionInterval `yaml:"interval"`
	CreateAhead int               `yaml:"create_ahead"`
}

type QueueStrategy string

type RegistryEntry struct {
	Name      string        `json:"name"`
	ID        uuid.UUID     `json:"id"`
	Queues    []string      `json:"queues"`
	Handlers  []string      `json:"handlers"`
	InFlight  []InflightJob `json:"in_flight"`
	StartedAt time.Time     `json:"started_at"`
	LastSeen  time.Time     `json:"last_seen"`
}

type RetentionConfig struct {
	Days int `yaml:"days"`
}

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