thirdcomponent

Documentation

Index

• type DiscoverPool
  • func NewDiscoverPool(ctx context.Context, reconciler *Reconciler, recorder record.EventRecorder) *DiscoverPool
  • func (d *DiscoverPool) AddDiscover(dis dis.Discover)
  • func (d *DiscoverPool) GetSize() float64
  • func (d *DiscoverPool) RemoveDiscover(component *v1alpha1.ThirdComponent)
  • func (d *DiscoverPool) RemoveDiscoverByName(req types.NamespacedName)
  • func (d *DiscoverPool) Start()
• type Reconciler
  • func Setup(ctx context.Context, mgr ctrl.Manager) (*Reconciler, error)
  • func (r *Reconciler) Collect(ch chan<- prometheus.Metric)
  • func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (res reconcile.Result, retErr error)
  • func (r *Reconciler) SetupWithManager(mgr ctrl.Manager) error
• type Worker
  • func (w *Worker) IsStop() bool
  • func (w *Worker) Start()
  • func (w *Worker) Stop()
  • func (w *Worker) UpdateDiscover(discover dis.Discover)

Types

type DiscoverPool

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

DiscoverPool -

func NewDiscoverPool

func NewDiscoverPool(ctx context.Context,
	reconciler *Reconciler,
	recorder record.EventRecorder) *DiscoverPool

NewDiscoverPool -

func (*DiscoverPool) AddDiscover

func (d *DiscoverPool) AddDiscover(dis dis.Discover)

AddDiscover -

func (*DiscoverPool) GetSize

func (d *DiscoverPool) GetSize() float64

GetSize -

func (*DiscoverPool) RemoveDiscover

func (d *DiscoverPool) RemoveDiscover(component *v1alpha1.ThirdComponent)

RemoveDiscover -

func (*DiscoverPool) RemoveDiscoverByName

func (d *DiscoverPool) RemoveDiscoverByName(req types.NamespacedName)

RemoveDiscoverByName -

func (*DiscoverPool) Start

func (d *DiscoverPool) Start()

Start -

type Reconciler

type Reconciler struct {
	Client client.Client

	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

Reconciler -

func Setup

func Setup(ctx context.Context, mgr ctrl.Manager) (*Reconciler, error)

Setup adds a controller that reconciles AppDeployment.

func (*Reconciler) Collect

func (r *Reconciler) Collect(ch chan<- prometheus.Metric)

Collect -

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (res reconcile.Result, retErr error)

Reconcile is the main logic of appDeployment controller

func (*Reconciler) SetupWithManager

func (r *Reconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager setup the controller with manager

type Worker

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

Worker -

func (*Worker) IsStop

func (w *Worker) IsStop() bool

IsStop -

func (*Worker) Start

func (w *Worker) Start()

Start -

func (*Worker) Stop

func (w *Worker) Stop()

Stop -

func (*Worker) UpdateDiscover

func (w *Worker) UpdateDiscover(discover dis.Discover)

UpdateDiscover -