probes

Documentation

Index

• Variables
• func PGWithCA(ca []byte) func(*pgxpool.Config) error
• type Manager
  • func NewManager(l logr.Logger) Manager
  • func (m Manager) Collector() prometheus.Collector
  • func (m Manager) StartProbe(p Prober)
  • func (m Manager) StopProbe(pi ProbeInfo)
• type PostgreSQL
  • func NewFailingPostgreSQL(service, name, namespace string) (*PostgreSQL, error)
  • func NewPostgreSQL(service, name, namespace, dsn, organization, sla string, ha bool, ...) (*PostgreSQL, error)
  • func (p PostgreSQL) Close() error
  • func (p PostgreSQL) GetInfo() ProbeInfo
  • func (p PostgreSQL) Probe(ctx context.Context) error
• type ProbeInfo
  • func NewProbeInfo(serviceKey string, nn types.NamespacedName, o client.Object) ProbeInfo
• type Prober
• type VSHNMinio
  • func NewMinio(service, name, namespace, organization, sla, endpointURL string, ha bool, ...) (*VSHNMinio, error)
  • func (minio VSHNMinio) Close() error
  • func (minio VSHNMinio) GetInfo() ProbeInfo
  • func (minio VSHNMinio) Probe(ctx context.Context) error
• type VSHNRedis
  • func NewRedis(service, name, namespace, organization, sla string, ha bool, ...) (*VSHNRedis, error)
  • func (redis VSHNRedis) Close() error
  • func (redis VSHNRedis) GetInfo() ProbeInfo
  • func (redis VSHNRedis) Probe(ctx context.Context) error

Variables

var ErrTimeout = errors.New("probe timed out")

Functions

func PGWithCA

func PGWithCA(ca []byte) func(*pgxpool.Config) error

PGWithCA adds the provided CA to the rootCAs of the pgxpool.

Types

type Manager

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

Manager manages a collection of Probers the check connectivity to AppCat services.

func NewManager

func NewManager(l logr.Logger) Manager

func (Manager) Collector

func (m Manager) Collector() prometheus.Collector

Collector returns the histogram to store the probe results

func (Manager) StartProbe

func (m Manager) StartProbe(p Prober)

StartProbe will send a probe once every second using the provided prober. If a prober with the same ProbeInfo already runs, it will stop the running prober.

func (Manager) StopProbe

func (m Manager) StopProbe(pi ProbeInfo)

StopProbe will stop the prober with the provided ProbeInfo. Is a Noop if none is running.

type PostgreSQL

type PostgreSQL struct {
	Service       string
	Name          string
	Namespace     string
	Organization  string
	HighAvailable bool
	ServiceLevel  string
	// contains filtered or unexported fields
}

PostgreSQL is a prober to test the uptime of a PostgreSQL instance.

func NewFailingPostgreSQL

func NewFailingPostgreSQL(service, name, namespace string) (*PostgreSQL, error)

NewFailingPostgreSQL creates a prober that will fail. Can be used if the controller can't access valid credentials.

func NewPostgreSQL

func NewPostgreSQL(service, name, namespace, dsn, organization, sla string, ha bool, ops ...func(*pgxpool.Config) error) (*PostgreSQL, error)

NewPostgreSQL connects to the provided dsn and returns a prober

func (PostgreSQL) Close

func (p PostgreSQL) Close() error

Close closes open connections to the PostgreSQL server.

func (PostgreSQL) GetInfo

func (p PostgreSQL) GetInfo() ProbeInfo

GetInfo returns the prober infos

func (PostgreSQL) Probe

func (p PostgreSQL) Probe(ctx context.Context) error

Probe sends a test query to the configured PostgreSQL server. Will return an error if the prober does not have a valid db connection.

type ProbeInfo

type ProbeInfo struct {
	Service       string
	Name          string
	Namespace     string
	Organization  string
	HighAvailable bool
	ServiceLevel  string
}

ProbeInfo contains meta information on a prober and in turn an AppCat service

func NewProbeInfo

func NewProbeInfo(serviceKey string, nn types.NamespacedName, o client.Object) ProbeInfo

type Prober

type Prober interface {
	GetInfo() ProbeInfo
	Probe(ctx context.Context) error
	Close() error
}

Prober checks the connectivity to an AppCat service

type VSHNMinio

type VSHNMinio struct {
	Service       string
	Name          string
	Namespace     string
	HighAvailable bool
	Organization  string
	ServiceLevel  string
	// contains filtered or unexported fields
}

func NewMinio

func NewMinio(service, name, namespace, organization, sla, endpointURL string, ha bool, opts miniolib.Options) (*VSHNMinio, error)

func (VSHNMinio) Close

func (minio VSHNMinio) Close() error

func (VSHNMinio) GetInfo

func (minio VSHNMinio) GetInfo() ProbeInfo

func (VSHNMinio) Probe

func (minio VSHNMinio) Probe(ctx context.Context) error

type VSHNRedis

type VSHNRedis struct {
	Service       string
	Name          string
	Namespace     string
	HighAvailable bool
	Organization  string
	ServiceLevel  string
	// contains filtered or unexported fields
}

func NewRedis

func NewRedis(service, name, namespace, organization, sla string, ha bool, opts redis.Options) (*VSHNRedis, error)

func (VSHNRedis) Close

func (redis VSHNRedis) Close() error

func (VSHNRedis) GetInfo

func (redis VSHNRedis) GetInfo() ProbeInfo

func (VSHNRedis) Probe

func (redis VSHNRedis) Probe(ctx context.Context) error