controller_worker

Documentation

Index

• type ControllerWorker
• type V1ControllerWorker
  • func NewV1ControllerWorker(scaleTargetRef *types.ScaleTargetRef, logger logr.Logger, client client.Client, ...) *V1ControllerWorker
  • func (cw *V1ControllerWorker) Close()
  • func (cw V1ControllerWorker) Run(ctx context.Context, updateInterval time.Duration) (<-chan interface{}, <-chan error)

Types

type ControllerWorker

type ControllerWorker interface {
	Run(ctx context.Context, updateInterval time.Duration) <-chan interface{}
	Close()
}

type V1ControllerWorker

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

func NewV1ControllerWorker

func NewV1ControllerWorker(scaleTargetRef *types.ScaleTargetRef, logger logr.Logger,
	client client.Client, provider pb.ProviderServiceClient, reqNamespace string) *V1ControllerWorker

func (*V1ControllerWorker) Close

func (cw *V1ControllerWorker) Close()

func (V1ControllerWorker) Run

func (cw V1ControllerWorker) Run(ctx context.Context, updateInterval time.Duration) (<-chan interface{}, <-chan error)