health

Documentation

Index

• Variables
• func HealthyMariaDBReplica(ctx context.Context, client client.Client, mariadb *mariadbv1alpha1.MariaDB) (*int, error)
• func HealthyMaxScalePod(ctx context.Context, client client.Client, maxscale *mariadbv1alpha1.MaxScale) (*int, error)
• func IsServiceHealthy(ctx context.Context, client client.Client, serviceKey types.NamespacedName) (bool, error)
• func IsStatefulSetHealthy(ctx context.Context, client ctrlclient.Client, key types.NamespacedName, ...) (bool, error)
• type EndpointPolicy
• type HealthOpt
  • func WithDesiredReplicas(r int32) HealthOpt
  • func WithEndpointPolicy(e EndpointPolicy) HealthOpt
  • func WithPort(p int32) HealthOpt
• type HealthOpts

Variables

var ErrNoHealthyInstancesAvailable = errors.New("no healthy instances available")

Functions

func HealthyMariaDBReplica

func HealthyMariaDBReplica(ctx context.Context, client client.Client, mariadb *mariadbv1alpha1.MariaDB) (*int, error)

func HealthyMaxScalePod

func HealthyMaxScalePod(ctx context.Context, client client.Client, maxscale *mariadbv1alpha1.MaxScale) (*int, error)

func IsServiceHealthy

func IsServiceHealthy(ctx context.Context, client client.Client, serviceKey types.NamespacedName) (bool, error)

func IsStatefulSetHealthy

func IsStatefulSetHealthy(ctx context.Context, client ctrlclient.Client, key types.NamespacedName,
	opts ...HealthOpt) (bool, error)

Types

type EndpointPolicy

type EndpointPolicy string

const (
	EndpointPolicyAll        EndpointPolicy = "All"
	EndpointPolicyAtLeastOne EndpointPolicy = "AtLeastOne"
)

type HealthOpt

type HealthOpt func(*HealthOpts)

func WithDesiredReplicas

func WithDesiredReplicas(r int32) HealthOpt

func WithEndpointPolicy

func WithEndpointPolicy(e EndpointPolicy) HealthOpt

func WithPort

func WithPort(p int32) HealthOpt

type HealthOpts

type HealthOpts struct {
	DesiredReplicas int32
	Port            *int32
	EndpointPolicy  *EndpointPolicy
}