status

type Checker interface {
	Status() (*status.Status, error)
	Name() string
}

type Config struct {
	// Address of the http server
	Address string
	// Time to wait for a health check response.
	CheckTimeout int `mapstructure:"check_timeout"`
	// Status code returned in case of fail, 503 by default
	UnavailableStatusCode int `mapstructure:"unavailable_status_code"`
}

type Configurer interface {
	// UnmarshalKey takes a single key and unmarshal it into a Struct.
	UnmarshalKey(name string, out any) error
	// Has checks if a config section exists.
	Has(name string) bool
}

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

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

type JobsChecker interface {
	JobsState(ctx context.Context) ([]*jobsApi.State, error)
	Name() string
}

type JobsReport struct {
	Pipeline     string `json:"pipeline"`
	Priority     uint64 `json:"priority"`
	Ready        bool   `json:"ready"`
	Queue        string `json:"queue"`
	Active       int64  `json:"active"`
	Delayed      int64  `json:"delayed"`
	Reserved     int64  `json:"reserved"`
	Driver       string `json:"driver"`
	ErrorMessage string `json:"error_message"`
}

type Logger interface {
	NamedLogger(name string) *zap.Logger
}

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

type Readiness interface {
	Ready() (*status.Status, error)
	Name() string
}

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

type Report struct {
	PluginName   string `json:"plugin_name"`
	ErrorMessage string `json:"error_message"`
	StatusCode   int    `json:"status_code"`
}