watchers

Documentation

Index

• type ConfigWatcher
  • func NewConfigWatcher(client *kubernetes.Clientset, cm *config.MutexConfigManager, ...) *ConfigWatcher
  • func (pw ConfigWatcher) CloneMap() map[string]v1.ConfigMap
  • func (pw ConfigWatcher) WatchConfigs()
• type EndpointWatcher
  • func NewEndpointWatcher(client *kubernetes.Clientset, cm *config.MutexConfigManager, ...) *EndpointWatcher
  • func (pw EndpointWatcher) CloneMap() map[string]v1.Endpoints
  • func (pw EndpointWatcher) GetUpdated() map[string]v1.Endpoints
  • func (pw EndpointWatcher) ResetUpdatedCache()
  • func (pw EndpointWatcher) WatchEndpoints()
• type NSWatcher
  • func NewNSWatcher(client *kubernetes.Clientset, cm *config.MutexConfigManager, ...) *NSWatcher
  • func (pw NSWatcher) CloneMap() map[string]m.NsSchema
  • func (pw NSWatcher) WatchNamespaces()
• type PVCWatcher
  • func NewPVCWatcher(client *kubernetes.Clientset, cm *config.MutexConfigManager, ...) *PVCWatcher
  • func (pw PVCWatcher) CloneMap() map[string]v1.PersistentVolumeClaim
  • func (pw PVCWatcher) WatchPVC()
• type RQWatcher
  • func NewRQWatcher(client *kubernetes.Clientset, cm *config.MutexConfigManager, ...) *RQWatcher
  • func (pw RQWatcher) CloneMap() map[string]v1.ResourceQuota
  • func (pw RQWatcher) WatchResourceQuotas()
• type SecretWathcer
  • func NewSecretWathcer(client *kubernetes.Clientset, secret *config.MutexConfigManager, ...) *SecretWathcer
  • func (pw SecretWathcer) CloneMap() map[string]v1.Secret
  • func (pw SecretWathcer) WatchSecrets()
• type ServiceWatcher
  • func NewServiceWatcher(client *kubernetes.Clientset, cm *config.MutexConfigManager, ...) *ServiceWatcher
  • func (pw ServiceWatcher) CloneMap() map[string]m.ServiceSchema
  • func (pw *ServiceWatcher) UpdateServiceCache()
  • func (pw ServiceWatcher) WatchServices()
• type WatchListener

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 NewPVCWatcher

func NewPVCWatcher(client *kubernetes.Clientset, cm *config.MutexConfigManager, cache *map[string]v1.PersistentVolumeClaim, l *log.Logger) *PVCWatcher

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)
}