operator

Documentation

Index

• Constants
• type Builder
  • func NewBuilder(provider ManagerProvider, scheme *runtime.Scheme, ...) *Builder
  • func (b *Builder) Build(ctx context.Context) (manager.Manager, error)
  • func (b *Builder) WithAPISecret(apiSecret client.ObjectKey) *Builder
  • func (b *Builder) WithAtlasDomain(domain string) *Builder
  • func (b *Builder) WithAtlasProvider(provider atlas.Provider) *Builder
  • func (b *Builder) WithConfig(config *rest.Config) *Builder
  • func (b *Builder) WithDeletionProtection(deletionProtection bool) *Builder
  • func (b *Builder) WithFeatureFlags(featureFlags *featureflags.FeatureFlags) *Builder
  • func (b *Builder) WithIndependentSyncPeriod(period time.Duration) *Builder
  • func (b *Builder) WithLeaderElection(enable bool) *Builder
  • func (b *Builder) WithLogger(logger *zap.Logger) *Builder
  • func (b *Builder) WithMetricAddress(address string) *Builder
  • func (b *Builder) WithNamespaces(namespaces ...string) *Builder
  • func (b *Builder) WithPredicates(predicates []predicate.Predicate) *Builder
  • func (b *Builder) WithProbeAddress(address string) *Builder
  • func (b *Builder) WithSkipNameValidation(skip bool) *Builder
  • func (b *Builder) WithSyncPeriod(period time.Duration) *Builder
• type ManagerProvider
• type ManagerProviderFunc
  • func (f ManagerProviderFunc) New(config *rest.Config, options manager.Options) (manager.Manager, error)

Constants

const (
	DefaultAtlasDomain           = "https://cloud.mongodb.com/"
	DefaultSyncPeriod            = 3 * time.Hour
	DefaultIndependentSyncPeriod = 15 * time.Minute
	DefaultLeaderElectionID      = "06d035fb.mongodb.com"
)

Types

type Builder

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

func NewBuilder

func NewBuilder(provider ManagerProvider, scheme *runtime.Scheme, minimumIndependentSyncPeriod time.Duration) *Builder

NewBuilder return a new Builder to construct operator controllers

func (*Builder) Build

func (b *Builder) Build(ctx context.Context) (manager.Manager, error)

Build builds the controller manager and configure operator controllers

func (*Builder) WithAPISecret

func (b *Builder) WithAPISecret(apiSecret client.ObjectKey) *Builder

func (*Builder) WithAtlasDomain

func (b *Builder) WithAtlasDomain(domain string) *Builder

func (*Builder) WithAtlasProvider

func (b *Builder) WithAtlasProvider(provider atlas.Provider) *Builder

func (*Builder) WithConfig

func (b *Builder) WithConfig(config *rest.Config) *Builder

func (*Builder) WithDeletionProtection

func (b *Builder) WithDeletionProtection(deletionProtection bool) *Builder

func (*Builder) WithFeatureFlags

func (b *Builder) WithFeatureFlags(featureFlags *featureflags.FeatureFlags) *Builder

func (*Builder) WithIndependentSyncPeriod

func (b *Builder) WithIndependentSyncPeriod(period time.Duration) *Builder

func (*Builder) WithLeaderElection

func (b *Builder) WithLeaderElection(enable bool) *Builder

func (*Builder) WithLogger

func (b *Builder) WithLogger(logger *zap.Logger) *Builder

func (*Builder) WithMetricAddress

func (b *Builder) WithMetricAddress(address string) *Builder

func (*Builder) WithNamespaces

func (b *Builder) WithNamespaces(namespaces ...string) *Builder

func (*Builder) WithPredicates

func (b *Builder) WithPredicates(predicates []predicate.Predicate) *Builder

func (*Builder) WithProbeAddress

func (b *Builder) WithProbeAddress(address string) *Builder

func (*Builder) WithSkipNameValidation

func (b *Builder) WithSkipNameValidation(skip bool) *Builder

WithSkipNameValidation skips name validation in controller-runtime to prevent duplicate controller names.

Note: use this in tests only, setting this to true in a production setup will cause faulty behavior.

func (*Builder) WithSyncPeriod

func (b *Builder) WithSyncPeriod(period time.Duration) *Builder

type ManagerProvider

type ManagerProvider interface {
	New(config *rest.Config, options manager.Options) (manager.Manager, error)
}

type ManagerProviderFunc

type ManagerProviderFunc func(config *rest.Config, options manager.Options) (manager.Manager, error)

func (ManagerProviderFunc) New

func (f ManagerProviderFunc) New(config *rest.Config, options manager.Options) (manager.Manager, error)