watchers

package
v0.1.15 Latest Latest
Warning

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

Go to latest
Published: Jun 19, 2019 License: Apache-2.0 Imports: 14 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ConfigWatcher

type ConfigWatcher struct {
	Client      *kubernetes.Clientset
	CMCache     map[string]v1.ConfigMap
	ConfManager *config.MutexConfigManager
	Listener    *WatchListener
	UpdateDelay bool
	Logger      *log.Logger
}

func NewConfigWatcher

func NewConfigWatcher(client *kubernetes.Clientset, cm *config.MutexConfigManager, cache *map[string]v1.ConfigMap, listener WatchListener, l *log.Logger) *ConfigWatcher

func (ConfigWatcher) CloneMap

func (pw ConfigWatcher) CloneMap() map[string]v1.ConfigMap

func (ConfigWatcher) WatchConfigs

func (pw ConfigWatcher) WatchConfigs()

type EndpointWatcher

type EndpointWatcher struct {
	Client        *kubernetes.Clientset
	EndpointCache map[string]v1.Endpoints
	UpdatedCache  map[string]v1.Endpoints
	ConfManager   *config.MutexConfigManager
	Logger        *log.Logger
}

func NewEndpointWatcher

func NewEndpointWatcher(client *kubernetes.Clientset, cm *config.MutexConfigManager, cache *map[string]v1.Endpoints, l *log.Logger) *EndpointWatcher

func (EndpointWatcher) CloneMap

func (pw EndpointWatcher) CloneMap() map[string]v1.Endpoints

func (EndpointWatcher) GetUpdated

func (pw EndpointWatcher) GetUpdated() map[string]v1.Endpoints

func (EndpointWatcher) ResetUpdatedCache

func (pw EndpointWatcher) ResetUpdatedCache()

func (EndpointWatcher) WatchEndpoints

func (pw EndpointWatcher) WatchEndpoints()

end points

type NSWatcher

type NSWatcher struct {
	Client      *kubernetes.Clientset
	NSCache     map[string]m.NsSchema
	ConfManager *config.MutexConfigManager
	Logger      *log.Logger
}

func NewNSWatcher

func NewNSWatcher(client *kubernetes.Clientset, cm *config.MutexConfigManager, cache *map[string]m.NsSchema, l *log.Logger) *NSWatcher

func (NSWatcher) CloneMap

func (pw NSWatcher) CloneMap() map[string]m.NsSchema

func (NSWatcher) WatchNamespaces

func (pw NSWatcher) WatchNamespaces()

quotas

type PVCWatcher

type PVCWatcher struct {
	Client      *kubernetes.Clientset
	PVCCache    map[string]v1.PersistentVolumeClaim
	ConfManager *config.MutexConfigManager
	Logger      *log.Logger
}

func (PVCWatcher) CloneMap

func (pw PVCWatcher) CloneMap() map[string]v1.PersistentVolumeClaim

func (PVCWatcher) WatchPVC

func (pw PVCWatcher) WatchPVC()

type RQWatcher

type RQWatcher struct {
	Client       *kubernetes.Clientset
	RQCache      map[string]v1.ResourceQuota
	ConfManager  *config.MutexConfigManager
	UpdatedCache map[string]m.RqSchema
	Logger       *log.Logger
}

func NewRQWatcher

func NewRQWatcher(client *kubernetes.Clientset, cm *config.MutexConfigManager, cache *map[string]v1.ResourceQuota, l *log.Logger) *RQWatcher

func (RQWatcher) CloneMap

func (pw RQWatcher) CloneMap() map[string]v1.ResourceQuota

func (RQWatcher) WatchResourceQuotas

func (pw RQWatcher) WatchResourceQuotas()

quotas

type SecretWathcer

type SecretWathcer struct {
	Client      *kubernetes.Clientset
	SecretCache map[string]v1.Secret
	ConfManager *config.MutexConfigManager
	Listener    *WatchListener
	UpdateDelay bool
	Logger      *log.Logger
}

func NewSecretWathcer

func NewSecretWathcer(client *kubernetes.Clientset, secret *config.MutexConfigManager, cache *map[string]v1.Secret, listener WatchListener, l *log.Logger) *SecretWathcer

func (SecretWathcer) CloneMap

func (pw SecretWathcer) CloneMap() map[string]v1.Secret

func (SecretWathcer) WatchSecrets

func (pw SecretWathcer) WatchSecrets()

type ServiceWatcher

type ServiceWatcher struct {
	Client      *kubernetes.Clientset
	SvcCache    map[string]m.ServiceSchema
	ConfManager *config.MutexConfigManager
	Listener    *WatchListener
	UpdateDelay bool
	Logger      *log.Logger
}

func NewServiceWatcher

func NewServiceWatcher(client *kubernetes.Clientset, cm *config.MutexConfigManager, cache *map[string]m.ServiceSchema, listener WatchListener, l *log.Logger) *ServiceWatcher

func (ServiceWatcher) CloneMap

func (pw ServiceWatcher) CloneMap() map[string]m.ServiceSchema

func (*ServiceWatcher) UpdateServiceCache

func (pw *ServiceWatcher) UpdateServiceCache()

func (ServiceWatcher) WatchServices

func (pw ServiceWatcher) WatchServices()

type WatchListener

type WatchListener interface {
	CacheUpdated(namespace string)
}

Jump to

Keyboard shortcuts

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