Documentation
¶
Overview ¶
Package observers contains the core logic for observers, which are what observe the environment to discover running services. An Observer only has to implement one method, Configure, which receives the configuration for that observer. That Configure method might be called multiple times, so an observer should be prepared for its config to change and take appropriate steps.
The ultimate output of an observer are objects that implement services.Endpoint, which represent the discovered service endpoints.
Index ¶
Constants ¶
This section is empty.
Variables ¶
var ConfigTemplates = map[string]interface{}{}
ConfigTemplates are blank (zero-value) instances of the configuration struct for a particular observer type.
Functions ¶
func Register ¶
func Register(_type string, factory ObserverFactory, configTemplate interface{})
Register an observer of _type with the agent. configTemplate should be a zero-valued struct that is of the same type that is accepted by the Configure method of the observer.
Types ¶
type ObserverFactory ¶
type ObserverFactory func(*ServiceCallbacks) interface{}
ObserverFactory creates an unconfigured instance of an observer
type ObserverManager ¶
type ObserverManager struct {
// Where to send observer notifications to
CallbackTargets *ServiceCallbacks
// contains filtered or unexported fields
}
ObserverManager instantiates and manages the configured observers
func (*ObserverManager) Configure ¶
func (om *ObserverManager) Configure(obsConfig []config.ObserverConfig)
Configure will do everything it can and returns any errors it encounters with certain observers. It is possible that some plugins might be configured and others not.
func (*ObserverManager) DiagnosticText ¶
func (om *ObserverManager) DiagnosticText() string
DiagnosticText outputs human-readable text about the active observers.
func (*ObserverManager) InternalMetrics ¶
func (om *ObserverManager) InternalMetrics() []*datapoint.Datapoint
InternalMetrics returns a list of datapoints relevant to the internal status of Observers
func (*ObserverManager) Shutdown ¶
func (om *ObserverManager) Shutdown()
Shutdown all of the managed observers
type ObserverWrapper ¶
type ObserverWrapper struct {
// contains filtered or unexported fields
}
ObserverWrapper represents an active observer
func (*ObserverWrapper) Shutdown ¶
func (ow *ObserverWrapper) Shutdown()
Shutdown calls Shutdown on the underlying observer instance if it implements it.
type ServiceCallbacks ¶
ServiceCallbacks are a set of functions that the observers call upon detecting new services and disappearing services.
type ServiceDiffer ¶
type ServiceDiffer struct {
DiscoveryFn func() []services.Endpoint
IntervalSeconds int
Callbacks *ServiceCallbacks
// contains filtered or unexported fields
}
ServiceDiffer will run the DiscoveryFn every IntervalSeconds and report any new or removed services to the provided Callbacks.
func (*ServiceDiffer) Start ¶
func (sd *ServiceDiffer) Start()
Start polling the DiscoveryFn on a regular interval
type Shutdownable ¶
type Shutdownable interface {
Shutdown()
}
Shutdownable describes an observer that has a shutdown routine. Observers should implement this if they spin up any goroutines that need to be stopped.
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package docker is an observer that watches a docker daemon and reports container ports as service endpoints.
|
Package docker is an observer that watches a docker daemon and reports container ports as service endpoints. |
|
Package ecs is a file-based observer that is primarily meant for development and test purposes.
|
Package ecs is a file-based observer that is primarily meant for development and test purposes. |
|
Package file is a file-based observer that is primarily meant for development and test purposes.
|
Package file is a file-based observer that is primarily meant for development and test purposes. |
|
Package host observer that monitors the current host for active network listeners and reports them as service endpoints Use of this observer requires the CAP_SYS_PTRACE and CAP_DAC_READ_SEARCH capability in Linux.
|
Package host observer that monitors the current host for active network listeners and reports them as service endpoints Use of this observer requires the CAP_SYS_PTRACE and CAP_DAC_READ_SEARCH capability in Linux. |
|
Package kubernetes contains an observer that watches the Kubernetes API for pods that are running on the same node as the agent.
|
Package kubernetes contains an observer that watches the Kubernetes API for pods that are running on the same node as the agent. |