controller

package

v0.14.0 Latest Latest Go to latest Published: Aug 17, 2022 License: Apache-2.0 Imports: 53 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/m3db/m3db-operator

Links

Open Source Insights

Documentation ¶

Index ¶

type M3DBController
- func NewM3DBController(opts ...Option) (*M3DBController, error)
- func (c *M3DBController) Run(nWorkers int, stopCh <-chan struct{}) error
type Option

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type M3DBController ¶ added in v0.4.0

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

M3DBController object

func NewM3DBController ¶ added in v0.4.0

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

NewM3DBController creates new instance of Controller

func (*M3DBController) Run ¶ added in v0.4.0

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 WithFilteredInformerFactory ¶ added in v0.8.0

func WithFilteredInformerFactory(f kubeinformers.SharedInformerFactory) Option

WithFilteredInformerFactory sets the Filteredrnetes base type informer factory.

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL