workers

Documentation

Index

• type Consumer
  • func NewConsumer(region string, endpointURL string, selfNamespace string, ...) (*Consumer, error)
  • func (c *Consumer) Run()
• type Reconciler
  • func NewReconciler(kubeClientSet kubernetes.Interface, customClientSet clientset.Interface, ...) *Reconciler
  • func (r *Reconciler) Run()

Types

type Consumer

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

Consumer is

func NewConsumer

func NewConsumer(
	region string,
	endpointURL string,
	selfNamespace string,
	cli kubernetes.Interface,
	lister listers.AWSSQSWorkerJobLister,
	wq workqueue.RateLimitingInterface,
	rec record.EventRecorder,
) (*Consumer, error)

NewConsumer is

func (*Consumer) Run

func (c *Consumer) Run()

Run is

type Reconciler

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

Reconciler is

func NewReconciler

func NewReconciler(
	kubeClientSet kubernetes.Interface,
	customClientSet clientset.Interface,
	jobLister batchlisters.JobLister,
	customResourceLister listers.AWSSQSWorkerJobLister,
	workQueue workqueue.RateLimitingInterface,
	recorder record.EventRecorder,
) *Reconciler

NewReconciler is

func (*Reconciler) Run

func (r *Reconciler) Run()

Run is