controllers

Documentation

Index

• type AllowController
  • func NewAllowController(conf *AllowControllerConfig) *AllowController
  • func (s *AllowController) Add(cm *corev1.ConfigMap)
  • func (s *AllowController) Del(cm *corev1.ConfigMap)
  • func (s *AllowController) Run(ctx context.Context) error
• type AllowControllerConfig
• type AuthorizedController
  • func NewAuthorizedController(conf *AuthorizedControllerConfig) *AuthorizedController
  • func (s *AuthorizedController) Add(cm *corev1.ConfigMap)
  • func (s *AuthorizedController) Del(cm *corev1.ConfigMap)
  • func (s *AuthorizedController) Run(ctx context.Context) error
• type AuthorizedControllerConfig
• type ConfigWatcher
  • func NewConfigWatcher(conf *ConfigWatcherConfig) *ConfigWatcher
  • func (c *ConfigWatcher) Reload()
  • func (c *ConfigWatcher) Run(ctx context.Context) error
• type ConfigWatcherConfig
• type DiscoveryController
  • func NewDiscoveryController(conf *DiscoveryControllerConfig) *DiscoveryController
  • func (s *DiscoveryController) Add(cm *corev1.ConfigMap)
  • func (s *DiscoveryController) Del(cm *corev1.ConfigMap)
  • func (s *DiscoveryController) Run(ctx context.Context) error
  • func (s *DiscoveryController) UpdateIPs(ips []string)
• type DiscoveryControllerConfig
• type EndpointWatcher
  • func NewEndpointWatcher(conf *EndpointWatcherConfig) *EndpointWatcher
  • func (e *EndpointWatcher) Run(ctx context.Context) error
• type EndpointWatcherConfig
• type RuntimeController
  • func NewRuntimeController(conf *RuntimeControllerConfig) *RuntimeController
  • func (r *RuntimeController) Run(ctx context.Context) error
• type RuntimeControllerConfig

Types

type AllowController

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

func NewAllowController

func NewAllowController(conf *AllowControllerConfig) *AllowController

func (*AllowController) Add

func (s *AllowController) Add(cm *corev1.ConfigMap)

func (*AllowController) Del

func (s *AllowController) Del(cm *corev1.ConfigMap)

func (*AllowController) Run

func (s *AllowController) Run(ctx context.Context) error

type AllowControllerConfig

type AllowControllerConfig struct {
	Namespace     string
	LabelSelector string
	Logger        logr.Logger
	Clientset     client.Interface
}

type AuthorizedController

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

func NewAuthorizedController

func NewAuthorizedController(conf *AuthorizedControllerConfig) *AuthorizedController

func (*AuthorizedController) Add

func (s *AuthorizedController) Add(cm *corev1.ConfigMap)

func (*AuthorizedController) Del

func (s *AuthorizedController) Del(cm *corev1.ConfigMap)

func (*AuthorizedController) Run

func (s *AuthorizedController) Run(ctx context.Context) error

type AuthorizedControllerConfig

type AuthorizedControllerConfig struct {
	Namespace     string
	LabelSelector string
	Logger        logr.Logger
	Clientset     client.Interface
}

type ConfigWatcher

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

func NewConfigWatcher

func NewConfigWatcher(conf *ConfigWatcherConfig) *ConfigWatcher

func (*ConfigWatcher) Reload

func (c *ConfigWatcher) Reload()

func (*ConfigWatcher) Run

func (c *ConfigWatcher) Run(ctx context.Context) error

type ConfigWatcherConfig

type ConfigWatcherConfig struct {
	Clientset     client.Interface
	Logger        logr.Logger
	Namespace     string
	LabelSelector string
	ReloadFunc    func(d []json.RawMessage)
}

type DiscoveryController

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

func NewDiscoveryController

func NewDiscoveryController(conf *DiscoveryControllerConfig) *DiscoveryController

func (*DiscoveryController) Add

func (s *DiscoveryController) Add(cm *corev1.ConfigMap)

func (*DiscoveryController) Del

func (s *DiscoveryController) Del(cm *corev1.ConfigMap)

func (*DiscoveryController) Run

func (s *DiscoveryController) Run(ctx context.Context) error

func (*DiscoveryController) UpdateIPs

func (s *DiscoveryController) UpdateIPs(ips []string)

type DiscoveryControllerConfig

type DiscoveryControllerConfig struct {
	Namespace     string
	LabelSelector string
	Logger        logr.Logger
	Clientset     client.Interface
}

type EndpointWatcher

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

func NewEndpointWatcher

func NewEndpointWatcher(conf *EndpointWatcherConfig) *EndpointWatcher

func (*EndpointWatcher) Run

func (e *EndpointWatcher) Run(ctx context.Context) error

type EndpointWatcherConfig

type EndpointWatcherConfig struct {
	Name      string
	Namespace string
	Clientset client.Interface
	SyncFunc  func(ips []string)
}

type RuntimeController

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

func NewRuntimeController

func NewRuntimeController(conf *RuntimeControllerConfig) *RuntimeController

func (*RuntimeController) Run

func (r *RuntimeController) Run(ctx context.Context) error

type RuntimeControllerConfig

type RuntimeControllerConfig struct {
	Namespace     string
	LabelSelector string
	Logger        logr.Logger
	Clientset     client.Interface
}