controller

Documentation

Index

• type Configuration
• type M3DBController
  • func NewM3DBController(opts ...Option) (*M3DBController, error)
  • func (c *M3DBController) Run(nWorkers int, stopCh <-chan struct{}) error
• type Option
  • func WithCRDClient(cl clientset.Interface) Option
  • func WithConfig(c Configuration) Option
  • func WithKClient(kc m3db.K8sops) Option
  • func WithKubeClient(cl kubernetes.Interface) Option
  • func WithKubeInformerFactory(f kubeinformers.SharedInformerFactory) Option
  • func WithKubectlProxy(use bool) Option
  • func WithLogger(l *zap.Logger) Option
  • func WithM3DBClusterInformerFactory(f informers.SharedInformerFactory) Option
  • func WithPodIdentityProvider(p podidentity.Provider) Option
  • func WithScope(s tally.Scope) Option

Types

type Configuration

type Configuration struct {
	// ManageCRD indicates whether the controller should create and update specs
	// of the CRDs it controls.
	ManageCRD bool

	// EnableValidation controls whether OpenAPI validation is enabled on the CRD.
	EnableValidation bool
}

Configuration contains parameters for the controller.

type M3DBController

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

M3DBController object

func NewM3DBController

func NewM3DBController(opts ...Option) (*M3DBController, error)

NewM3DBController creates new instance of Controller

func (*M3DBController) Run

func (c *M3DBController) Run(nWorkers int, stopCh <-chan struct{}) error

Run drives the controller event loop.

type Option

type Option interface {
	// contains filtered or unexported methods
}

Option provides configuration of a controller.

func WithCRDClient

func WithCRDClient(cl clientset.Interface) Option

WithCRDClient sets the client of our custom type.

func WithConfig

func WithConfig(c Configuration) Option

WithConfig sets configuration for the controller.

func WithKClient

func WithKClient(kc m3db.K8sops) Option

WithKClient sets the k8sops client.

func WithKubeClient

func WithKubeClient(cl kubernetes.Interface) Option

WithKubeClient sets the base Kubernetes client.

func WithKubeInformerFactory

func WithKubeInformerFactory(f kubeinformers.SharedInformerFactory) Option

WithKubeInformerFactory sets the Kubernetes base type informer factory.

func WithKubectlProxy

func WithKubectlProxy(use bool) Option

WithKubectlProxy sets whether to use a kubectl proxy for communicating with the cluster.

func WithLogger

func WithLogger(l *zap.Logger) Option

WithLogger sets a logger.

func WithM3DBClusterInformerFactory

func WithM3DBClusterInformerFactory(f informers.SharedInformerFactory) Option

WithM3DBClusterInformerFactory sets the factory for our custom type.

func WithPodIdentityProvider

func WithPodIdentityProvider(p podidentity.Provider) Option

WithPodIdentityProvider sets the pod identity provider.

func WithScope

func WithScope(s tally.Scope) Option

WithScope sets the telemetry scope