highavailability

Documentation

Index

• type Ha
  • func NewHa(logger logger.Logger) *Ha
  • func (ha *Ha) DecreaseClusterReplicas(cluster *dcs.Cluster)
  • func (ha *Ha) IsHealthiestMember(ctx context.Context, cluster *dcs.Cluster) bool
  • func (ha *Ha) RunCycle()
  • func (ha *Ha) ShutdownWithWait()
  • func (ha *Ha) Start()

Types

type Ha

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

func NewHa

func NewHa(logger logger.Logger) *Ha

func (*Ha) DecreaseClusterReplicas

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

func (*Ha) IsHealthiestMember

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

func (*Ha) RunCycle

func (ha *Ha) RunCycle()

func (*Ha) ShutdownWithWait

func (ha *Ha) ShutdownWithWait()

func (*Ha) Start

func (ha *Ha) Start()