reportqueue

type DrainOptions struct {
	MaxItems     int
	LeaseTimeout time.Duration
	Now          func() time.Time
	Processor    Processor
}

type DrainResult struct {
	Processed int  `json:"processed"`
	Succeeded int  `json:"succeeded"`
	Retried   int  `json:"retried"`
	Dead      int  `json:"dead"`
	Recovered int  `json:"recovered"`
	Locked    bool `json:"locked"`
}

type EnqueueOptions struct {
	Now func() time.Time
}

type EnqueueResult struct {
	ID   string `json:"id"`
	Path string `json:"path"`
}

type Envelope struct {
	Version             int                  `json:"version"`
	ID                  string               `json:"id"`
	CreatedAt           time.Time            `json:"created_at"`
	StorePath           string               `json:"store_path"`
	Kind                string               `json:"kind"`
	Report              Report               `json:"report"`
	RawPayloadSet       bool                 `json:"raw_payload_set,omitempty"`
	NoTmux              bool                 `json:"no_tmux,omitempty"`
	Runtime             RuntimeContext       `json:"runtime"`
	Attempt             int                  `json:"attempt,omitempty"`
	NextAttemptAt       time.Time            `json:"next_attempt_at,omitzero"`
	ProcessingStartedAt time.Time            `json:"processing_started_at,omitzero"`
	WorkerPID           int                  `json:"worker_pid,omitempty"`
	LastError           string               `json:"last_error,omitempty"`
	CachedTmux          registry.TmuxContext `json:"cached_tmux,omitzero"`
}

type PermanentError struct {
	Err error
}

type Processor func(context.Context, Envelope) error

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

type Report = registry.Observation

type RuntimeContext struct {
	CWD        string            `json:"cwd,omitempty"`
	ParentArgs []string          `json:"parent_args,omitempty"`
	Env        map[string]string `json:"env,omitempty"`
}

type StatusResult struct {
	Root               string    `json:"root"`
	Pending            int       `json:"pending"`
	Ready              int       `json:"ready"`
	Deferred           int       `json:"deferred"`
	Processing         int       `json:"processing"`
	StaleLeases        int       `json:"stale_leases"`
	Retries            int       `json:"retries"`
	NextRetryAt        time.Time `json:"next_retry_at,omitzero"`
	Dead               int       `json:"dead"`
	Invalid            int       `json:"invalid"`
	OldestPendingAt    time.Time `json:"oldest_pending_at,omitzero"`
	OldestProcessingAt time.Time `json:"oldest_processing_at,omitzero"`
	OldestBacklogAt    time.Time `json:"oldest_backlog_at,omitzero"`
	OldestDeadAt       time.Time `json:"oldest_dead_at,omitzero"`
}