config

Documentation

Index

• type ChangeHandler
• type Config
  • func New(ctx context.Context, kubeClient *kubernetes.Clientset, ...) (Config, error)

Types

type ChangeHandler

type ChangeHandler func(c Config)

type Config

type Config interface {
	// OnChange is used to register a handler to be called when the configuration has been changed
	OnChange(handler ChangeHandler)

	// BatchMaxDuration returns the maximum batch duration
	BatchMaxDuration() time.Duration
	// BatchIdleDuration returns the maximum idle period used to extend a batch duration up to BatchMaxDuration
	BatchIdleDuration() time.Duration
}

func New

func New(ctx context.Context, kubeClient *kubernetes.Clientset, iw *informer.InformedWatcher) (Config, error)