worker

package
v0.0.0-...-750f79a Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 19, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BindingWorker

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

func NewBindingWorker

func NewBindingWorker(km KindManager) *BindingWorker

func (*BindingWorker) Process

func (b *BindingWorker) Process(binding *v1alpha1.Binding, log log.FieldLogger) (*v1alpha1.Binding, error)

func (*BindingWorker) RemoveProcess

func (b *BindingWorker) RemoveProcess(binding *v1alpha1.Binding, log log.FieldLogger) (*v1alpha1.Binding, error)

type KindManager

type KindManager interface {
	AddLabel(*v1alpha1.Binding) error
	RemoveLabel(*v1alpha1.Binding) error
	LabelExist(*v1alpha1.Binding) (bool, error)
	RemoveOldAddNewLabel(*v1alpha1.Binding) error
}

type TargetKindStorage

type TargetKindStorage interface {
	Register(tk v1alpha1.TargetKind) error
	Unregister(tk v1alpha1.TargetKind) error
	Get(kind v1alpha1.Kind) (*storage.ResourceData, error)
	Exist(kind v1alpha1.TargetKind) bool
	Equal(tk v1alpha1.TargetKind, registeredTk *storage.ResourceData) bool
}

type TargetKindWorker

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

func NewTargetKindWorker

func NewTargetKindWorker(storage TargetKindStorage, dynamicClient dynamic.Interface) *TargetKindWorker

func (*TargetKindWorker) Process

func (w *TargetKindWorker) Process(targetKind *v1alpha1.TargetKind, log log.FieldLogger) (*v1alpha1.TargetKind, error)

func (*TargetKindWorker) RemoveProcess

func (w *TargetKindWorker) RemoveProcess(targetKind *v1alpha1.TargetKind, log log.FieldLogger) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL