worker

Documentation

Index

• type BindingWorker
  • func NewBindingWorker(km KindManager) *BindingWorker
  • func (b *BindingWorker) Process(binding *v1alpha1.Binding, log log.FieldLogger) (*v1alpha1.Binding, error)
  • func (b *BindingWorker) RemoveProcess(binding *v1alpha1.Binding, log log.FieldLogger) (*v1alpha1.Binding, error)
• type KindManager
• type TargetKindStorage
• type TargetKindWorker
  • func NewTargetKindWorker(storage TargetKindStorage, dynamicClient dynamic.Interface) *TargetKindWorker
  • func (w *TargetKindWorker) Process(targetKind *v1alpha1.TargetKind, log log.FieldLogger) (*v1alpha1.TargetKind, error)
  • func (w *TargetKindWorker) RemoveProcess(targetKind *v1alpha1.TargetKind, log log.FieldLogger) error

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