IstioNodeToIP extract the IP address from an Envoy node identifier configured by Istio's pilot-agent.

NewAckingResourceMutatorWrapper creates a new AckingResourceMutatorWrapper to wrap the given ResourceMutator.

NewBaseObservableResourceSource initializes the given set.

NewCache creates a new, empty cache with 0 as its current version.

NewMockStream creates a new mock Stream for testing.

NewResourceWatcher creates a new ResourceWatcher backed by the given resource set.

NewServer creates an xDS gRPC stream handler using the given resource sources.

AnyTypeURL is the default type URL to use for ADS resource sets.

ErrInvalidVersionInfo is the error returned when receiving a request with a version info that is not a positive integer.

ErrNoADSTypeURL is the error returned when receiving a request without a type URL from an ADS stream.

ErrResourceWatch is the error returned whenever an internal error occurs while waiting for new versions of resources.

ErrUnknownTypeURL is the error returned when receiving a request with an unknown type URL.

AckingResourceMutatorWrapper is an AckingResourceMutator which wraps a ResourceMutator to notifies callers when resource updates are ACKed by nodes.

BaseObservableResourceSource implements the AddResourceVersionObserver and RemoveResourceVersionObserver methods to handle the notification of new resource versions.

Cache is a key-value container which allows atomically updating entries and incrementing a version number and notifying observers if the cache is actually modified.

MockStream is a mock implementation of Stream used for testing.

ResourceTypeConfiguration is the configuration of the XDS server for a resource type.

ResourceWatcher watches and retrieves new versions of resources from a resource set.

Server implements the handling of xDS streams.

VersionedResources is a set of protobuf-encoded resources along with their version.

AckingResourceMutator is a variant of ResourceMutator which calls back a Completion when a resource update is ACKed by a set of Envoy nodes.

ObservableResourceSet is a ResourceSet that allows registering observers of new resource versions from this source.

ObservableResourceSource is a ResourceSource that allows registering observers of new resource versions from this source.

ResourceMutator provides write access to a versioned set of resources.

ResourceSet provides read-write access to a versioned set of resources.

ResourceSource provides read access to a versioned set of resources.

ResourceVersionAckObserver defines the HandleResourceVersionAck method which is called whenever a node acknowledges having applied a version of the resources of a given type.

ResourceVersionObserver defines the HandleNewResourceVersion method which is called whenever the version of the resources of a given type has changed.

Stream is the subset of the gRPC bi-directional stream types which is used by Server.

NodeToIDFunc extracts a string identifier from an Envoy Node identifier.