healthcheck

Documentation

Index

• func CustomWorkloadHealthcheck(ctx context.Context, timeout time.Duration, definition string) error
• func EasyCustomWorkloadHealthcheck(ctx context.Context, timeout time.Duration, namespace string, ...) error
• func MicroShiftHealthcheck(ctx context.Context, timeout time.Duration) error
• type AllErrGroup
  • func (g *AllErrGroup) Go(f func() error)
  • func (g *AllErrGroup) Wait() error
• type NamespaceWorkloads
• type Systemd
  • func NewSystemd(ctx context.Context) (*Systemd, error)
  • func (s *Systemd) Close()
  • func (s *Systemd) IsServiceActiveAndNotFailed(ctx context.Context, service string) (bool, error)
  • func (s *Systemd) IsServiceEnabled(ctx context.Context, service string) (bool, error)

Functions

func CustomWorkloadHealthcheck

func CustomWorkloadHealthcheck(ctx context.Context, timeout time.Duration, definition string) error

func EasyCustomWorkloadHealthcheck

func EasyCustomWorkloadHealthcheck(ctx context.Context, timeout time.Duration, namespace string, deployments, daemonsets, statefulsets []string) error

func MicroShiftHealthcheck

func MicroShiftHealthcheck(ctx context.Context, timeout time.Duration) error

Types

type AllErrGroup

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

AllErrGroup is a helper to wait for all goroutines and get all errors that occurred. It's based on sync.WaitGroup (which doesn't capture any errors) and errgroup.Group (which only captures the first error).

func (*AllErrGroup) Go

func (g *AllErrGroup) Go(f func() error)

func (*AllErrGroup) Wait

func (g *AllErrGroup) Wait() error

type NamespaceWorkloads

type NamespaceWorkloads struct {
	Deployments  []string `json:"deployments"`
	DaemonSets   []string `json:"daemonsets"`
	StatefulSets []string `json:"statefulsets"`
}

type Systemd

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

func NewSystemd

func NewSystemd(ctx context.Context) (*Systemd, error)

func (*Systemd) Close

func (s *Systemd) Close()

func (*Systemd) IsServiceActiveAndNotFailed

func (s *Systemd) IsServiceActiveAndNotFailed(ctx context.Context, service string) (bool, error)

func (*Systemd) IsServiceEnabled

func (s *Systemd) IsServiceEnabled(ctx context.Context, service string) (bool, error)