xdsmgr

Documentation

Overview

Package xdsmgr implements a resource discovery manager for envoy.

Index

• type Manager
  • func NewManager(resources map[string][]*envoy_service_discovery_v3.Resource, ...) *Manager
  • func (mgr *Manager) DeltaAggregatedResources(...) error
  • func (mgr *Manager) StreamAggregatedResources(...) error
  • func (mgr *Manager) Update(ctx context.Context, ...)

Types

type Manager

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

A Manager manages xDS resources.

func NewManager

func NewManager(resources map[string][]*envoy_service_discovery_v3.Resource, eventHandler func(*events.EnvoyConfigurationEvent)) *Manager

NewManager creates a new Manager.

func (*Manager) DeltaAggregatedResources

func (mgr *Manager) DeltaAggregatedResources(
	stream envoy_service_discovery_v3.AggregatedDiscoveryService_DeltaAggregatedResourcesServer,
) error

DeltaAggregatedResources implements the increment xDS server.

func (*Manager) StreamAggregatedResources

func (mgr *Manager) StreamAggregatedResources(
	stream envoy_service_discovery_v3.AggregatedDiscoveryService_StreamAggregatedResourcesServer,
) error

StreamAggregatedResources is not implemented.

func (*Manager) Update

func (mgr *Manager) Update(ctx context.Context, resources map[string][]*envoy_service_discovery_v3.Resource)

Update updates the state of resources. If any changes are made they will be pushed to any listening streams. For each TypeURL the list of resources should be the complete list of resources.