syncer

Documentation

Index

• type Controller
  • func New(remoteEnvironmentInformer informers.RemoteEnvironmentInformer, ...) *Controller
  • func (c *Controller) Run(stopCh <-chan struct{})
• type RelistRequester
  • func NewRelistRequester(serviceCatalogSyncer serviceCatalogSyncer, brokerName string, ...) *RelistRequester
  • func (r *RelistRequester) RequestRelist()
  • func (r *RelistRequester) Run(stopCh <-chan struct{})
• type TimeAfterProvider
  • func (p TimeAfterProvider) After(d time.Duration) <-chan time.Time

Types

type Controller

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

Controller populates local storage with all RemoteEnvironment custom resources created in k8s cluster.

func New

func New(remoteEnvironmentInformer informers.RemoteEnvironmentInformer, reUpserter remoteEnvironmentUpserter, reRemover remoteEnvironmentRemover, scRelistRequester scRelistRequester, log logrus.FieldLogger) *Controller

New creates new remote environment controller

func (*Controller) Run

func (c *Controller) Run(stopCh <-chan struct{})

Run starts the controller

type RelistRequester

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

RelistRequester informs the Service Catalog that given Service Broker should be relisted. Due to performance reason, many relist requests which happen during the period defined in `reListDurationWindow` result in a single Service Catalog relist trigger.

func NewRelistRequester

func NewRelistRequester(serviceCatalogSyncer serviceCatalogSyncer, brokerName string, reListDuration time.Duration, log logrus.FieldLogger) *RelistRequester

NewRelistRequester returns new instance of RelistRequester

func (*RelistRequester) RequestRelist

func (r *RelistRequester) RequestRelist()

RequestRelist informs the Service Catalog that Broker should be relisted.

func (*RelistRequester) Run

func (r *RelistRequester) Run(stopCh <-chan struct{})

Run runs worker which executing relist operation

type TimeAfterProvider

type TimeAfterProvider func(d time.Duration) <-chan time.Time

TimeAfterProvider is a provider for time.After. If not initialised defaults to time.After implementation for stdlib. It's intended to facilitate testing without time dependency.

func (TimeAfterProvider) After

func (p TimeAfterProvider) After(d time.Duration) <-chan time.Time

After calls attached After implementation.