controllers

Documentation

Index

• func NewCondition(conditionStatus string, conditionType string, conditionReason string, ...) zookeeperservice.StatusCondition
• type PasswordGenerator
• type ReconcileBackupDaemon
  • func NewReconcileBackupDaemon(r *ZooKeeperServiceReconciler, cr *zookeeperservice.ZooKeeperService, ...) ReconcileBackupDaemon
  • func (r ReconcileBackupDaemon) Reconcile() error
  • func (r ReconcileBackupDaemon) Status() error
• type ReconcileIntegrationTests
  • func NewReconcileIntegrationTests(r *ZooKeeperServiceReconciler, cr *zookeeperservice.ZooKeeperService, ...) ReconcileIntegrationTests
  • func (r ReconcileIntegrationTests) Reconcile() error
  • func (r ReconcileIntegrationTests) Status() error
• type ReconcileMonitoring
  • func NewReconcileMonitoring(r *ZooKeeperServiceReconciler, cr *zookeeperservice.ZooKeeperService, ...) ReconcileMonitoring
  • func (r ReconcileMonitoring) Reconcile() error
  • func (r ReconcileMonitoring) Status() error
• type ReconcileService
• type ReconcileZooKeeper
  • func NewReconcileZooKeeper(r *ZooKeeperServiceReconciler, cr *zookeeperservice.ZooKeeperService, ...) ReconcileZooKeeper
  • func (r ReconcileZooKeeper) Reconcile() error
  • func (r ReconcileZooKeeper) Status() error
• type VaultPasswordGenerator
  • func NewVaultPasswordGenerator(cr *zookeeperservice.ZooKeeperService, reconciler *ZooKeeperServiceReconciler) (*VaultPasswordGenerator, error)
  • func (generator VaultPasswordGenerator) Generate() (string, error)
• type ZooKeeperServiceReconciler
  • func (r *ZooKeeperServiceReconciler) GeneratePasswordForPolicy(policyName string) (string, error)
  • func (r *ZooKeeperServiceReconciler) InitVaultClient(cr *zookeeperservice.ZooKeeperService) error
  • func (r *ZooKeeperServiceReconciler) ReadVaultAuthRole(roleName string, cr *zookeeperservice.ZooKeeperService) (map[string]interface{}, error)
  • func (r *ZooKeeperServiceReconciler) ReadVaultPolicy(policyName string) (string, error)
  • func (r *ZooKeeperServiceReconciler) ReadVaultSecret(path string, secretName string) (map[string]interface{}, error)
  • func (r *ZooKeeperServiceReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)
  • func (r *ZooKeeperServiceReconciler) SetupWithManager(mgr ctrl.Manager) error
  • func (r *ZooKeeperServiceReconciler) WriteVaultAuthRole(roleName string, role interface{}, cr *zookeeperservice.ZooKeeperService) error
  • func (r *ZooKeeperServiceReconciler) WriteVaultPasswordPolicy(policyName string, policy interface{}) error
  • func (r *ZooKeeperServiceReconciler) WriteVaultPolicy(policyName string, policy string) error
  • func (r *ZooKeeperServiceReconciler) WriteVaultSecret(path string, secretName string, secret map[string]interface{}) (int64, error)

Functions

func NewCondition

func NewCondition(conditionStatus string, conditionType string, conditionReason string, conditionMessage string) zookeeperservice.StatusCondition

Types

type PasswordGenerator

type PasswordGenerator interface {
	Generate() (string, error)
}

type ReconcileBackupDaemon

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

func NewReconcileBackupDaemon

func NewReconcileBackupDaemon(r *ZooKeeperServiceReconciler, cr *zookeeperservice.ZooKeeperService, logger logr.Logger) ReconcileBackupDaemon

func (ReconcileBackupDaemon) Reconcile

func (r ReconcileBackupDaemon) Reconcile() error

func (ReconcileBackupDaemon) Status

func (r ReconcileBackupDaemon) Status() error

type ReconcileIntegrationTests

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

func NewReconcileIntegrationTests

func NewReconcileIntegrationTests(r *ZooKeeperServiceReconciler, cr *zookeeperservice.ZooKeeperService, logger logr.Logger) ReconcileIntegrationTests

func (ReconcileIntegrationTests) Reconcile

func (r ReconcileIntegrationTests) Reconcile() error

func (ReconcileIntegrationTests) Status

func (r ReconcileIntegrationTests) Status() error

type ReconcileMonitoring

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

func NewReconcileMonitoring

func NewReconcileMonitoring(r *ZooKeeperServiceReconciler, cr *zookeeperservice.ZooKeeperService, logger logr.Logger) ReconcileMonitoring

func (ReconcileMonitoring) Reconcile

func (r ReconcileMonitoring) Reconcile() error

func (ReconcileMonitoring) Status

func (r ReconcileMonitoring) Status() error

type ReconcileService

type ReconcileService interface {
	Reconcile() error
	Status() error
}

type ReconcileZooKeeper

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

func NewReconcileZooKeeper

func NewReconcileZooKeeper(r *ZooKeeperServiceReconciler, cr *zookeeperservice.ZooKeeperService, logger logr.Logger) ReconcileZooKeeper

func (ReconcileZooKeeper) Reconcile

func (r ReconcileZooKeeper) Reconcile() error

func (ReconcileZooKeeper) Status

func (r ReconcileZooKeeper) Status() error

type VaultPasswordGenerator

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

func NewVaultPasswordGenerator

func NewVaultPasswordGenerator(cr *zookeeperservice.ZooKeeperService, reconciler *ZooKeeperServiceReconciler) (*VaultPasswordGenerator, error)

func (VaultPasswordGenerator) Generate

func (generator VaultPasswordGenerator) Generate() (string, error)

type ZooKeeperServiceReconciler

type ZooKeeperServiceReconciler struct {
	// This client, initialized using mgr.Client() above, is a split client
	// that reads objects from the cache and writes to the apiserver
	Client           client.Client
	Scheme           *runtime.Scheme
	ResourceVersions map[string]string
	ResourceHashes   map[string]string
}

ZooKeeperServiceReconciler reconciles a ZooKeeperService object

func (*ZooKeeperServiceReconciler) GeneratePasswordForPolicy

func (r *ZooKeeperServiceReconciler) GeneratePasswordForPolicy(policyName string) (string, error)

func (*ZooKeeperServiceReconciler) InitVaultClient

func (r *ZooKeeperServiceReconciler) InitVaultClient(cr *zookeeperservice.ZooKeeperService) error

func (*ZooKeeperServiceReconciler) ReadVaultAuthRole

func (r *ZooKeeperServiceReconciler) ReadVaultAuthRole(roleName string, cr *zookeeperservice.ZooKeeperService) (map[string]interface{}, error)

func (*ZooKeeperServiceReconciler) ReadVaultPolicy

func (r *ZooKeeperServiceReconciler) ReadVaultPolicy(policyName string) (string, error)

func (*ZooKeeperServiceReconciler) ReadVaultSecret

func (r *ZooKeeperServiceReconciler) ReadVaultSecret(path string, secretName string) (map[string]interface{}, error)

func (*ZooKeeperServiceReconciler) Reconcile

func (r *ZooKeeperServiceReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)

func (*ZooKeeperServiceReconciler) SetupWithManager

func (r *ZooKeeperServiceReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

func (*ZooKeeperServiceReconciler) WriteVaultAuthRole

func (r *ZooKeeperServiceReconciler) WriteVaultAuthRole(roleName string, role interface{}, cr *zookeeperservice.ZooKeeperService) error

func (*ZooKeeperServiceReconciler) WriteVaultPasswordPolicy

func (r *ZooKeeperServiceReconciler) WriteVaultPasswordPolicy(policyName string, policy interface{}) error

func (*ZooKeeperServiceReconciler) WriteVaultPolicy

func (r *ZooKeeperServiceReconciler) WriteVaultPolicy(policyName string, policy string) error

func (*ZooKeeperServiceReconciler) WriteVaultSecret

func (r *ZooKeeperServiceReconciler) WriteVaultSecret(path string, secretName string, secret map[string]interface{}) (int64, error)