health

Documentation

Index

• func Heartbeat(ctx context.Context, tick <-chan time.Time, listenAddr string, ...)
• func NewEnvironmentHealthTracker(ctx context.Context, envs []string, s streamStatuser, t time.Duration) func() []domain.EnvironmentHealth
• func StreamHealthCheck() error
• type EnvironmentHealthTracker
  • func (e EnvironmentHealthTracker) GetEnvHealth() []domain.EnvironmentHealth

Functions

func Heartbeat

func Heartbeat(ctx context.Context, tick <-chan time.Time, listenAddr string, logger log.StructuredLogger)

Heartbeat kicks off a goroutine that polls the /health endpoint at intervals determined by how frequently events are sent on the tick channel.

func NewEnvironmentHealthTracker

func NewEnvironmentHealthTracker(ctx context.Context, envs []string, s streamStatuser, t time.Duration) func() []domain.EnvironmentHealth

NewEnvironmentHealthTracker creates an EnvironmentHealthTracker

func StreamHealthCheck

func StreamHealthCheck() error

StreamHealthCheck checks if the GripControl stream is available - this is required to enable streaming mode

Types

type EnvironmentHealthTracker

type EnvironmentHealthTracker struct {
	*sync.RWMutex
	// contains filtered or unexported fields
}

EnvironmentHealthTracker tracks the health of environments

func (EnvironmentHealthTracker) GetEnvHealth

func (e EnvironmentHealthTracker) GetEnvHealth() []domain.EnvironmentHealth

GetEnvHealth is a function that checks the health of all connected environments