ConfigIsPresent checks to see if any configuration is actually present in the given configdir.

ForceEndpoints reflects AMBASSADOR_FORCE_ENDPOINTS, to determine whether we're forcing endpoint watching or (the default) not.

GetAmbId extracts the AmbassadorId from the kubernetes resource.

GetAnnotations extracts and converts any parseable annotations from the supplied resource.

GetConfigDir returns the path to the directory we should check for filesystem config.

GetInterestingTypes takes a list of available server types, and returns the types we think are interesting to watch.

GetQueries takes a set of interesting types, and returns a set of kates.Query to watch for them.

This is the main ambassador entrypoint.

NewFake will construct a new Fake object.

NewFSWatcher instantiates an FSWatcher.

NewIstioCert instantiates an IstioCert to manage a certificate that Istio will write into directory "dir", should have the given "name" and appear to live in K8s namespace "namespace", and will have updates posted to "updateChannel" whenever the cert changes.

NewK8sStore creates a new and empty store.

NewKubernetesSnapshot creates a new, empty set of Ambassador inputs.

NewNotifier constructs a new notifier struct that is ready for use.

NewQueue constructs a new queue with the supplied timeout.

ReconcileSecrets figures out which secrets we're actually using, since we don't want to send secrets to Ambassador unless we're using them, since any secret we send will be saved to disk.

RunFake will create a new fake, invoke its Setup method and register its Teardown method as a Cleanup function with the test object.

take the next port in the range of ambassador ports.

FSWDelete is a delete operation.

FSWUpdate is an update operation.

Indicates that the watcher is deferring processing of the snapshot because it is considered to be a product of churn.

Indicates that the watcher is dropping the snapshot because it has determined that it is logically a noop.

Indicates the watcher is still in the booting process and the snapshot has dangling pointers.

Indicates that the snapshot is ready to be processed.

The Fake struct is a test harness for edgestack.

FakeConfig provides option when constructing a new Fake.

FSWatcher is a thing that can watch the filesystem for us, and call handler functions when things change.

FSWEvent represents a single interesting event.

IstioCert holds all the state we need to manage an Istio certificate.

IstioCertUpdate gets sent over the IstioCert's Updates channel whenever the cert changes XXX This will morph into a more general "internally-generated resource" thing later.

A K8sStore is implement just enough data structures to mock the watch aspect of kubernetes for testing purposes.

ModuleSecrets is..

The Notifier struct buffers up notifications to multiple listeners.

The Queue struct implements a multi-writer/multi-reader concurrent queue where the dequeue operation (the Get() method) takes a predicate that allows it to skip past queue entries until it finds one that satisfies the specified predicate.

SnapshotHolder is responsible for holding.

FSWErrorHandler is a handler function for an error.

FSWEventHandler is a handler function for an interesting event.

FSWOp specifies the operation for an event.