registry

Documentation

Index

• type ProxyRegistry
  • func NewProxyRegistry() *ProxyRegistry
  • func (pr *ProxyRegistry) GetConnectedProxy(connectionID int64) *models.Proxy
  • func (pr *ProxyRegistry) GetConnectedProxyCount() int
  • func (pr *ProxyRegistry) ListConnectedProxies() map[string]*models.Proxy
  • func (pr *ProxyRegistry) RegisterProxy(proxy *models.Proxy)
  • func (pr *ProxyRegistry) UnregisterProxy(connectionID int64)

Types

type ProxyRegistry

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

ProxyRegistry keeps track of Envoy proxies as they connect and disconnect from the control plane.

func NewProxyRegistry

func NewProxyRegistry() *ProxyRegistry

NewProxyRegistry initializes a new empty *ProxyRegistry.

func (*ProxyRegistry) GetConnectedProxy

func (pr *ProxyRegistry) GetConnectedProxy(connectionID int64) *models.Proxy

GetConnectedProxy loads a connected proxy from the registry.

func (*ProxyRegistry) GetConnectedProxyCount

func (pr *ProxyRegistry) GetConnectedProxyCount() int

GetConnectedProxyCount counts the number of connected proxies

func (*ProxyRegistry) ListConnectedProxies

func (pr *ProxyRegistry) ListConnectedProxies() map[string]*models.Proxy

ListConnectedProxies lists the Envoy proxies already connected and the time they first connected.

func (*ProxyRegistry) RegisterProxy

func (pr *ProxyRegistry) RegisterProxy(proxy *models.Proxy)

RegisterProxy registers a newly connected proxy.

func (*ProxyRegistry) UnregisterProxy

func (pr *ProxyRegistry) UnregisterProxy(connectionID int64)

UnregisterProxy unregisters the given proxy from the catalog.