status

Documentation

Index

• Variables
• type Checker
  • func NewChecker(cl client.Client, ...) *Checker
  • func (c *Checker) Check(ctx context.Context, logger logr.Logger, etcd *druidv1alpha1.Etcd) error
• type ConditionCheckFn
• type EtcdMemberCheckFn

Variables

var (
	// NewDefaultConditionBuilder is the default condition builder.
	NewDefaultConditionBuilder = condition.NewBuilder
	// NewDefaultEtcdMemberBuilder is the default etcd member builder.
	NewDefaultEtcdMemberBuilder = etcdmember.NewBuilder
	// ConditionChecks Checks are the registered condition checks.
	ConditionChecks = []ConditionCheckFn{
		condition.AllMembersReadyCheck,
		condition.ReadyCheck,
		condition.BackupReadyCheck,
		condition.DataVolumesReadyCheck,
	}
	// EtcdMemberChecks are the etcd member checks.
	EtcdMemberChecks = []EtcdMemberCheckFn{
		etcdmember.ReadyCheck,
	}
)

var TimeNow = time.Now

TimeNow is the function used to get the current time.

Types

type Checker

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

Checker checks Etcd status conditions and the status of the Etcd members.

func NewChecker

func NewChecker(cl client.Client, etcdMemberNotReadyThreshold, etcdMemberUnknownThreshold time.Duration) *Checker

NewChecker creates a new instance for checking the etcd status.

func (*Checker) Check

func (c *Checker) Check(ctx context.Context, logger logr.Logger, etcd *druidv1alpha1.Etcd) error

Check executes the status checks and mutates the passed status object with the corresponding results.

type ConditionCheckFn

type ConditionCheckFn func(client.Client) condition.Checker

ConditionCheckFn is a type alias for a function which returns an implementation of `Check`.

type EtcdMemberCheckFn

type EtcdMemberCheckFn func(client.Client, logr.Logger, time.Duration, time.Duration) etcdmember.Checker

EtcdMemberCheckFn is a type alias for a function which returns an implementation of `Check`.