manager

Documentation

Overview

Callbacks are called by GRPC server on new events.

package manager provide GRPC server configuration and configuration cache manager.

Index

• func NewCacheManager(snapshotCache cache_v3.SnapshotCache, logger logr.Logger) *cacheManager
• func NewEnvoySnapshotCacheLogger(logger logr.Logger) envoy_log.Logger
• type Callbacks
  • func NewCallbacks(cacheManager *cacheManager, logger logr.Logger) *Callbacks
  • func (c *Callbacks) OnDeltaStreamClosed(id int64)
  • func (c *Callbacks) OnDeltaStreamOpen(ctx context.Context, id int64, typeUrl string) error
  • func (c *Callbacks) OnFetchRequest(ctx context.Context, request *envoy_discovery_v3.DiscoveryRequest) error
  • func (c *Callbacks) OnFetchResponse(request *envoy_discovery_v3.DiscoveryRequest, ...)
  • func (c *Callbacks) OnStreamClosed(id int64)
  • func (c *Callbacks) OnStreamDeltaRequest(id int64, request *envoy_discovery_v3.DeltaDiscoveryRequest) error
  • func (c *Callbacks) OnStreamDeltaResponse(id int64, request *envoy_discovery_v3.DeltaDiscoveryRequest, ...)
  • func (c *Callbacks) OnStreamOpen(ctx context.Context, id int64, typeUrl string) error
  • func (c *Callbacks) OnStreamRequest(id int64, request *envoy_discovery_v3.DiscoveryRequest) error
  • func (c *Callbacks) OnStreamResponse(ctx context.Context, id int64, request *envoy_discovery_v3.DiscoveryRequest, ...)
• type EnvoyConfigManager
  • func NewEnvoyConfigManager(ctx context.Context, address string, logger logr.Logger) *EnvoyConfigManager
  • func (em *EnvoyConfigManager) ApplyNewFleetSnapshot(fleet string, snapshot *cache.Snapshot) error
  • func (em *EnvoyConfigManager) Start() error
• type EnvoySnapshotCacheLogger
  • func (l EnvoySnapshotCacheLogger) Debugf(format string, args ...interface{})
  • func (l EnvoySnapshotCacheLogger) Errorf(format string, args ...interface{})
  • func (l EnvoySnapshotCacheLogger) Infof(format string, args ...interface{})
  • func (l EnvoySnapshotCacheLogger) Warnf(format string, args ...interface{})

Functions

func NewCacheManager

func NewCacheManager(snapshotCache cache_v3.SnapshotCache, logger logr.Logger) *cacheManager

func NewEnvoySnapshotCacheLogger

func NewEnvoySnapshotCacheLogger(logger logr.Logger) envoy_log.Logger

Types

type Callbacks

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

func NewCallbacks

func NewCallbacks(cacheManager *cacheManager, logger logr.Logger) *Callbacks

func (*Callbacks) OnDeltaStreamClosed

func (c *Callbacks) OnDeltaStreamClosed(id int64)

func (*Callbacks) OnDeltaStreamOpen

func (c *Callbacks) OnDeltaStreamOpen(ctx context.Context, id int64, typeUrl string) error

func (*Callbacks) OnFetchRequest

func (c *Callbacks) OnFetchRequest(ctx context.Context, request *envoy_discovery_v3.DiscoveryRequest) error

func (*Callbacks) OnFetchResponse

func (c *Callbacks) OnFetchResponse(request *envoy_discovery_v3.DiscoveryRequest, response *envoy_discovery_v3.DiscoveryResponse)

func (*Callbacks) OnStreamClosed

func (c *Callbacks) OnStreamClosed(id int64)

func (*Callbacks) OnStreamDeltaRequest

func (c *Callbacks) OnStreamDeltaRequest(id int64, request *envoy_discovery_v3.DeltaDiscoveryRequest) error

func (*Callbacks) OnStreamDeltaResponse

func (c *Callbacks) OnStreamDeltaResponse(id int64, request *envoy_discovery_v3.DeltaDiscoveryRequest, response *envoy_discovery_v3.DeltaDiscoveryResponse)

func (*Callbacks) OnStreamOpen

func (c *Callbacks) OnStreamOpen(ctx context.Context, id int64, typeUrl string) error

func (*Callbacks) OnStreamRequest

func (c *Callbacks) OnStreamRequest(id int64, request *envoy_discovery_v3.DiscoveryRequest) error

func (*Callbacks) OnStreamResponse

func (c *Callbacks) OnStreamResponse(ctx context.Context, id int64, request *envoy_discovery_v3.DiscoveryRequest, response *envoy_discovery_v3.DiscoveryResponse)

type EnvoyConfigManager

type EnvoyConfigManager struct {
	XDSServer *server.Server
	// contains filtered or unexported fields
}

EnvoyConfigManager holds cacheManager and XDS service Only its methods must be called to update Envoy configuration

func NewEnvoyConfigManager

func NewEnvoyConfigManager(ctx context.Context, address string, logger logr.Logger) *EnvoyConfigManager

func (*EnvoyConfigManager) ApplyNewFleetSnapshot

func (em *EnvoyConfigManager) ApplyNewFleetSnapshot(fleet string, snapshot *cache.Snapshot) error

func (*EnvoyConfigManager) Start

func (em *EnvoyConfigManager) Start() error

type EnvoySnapshotCacheLogger

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

EnvoySnapshotCacheLogger wraps a `logr.Logger` logger.

func (EnvoySnapshotCacheLogger) Debugf

func (l EnvoySnapshotCacheLogger) Debugf(format string, args ...interface{})

Debugf logs a formatted debugging message.

func (EnvoySnapshotCacheLogger) Errorf

func (l EnvoySnapshotCacheLogger) Errorf(format string, args ...interface{})

Errorf logs a formatted error message.

func (EnvoySnapshotCacheLogger) Infof

func (l EnvoySnapshotCacheLogger) Infof(format string, args ...interface{})

Infof logs a formatted informational message.

func (EnvoySnapshotCacheLogger) Warnf

func (l EnvoySnapshotCacheLogger) Warnf(format string, args ...interface{})

Warnf logs a formatted warning message.