resourcecomponent

Documentation

Index

• type ComponentsDiscoverTask
  • func NewComponentsDiscoverTask(logger log.Logger, mc model.ClientSet) (in *ComponentsDiscoverTask, err error)
  • func (in *ComponentsDiscoverTask) Process(ctx context.Context, args ...any) error
• type LabelApplyTask
  • func NewLabelApplyTask(logger log.Logger, mc model.ClientSet) (in *LabelApplyTask, err error)
  • func (in *LabelApplyTask) Process(ctx context.Context, args ...any) error
• type StatusSyncTask
  • func NewStatusSyncTask(logger log.Logger, mc model.ClientSet) (in *StatusSyncTask, err error)
  • func (in *StatusSyncTask) Process(ctx context.Context, args ...any) error

Types

type ComponentsDiscoverTask

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

func NewComponentsDiscoverTask

func NewComponentsDiscoverTask(logger log.Logger, mc model.ClientSet) (in *ComponentsDiscoverTask, err error)

func (*ComponentsDiscoverTask) Process

func (in *ComponentsDiscoverTask) Process(ctx context.Context, args ...any) error

Process implements the Task interface, it will discover the components of managed instance resources.

Process fetches all connectors at first, and constructs the operator related to each connector. Then it will query the resources belong to each connector, and process the resources in batches concurrently according to the operator burst size.

type LabelApplyTask

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

func NewLabelApplyTask

func NewLabelApplyTask(logger log.Logger, mc model.ClientSet) (in *LabelApplyTask, err error)

func (*LabelApplyTask) Process

func (in *LabelApplyTask) Process(ctx context.Context, args ...any) error

Process implements the Task interface, it will label managed instance resources.

Process fetches all connectors at first, and constructs the operator related to each connector. Then it will query the resources belong to each connector, and process the resources in batches concurrently according to the operator burst size.

type StatusSyncTask

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

func NewStatusSyncTask

func NewStatusSyncTask(logger log.Logger, mc model.ClientSet) (in *StatusSyncTask, err error)

func (*StatusSyncTask) Process

func (in *StatusSyncTask) Process(ctx context.Context, args ...any) error