k8s

Documentation

Index

• Constants
• Variables
• type SecretController
  • func NewSecretController(cfg *configv1.Config) *SecretController
  • func (s *SecretController) Name() string
  • func (s *SecretController) PreRun() error
  • func (s *SecretController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (s *SecretController) ServeContext(ctx context.Context) error

Constants

const (
	// ServiceAccountTokenPath is the path to the service account token file in a Kubernetes pod.
	ServiceAccountTokenPath = "/var/run/secrets/kubernetes.io/serviceaccount/token"
	// NamespacePath is the path to the namespace file in a Kubernetes pod.
	NamespacePath = "/var/run/secrets/kubernetes.io/serviceaccount/namespace"
)

Variables

var (
	ErrLoadingConfig = errors.New("error loading kube config")
)

Types

type SecretController

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

SecretController watches secrets for updates and updates the configuration with the loaded data.

func NewSecretController

func NewSecretController(cfg *configv1.Config) *SecretController

NewSecretController creates a new k8s Controller that loads secrets from Kubernetes and updates the configuration with the loaded data.

func (*SecretController) Name

func (s *SecretController) Name() string

Name implements run.PreRunner

func (*SecretController) PreRun

func (s *SecretController) PreRun() error

PreRun saves the original configuration in PreRun phase because the configuration is loaded from the file in the config Validate phase.

func (*SecretController) Reconcile

func (s *SecretController) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*SecretController) ServeContext

func (s *SecretController) ServeContext(ctx context.Context) error

ServeContext starts the controller manager and watches secrets for updates.