membergarbagecollector

Documentation

Index

• func RunMemberGarbageCollectorPeriodically(ctx context.Context, hconfig *brtypes.HealthConfig, logger *logrus.Entry, ...)
• type MGCChecker
• type MemberGarbageCollector
  • func NewMemberGarbageCollector(logger *logrus.Entry, clientSet client.Client, etcdTimeout wrappers.Duration) (*MemberGarbageCollector, error)
  • func (mgc *MemberGarbageCollector) RemoveSuperfluousMembers(ctx context.Context, etcdCluster etcdclient.ClusterCloser) error

Functions

func RunMemberGarbageCollectorPeriodically

func RunMemberGarbageCollectorPeriodically(ctx context.Context, hconfig *brtypes.HealthConfig, logger *logrus.Entry, etcdConfig *brtypes.EtcdConnectionConfig)

RunMemberGarbageCollectorPeriodically periodically calls the member garbage collector

Types

type MGCChecker

type MGCChecker interface {
	RemoveSuperfluousMembers(ctx context.Context) error
}

MGCChecker garbage collects the members from the etcd cluster if its corresponding pod is not present. Used by Gomock to generate mock functions

type MemberGarbageCollector

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

MemberGarbageCollector contains information to regularly cleanup superfluous ETCD members

func NewMemberGarbageCollector

func NewMemberGarbageCollector(logger *logrus.Entry, clientSet client.Client, etcdTimeout wrappers.Duration) (*MemberGarbageCollector, error)

NewMemberGarbageCollector returns the member garbage collect object

func (*MemberGarbageCollector) RemoveSuperfluousMembers

func (mgc *MemberGarbageCollector) RemoveSuperfluousMembers(ctx context.Context, etcdCluster etcdclient.ClusterCloser) error

RemoveSuperfluousMembers removes a member from the etcd cluster if its corresponding pod is not present