highavailability

Documentation

Index

• type Ha
  • func GetHa() *Ha
  • func NewHa(logger logr.Logger) *Ha
  • func (ha *Ha) DecreaseClusterReplicas(cluster *dcs3.Cluster)
  • func (ha *Ha) DeleteCurrentMember(ctx context.Context, cluster *dcs3.Cluster) error
  • func (ha *Ha) HasOtherHealthyMember(cluster *dcs3.Cluster) bool
  • func (ha *Ha) IsHealthiestMember(ctx context.Context, cluster *dcs3.Cluster) bool
  • func (ha *Ha) IsPodReady() (bool, error)
  • func (ha *Ha) RunCycle()
  • func (ha *Ha) ShutdownWithWait()
  • func (ha *Ha) Start()

Types

type Ha

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

func GetHa

func GetHa() *Ha

func NewHa

func NewHa(logger logr.Logger) *Ha

func (*Ha) DecreaseClusterReplicas

func (ha *Ha) DecreaseClusterReplicas(cluster *dcs3.Cluster)

func (*Ha) DeleteCurrentMember

func (ha *Ha) DeleteCurrentMember(ctx context.Context, cluster *dcs3.Cluster) error

func (*Ha) HasOtherHealthyMember

func (ha *Ha) HasOtherHealthyMember(cluster *dcs3.Cluster) bool

func (*Ha) IsHealthiestMember

func (ha *Ha) IsHealthiestMember(ctx context.Context, cluster *dcs3.Cluster) bool

func (*Ha) IsPodReady

func (ha *Ha) IsPodReady() (bool, error)

IsPodReady checks if pod is ready, it can successfully resolve domain

func (*Ha) RunCycle

func (ha *Ha) RunCycle()

func (*Ha) ShutdownWithWait

func (ha *Ha) ShutdownWithWait()

func (*Ha) Start

func (ha *Ha) Start()