gccontroller

type Controller ¶

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

func NewController(ctx context.Context, wfClientset wfclientset.Interface, wfInformer cache.SharedIndexInformer, metrics *metrics.Metrics, retentionPolicy *config.RetentionPolicy) *Controller

func (c *Controller) Run(ctx context.Context, workflowGCWorkers int) error

type Heap ¶ added in v4.1.0

type Heap interface {
	Len() int
	Less(i, j int) bool
	Swap(i, j int)
	Push(x any)
	Pop() any
}

Heap is the interface for a GC heap (implements heap.Interface)

func NewHeap() Heap