elimination

Documentation

Index

• func TrackUntilEliminated(ctx context.Context, kubeDynamicClient dynamic.Interface, ...) error
• type EliminationTracker
  • func NewEliminationTracker(kubeDynamicClient dynamic.Interface, spec *EliminationTrackerSpec) *EliminationTracker
  • func (tracker *EliminationTracker) Track(ctx context.Context, opts EliminationTrackerOptions) error
• type EliminationTrackerOptions
• type EliminationTrackerSpec
  • func (spec *EliminationTrackerSpec) String() string
• type ResourceStatus

Functions

func TrackUntilEliminated

func TrackUntilEliminated(ctx context.Context, kubeDynamicClient dynamic.Interface, specs []*EliminationTrackerSpec, opts EliminationTrackerOptions) error

Types

type EliminationTracker

type EliminationTracker struct {
	KubeDynamicClient dynamic.Interface
	Spec              *EliminationTrackerSpec

	ResourceStatus chan ResourceStatus
}

func NewEliminationTracker

func NewEliminationTracker(kubeDynamicClient dynamic.Interface, spec *EliminationTrackerSpec) *EliminationTracker

func (*EliminationTracker) Track

func (tracker *EliminationTracker) Track(ctx context.Context, opts EliminationTrackerOptions) error

type EliminationTrackerOptions

type EliminationTrackerOptions struct {
	Timeout              time.Duration
	StatusProgressPeriod time.Duration
}

type EliminationTrackerSpec

type EliminationTrackerSpec struct {
	ResourceName         string
	Namespace            string
	GroupVersionResource schema.GroupVersionResource
}

func (*EliminationTrackerSpec) String

func (spec *EliminationTrackerSpec) String() string

type ResourceStatus

type ResourceStatus struct {
	Spec         *EliminationTrackerSpec
	ManifestJson []byte
}