controller

Documentation

Index

• func RenewTokenJobWrapper(ctx context.Context, stopChan chan struct{}, cfg *config.Config, ...)
• func RevokeTokenJobWrapper(ctx context.Context, stopChan chan struct{}, cfg *config.Config, ...)
• type Controller
  • func NewController(cfg *config.Config, Clientset *kubernetes.Clientset) *Controller
  • func (c *Controller) GetLock(lockName string)
  • func (c *Controller) RunInjector(ctx context.Context, errChan chan<- error, runSuccess chan<- bool)
  • func (c *Controller) RunRenewer(ctx context.Context, metricsSuccess chan<- bool)
  • func (c *Controller) RunRevoker(ctx context.Context, metricsSuccess chan<- bool)

Functions

func RenewTokenJobWrapper

func RenewTokenJobWrapper(ctx context.Context, stopChan chan struct{}, cfg *config.Config, clientset k8s.KubernetesClient)

func RevokeTokenJobWrapper

func RevokeTokenJobWrapper(ctx context.Context, stopChan chan struct{}, cfg *config.Config, clientset k8s.KubernetesClient)

Types

type Controller

type Controller struct {
	Cfg       *config.Config
	Clientset *kubernetes.Clientset
	Lock      *resourcelock.LeaseLock
	PodName   string
	// contains filtered or unexported fields
}

func NewController

func NewController(cfg *config.Config, Clientset *kubernetes.Clientset) *Controller

func (*Controller) GetLock

func (c *Controller) GetLock(lockName string)

func (*Controller) RunInjector

func (c *Controller) RunInjector(ctx context.Context, errChan chan<- error, runSuccess chan<- bool)

func (*Controller) RunRenewer

func (c *Controller) RunRenewer(ctx context.Context, metricsSuccess chan<- bool)

func (*Controller) RunRevoker

func (c *Controller) RunRevoker(ctx context.Context, metricsSuccess chan<- bool)