controllers

package
v0.8.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 9, 2022 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 (*AuthorizedController) Add

func (*AuthorizedController) Del

func (*AuthorizedController) Run

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 (*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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL