status

Mar 13, 2023

Changes in this version

+ type Health struct

+ func NewHealthHandler(sr map[string]Checker, log *zap.Logger, usc int) *Health

+ func (rd *Health) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type Jobs struct

+ func NewJobsHandler(jc JobsChecker, log *zap.Logger, usc int) *Jobs

+ func (jb *Jobs) ServeHTTP(w http.ResponseWriter, _ *http.Request)

+ type JobsChecker interface

+ JobsState func(ctx context.Context) ([]*jobsApi.State, error)

+ Name func() string

+ type Ready struct

+ func NewReadyHandler(sr map[string]Readiness, log *zap.Logger, usc int) *Ready

+ func (rd *Ready) ServeHTTP(w http.ResponseWriter, r *http.Request)

Jan 9, 2023

Changes in this version

+ const PluginName

+ type Checker interface

+ Name func() string

+ Status func() (*status.Status, error)

+ type Config struct

+ Address string

+ UnavailableStatusCode int

+ func (c *Config) InitDefaults()

+ type Configurer interface

+ Has func(name string) bool

+ UnmarshalKey func(name string, out any) error

+ type Logger interface

+ NamedLogger func(name string) *zap.Logger

+ type Plugin struct

+ func (c *Plugin) Collects() []*dep.In

+ func (c *Plugin) Init(cfg Configurer, log Logger) error

+ func (c *Plugin) Name() string

+ func (c *Plugin) RPC() any

+ func (c *Plugin) Serve() chan error

+ func (c *Plugin) Stop(context.Context) error

+ type Plugins struct

+ Plugins []string

+ type Readiness interface

+ Name func() string

+ Ready func() (*status.Status, error)