highavailability

Documentation

Index

• Constants
• func IsHAAvailable(characterType, workloadType string) bool
• type Ha
  • func GetHa() *Ha
  • func NewHa(disableDNSChecker bool) *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) RunCycle()
  • func (ha *Ha) ShutdownWithWait()
  • func (ha *Ha) Start()

Constants

const (
	WorkloadTypeKey = "workloadType"
	Replication     = "Replication"
	Consensus       = "Consensus"
)

Functions

func IsHAAvailable

func IsHAAvailable(characterType, workloadType string) bool

Types

type Ha

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

func GetHa

func GetHa() *Ha

func NewHa

func NewHa(disableDNSChecker bool) *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) RunCycle

func (ha *Ha) RunCycle()

func (*Ha) ShutdownWithWait

func (ha *Ha) ShutdownWithWait()

func (*Ha) Start

func (ha *Ha) Start()