gcmanager

README

Spiderpool IP garbage collection

Notice

• Current Tracing mechanism will not trace 'Terminating' time out pod if it's a StatefulSet pod, and the StatefulSet object was deleted or decreased its replicas.

Documentation

Index

• type GCManager
  • func NewGCManager(ctx context.Context, clientSet *kubernetes.Clientset, ...) (GCManager, error)
• type GarbageCollectionConfig
• type PodDBer
  • func NewPodDBer(maxDatabaseCap int) PodDBer
• type PodDatabase
  • func (p *PodDatabase) ApplyPodEntry(podEntry *PodEntry) error
  • func (p *PodDatabase) DeletePodEntry(namespace, podName string)
  • func (p *PodDatabase) ListAllPodEntries() []PodEntry
• type PodEntry
• type SpiderGC
  • func (s *SpiderGC) GetPodDatabase() PodDBer
  • func (s *SpiderGC) Health()
  • func (s *SpiderGC) Start(ctx context.Context) error
  • func (s *SpiderGC) TriggerGCAll()

Types

type GCManager

type GCManager interface {
	Start(ctx context.Context) error

	GetPodDatabase() PodDBer

	TriggerGCAll()

	Health()
}

func NewGCManager

func NewGCManager(ctx context.Context, clientSet *kubernetes.Clientset, config *GarbageCollectionConfig,
	wepManager workloadendpointmanager.WorkloadEndpointManager,
	ippoolManager ippoolmanager.IPPoolManager,
	podManager podmanager.PodManager,
	stsManager statefulsetmanager.StatefulSetManager,
	spiderControllerLeader election.SpiderLeaseElector) (GCManager, error)

type GarbageCollectionConfig

type GarbageCollectionConfig struct {
	EnableGCIP                bool
	EnableGCForTerminatingPod bool
	EnableStatefulSet         bool

	ReleaseIPWorkerNum     int
	GCIPChannelBuffer      int
	MaxPodEntryDatabaseCap int

	DefaultGCIntervalDuration int
	TracePodGapDuration       int
	GCSignalTimeoutDuration   int
	GCSignalGapDuration       int
	AdditionalGraceDelay      int
}

type PodDBer

type PodDBer interface {
	DeletePodEntry(namespace, podName string)
	ApplyPodEntry(podEntry *PodEntry) error
	ListAllPodEntries() []PodEntry
}

func NewPodDBer

func NewPodDBer(maxDatabaseCap int) PodDBer

type PodDatabase

type PodDatabase struct {
	lock.RWMutex
	// contains filtered or unexported fields
}

PodDatabase represents controller PodEntry database

func (*PodDatabase) ApplyPodEntry

func (p *PodDatabase) ApplyPodEntry(podEntry *PodEntry) error

func (*PodDatabase) DeletePodEntry

func (p *PodDatabase) DeletePodEntry(namespace, podName string)

func (*PodDatabase) ListAllPodEntries

func (p *PodDatabase) ListAllPodEntries() []PodEntry

type PodEntry

type PodEntry struct {
	PodName   string
	Namespace string
	NodeName  string

	EntryUpdateTime time.Time

	TracingStartTime    time.Time
	TracingGracefulTime time.Duration
	TracingStopTime     time.Time

	PodTracingReason types.PodStatus
}

PodEntry represents a pod cache

type SpiderGC

type SpiderGC struct {
	PodDB PodDBer
	// contains filtered or unexported fields
}

func (*SpiderGC) GetPodDatabase

func (s *SpiderGC) GetPodDatabase() PodDBer

func (*SpiderGC) Health

func (s *SpiderGC) Health()

func (*SpiderGC) Start

func (s *SpiderGC) Start(ctx context.Context) error

func (*SpiderGC) TriggerGCAll

func (s *SpiderGC) TriggerGCAll()