watchers

package
v0.0.0-...-0e4f5d7 Latest Latest
Warning

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

 Go to latest Published: Sep 15, 2022 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Overview

* Copyright 2019, EnMasse authors. * License: Apache License 2.0 (see the file LICENSE or http://apache.org/licenses/LICENSE-2.0.html).

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AddressCreate 

func AddressCreate(space *v1beta1.Address) interface{}

func AddressSpaceCreate 

func AddressSpaceCreate(space *v1beta1.AddressSpace) interface{}

func AddressSpaceUpdate 

func AddressSpaceUpdate(value *v1beta1.AddressSpace, existing interface{}) bool

func AddressUpdate 

func AddressUpdate(value *v1beta1.Address, existing interface{}) bool

Types

type AddressPlanWatcher 

type AddressPlanWatcher struct {
	Namespace string
	cache.Cache
	ClientInterface cp.AdminV1beta2Interface
	// contains filtered or unexported fields
}

func (*AddressPlanWatcher) AwaitWatching 

func (kw *AddressPlanWatcher) AwaitWatching()

func (*AddressPlanWatcher) GetRestartCount 

func (kw *AddressPlanWatcher) GetRestartCount() int32

func (*AddressPlanWatcher) Shutdown 

func (kw *AddressPlanWatcher) Shutdown()

func (*AddressPlanWatcher) Watch 

func (kw *AddressPlanWatcher) Watch() error

type AddressSpacePlanWatcher 

type AddressSpacePlanWatcher struct {
	Namespace string
	cache.Cache
	ClientInterface cp.AdminV1beta2Interface
	// contains filtered or unexported fields
}

func (*AddressSpacePlanWatcher) AwaitWatching 

func (kw *AddressSpacePlanWatcher) AwaitWatching()

func (*AddressSpacePlanWatcher) GetRestartCount 

func (kw *AddressSpacePlanWatcher) GetRestartCount() int32

func (*AddressSpacePlanWatcher) Shutdown 

func (kw *AddressSpacePlanWatcher) Shutdown()

func (*AddressSpacePlanWatcher) Watch 

func (kw *AddressSpacePlanWatcher) Watch() error

type AddressSpaceSchemaWatcher 

type AddressSpaceSchemaWatcher struct {
	Namespace string
	cache.Cache
	ClientInterface cp.EnmasseV1beta1Interface
	// contains filtered or unexported fields
}

func (*AddressSpaceSchemaWatcher) AwaitWatching 

func (kw *AddressSpaceSchemaWatcher) AwaitWatching()

func (*AddressSpaceSchemaWatcher) GetRestartCount 

func (kw *AddressSpaceSchemaWatcher) GetRestartCount() int32

func (*AddressSpaceSchemaWatcher) Shutdown 

func (kw *AddressSpaceSchemaWatcher) Shutdown()

func (*AddressSpaceSchemaWatcher) Watch 

func (kw *AddressSpaceSchemaWatcher) Watch() error

type AddressSpaceWatcher 

type AddressSpaceWatcher struct {
	Namespace string
	cache.Cache
	ClientInterface cp.EnmasseV1beta1Interface
	// contains filtered or unexported fields
}

func (*AddressSpaceWatcher) AwaitWatching 

func (kw *AddressSpaceWatcher) AwaitWatching()

func (*AddressSpaceWatcher) GetRestartCount 

func (kw *AddressSpaceWatcher) GetRestartCount() int32

func (*AddressSpaceWatcher) Shutdown 

func (kw *AddressSpaceWatcher) Shutdown()

func (*AddressSpaceWatcher) Watch 

func (kw *AddressSpaceWatcher) Watch() error

type AddressWatcher 

type AddressWatcher struct {
	Namespace string
	cache.Cache
	ClientInterface cp.EnmasseV1beta1Interface
	// contains filtered or unexported fields
}

func (*AddressWatcher) AwaitWatching 

func (kw *AddressWatcher) AwaitWatching()

func (*AddressWatcher) GetRestartCount 

func (kw *AddressWatcher) GetRestartCount() int32

func (*AddressWatcher) Shutdown 

func (kw *AddressWatcher) Shutdown()

func (*AddressWatcher) Watch 

func (kw *AddressWatcher) Watch() error

type AgentCollectorCreator 

type AgentCollectorCreator = func(host string, port int32, infraUuid string, addressSpace string, addressSpaceNamespace string, tlsConfig *tls.Config) agent.Delegate

type AgentWatcher 

type AgentWatcher struct {
	Namespace             string
	Cache                 cache.Cache
	ClientInterface       cp.CoreV1Interface
	AgentCollectorCreator AgentCollectorCreator

	RouteClientInterface *routev1.RouteV1Client
	// contains filtered or unexported fields
}

func NewAgentWatcher 

func NewAgentWatcher(c cache.Cache, resyncInterval *time.Duration, namespace string, creator AgentCollectorCreator, developmentMode bool, options ...WatcherOption) (*AgentWatcher, error)

func (*AgentWatcher) AwaitWatching 

func (clw *AgentWatcher) AwaitWatching()

func (*AgentWatcher) Collector 

func (clw *AgentWatcher) Collector(infraUuid string) agent.Delegate

func (*AgentWatcher) GetRestartCount 

func (clw *AgentWatcher) GetRestartCount() int32

func (*AgentWatcher) Shutdown 

func (clw *AgentWatcher) Shutdown()

func (*AgentWatcher) Watch 

func (clw *AgentWatcher) Watch() error

type AuthenticationServiceWatcher 

type AuthenticationServiceWatcher struct {
	Namespace string
	cache.Cache
	ClientInterface cp.AdminV1beta1Interface
	// contains filtered or unexported fields
}

func (*AuthenticationServiceWatcher) AwaitWatching 

func (kw *AuthenticationServiceWatcher) AwaitWatching()

func (*AuthenticationServiceWatcher) GetRestartCount 

func (kw *AuthenticationServiceWatcher) GetRestartCount() int32

func (*AuthenticationServiceWatcher) Shutdown 

func (kw *AuthenticationServiceWatcher) Shutdown()

func (*AuthenticationServiceWatcher) Watch 

func (kw *AuthenticationServiceWatcher) Watch() error

type NamespaceWatcher 

type NamespaceWatcher struct {
	Namespace string
	cache.Cache
	ClientInterface cp.CoreV1Interface
	// contains filtered or unexported fields
}

func (*NamespaceWatcher) AwaitWatching 

func (kw *NamespaceWatcher) AwaitWatching()

func (*NamespaceWatcher) GetRestartCount 

func (kw *NamespaceWatcher) GetRestartCount() int32

func (*NamespaceWatcher) Shutdown 

func (kw *NamespaceWatcher) Shutdown()

func (*NamespaceWatcher) Watch 

func (kw *NamespaceWatcher) Watch() error

type ResourceWatcher 

type ResourceWatcher interface {
	Watch() error
	AwaitWatching()
	Shutdown()
	GetRestartCount() int32
}

func NewAddressPlanWatcher 

func NewAddressPlanWatcher(c cache.Cache, resyncInterval *time.Duration, namespace string, options ...WatcherOption) (ResourceWatcher, error)

func NewAddressSpacePlanWatcher 

func NewAddressSpacePlanWatcher(c cache.Cache, resyncInterval *time.Duration, namespace string, options ...WatcherOption) (ResourceWatcher, error)

func NewAddressSpaceSchemaWatcher 

func NewAddressSpaceSchemaWatcher(c cache.Cache, resyncInterval *time.Duration, options ...WatcherOption) (ResourceWatcher, error)

func NewAddressSpaceWatcher 

func NewAddressSpaceWatcher(c cache.Cache, resyncInterval *time.Duration, options ...WatcherOption) (ResourceWatcher, error)

func NewAddressWatcher 

func NewAddressWatcher(c cache.Cache, resyncInterval *time.Duration, options ...WatcherOption) (ResourceWatcher, error)

func NewAuthenticationServiceWatcher 

func NewAuthenticationServiceWatcher(c cache.Cache, resyncInterval *time.Duration, namespace string, options ...WatcherOption) (ResourceWatcher, error)

func NewNamespaceWatcher 

func NewNamespaceWatcher(c cache.Cache, resyncInterval *time.Duration, options ...WatcherOption) (ResourceWatcher, error)

type WatcherManager 

type WatcherManager interface {
	// starts the watcher manager but does not begin watching.  must not called more than once.
	Start()
	// initiates watching if not currently watching (idempotent).
	BeginWatching()
	// ceases watching if currently watching (idempotent).
	EndWatching()
	// shuts down the watcher manager.  If watchers are watching they will be stopped.  must not called more than once.
	Shutdown()
	GetCollector(infra string) agent.Delegate
}

func New 

func New(objectCache *cache.MemdbCache, resyncInterval time.Duration, config *rest.Config, infraNamespace string, developmentMode *bool, agentCommandDelegateExpiryPeriod time.Duration, agentAmqpConnectTimeout time.Duration, agentAmqpMaxFrameSize uint32) WatcherManager

type WatcherOption 

type WatcherOption func(watcher ResourceWatcher) error

func AddressPlanWatcherClient 

func AddressPlanWatcherClient(client cp.AdminV1beta2Interface) WatcherOption

Used to inject the fake client set for testing purposes

func AddressPlanWatcherConfig 

func AddressPlanWatcherConfig(config *rest.Config) WatcherOption

func AddressPlanWatcherFactory 

func AddressPlanWatcherFactory(create func(*tp.AddressPlan) interface{}, update func(*tp.AddressPlan, interface{}) bool) WatcherOption

func AddressSpacePlanWatcherClient 

func AddressSpacePlanWatcherClient(client cp.AdminV1beta2Interface) WatcherOption

Used to inject the fake client set for testing purposes

func AddressSpacePlanWatcherConfig 

func AddressSpacePlanWatcherConfig(config *rest.Config) WatcherOption

func AddressSpacePlanWatcherFactory 

func AddressSpacePlanWatcherFactory(create func(*tp.AddressSpacePlan) interface{}, update func(*tp.AddressSpacePlan, interface{}) bool) WatcherOption

func AddressSpaceSchemaWatcherClient 

func AddressSpaceSchemaWatcherClient(client cp.EnmasseV1beta1Interface) WatcherOption

Used to inject the fake client set for testing purposes

func AddressSpaceSchemaWatcherConfig 

func AddressSpaceSchemaWatcherConfig(config *rest.Config) WatcherOption

func AddressSpaceSchemaWatcherFactory 

func AddressSpaceSchemaWatcherFactory(create func(*tp.AddressSpaceSchema) interface{}, update func(*tp.AddressSpaceSchema, interface{}) bool) WatcherOption

func AddressSpaceWatcherClient 

func AddressSpaceWatcherClient(client cp.EnmasseV1beta1Interface) WatcherOption

Used to inject the fake client set for testing purposes

func AddressSpaceWatcherConfig 

func AddressSpaceWatcherConfig(config *rest.Config) WatcherOption

func AddressSpaceWatcherFactory 

func AddressSpaceWatcherFactory(create func(*tp.AddressSpace) interface{}, update func(*tp.AddressSpace, interface{}) bool) WatcherOption

func AddressWatcherClient 

func AddressWatcherClient(client cp.EnmasseV1beta1Interface) WatcherOption

Used to inject the fake client set for testing purposes

func AddressWatcherConfig 

func AddressWatcherConfig(config *rest.Config) WatcherOption

func AddressWatcherFactory 

func AddressWatcherFactory(create func(*tp.Address) interface{}, update func(*tp.Address, interface{}) bool) WatcherOption

func AgentWatcherClient 

func AgentWatcherClient(client cp.CoreV1Interface) WatcherOption

func AgentWatcherRouteConfig 

func AgentWatcherRouteConfig(config *rest.Config) WatcherOption

Development only

func AgentWatcherServiceConfig 

func AgentWatcherServiceConfig(config *rest.Config) WatcherOption

func AuthenticationServiceWatcherClient 

func AuthenticationServiceWatcherClient(client cp.AdminV1beta1Interface) WatcherOption

Used to inject the fake client set for testing purposes

func AuthenticationServiceWatcherConfig 

func AuthenticationServiceWatcherConfig(config *rest.Config) WatcherOption

func AuthenticationServiceWatcherFactory 

func AuthenticationServiceWatcherFactory(create func(*tp.AuthenticationService) interface{}, update func(*tp.AuthenticationService, interface{}) bool) WatcherOption

func NamespaceWatcherClient 

func NamespaceWatcherClient(client cp.CoreV1Interface) WatcherOption

Used to inject the fake client set for testing purposes

func NamespaceWatcherConfig 

func NamespaceWatcherConfig(config *rest.Config) WatcherOption

func NamespaceWatcherFactory 

func NamespaceWatcherFactory(create func(*tp.Namespace) interface{}, update func(*tp.Namespace, interface{}) bool) WatcherOption

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.