listeners

README

package listeners

This package is providing the ServiceListener concept to the agent. A ServiceListener listens for events related to services the agent should monitor.

Service

Service represents an application we can run an integration against. It should be matched with a config template by the ConfigResolver. Services can only be Docker containers for now.

ServiceListener

ServiceListener monitors events related to Service lifecycles. It then formats and transmits this data to ConfigResolver.

DockerListener

DockerListener first gets current running containers and send these to the AutoConfig. Then it starts listening on the Docker event API for container activity and pass by Services mentioned in start/stop events to the AutoConfig through the corresponding channel.

ECSListener

The ECSListener relies on the metadata APIs available within the agent container. We're listening on changes on the container list exposed through the API to discover new Services.

KubeletListener

The KubeletListener relies on the Kubelet API. We're listening on changes on the container list exposed through the API (/pods) to discover new Services.

Listeners & auto-discovery

Template variable support

Listener	AD identifiers	Host	Port	Tag	Pid	Env	Hostname
Docker	✅	✅	✅	✅	✅	✅	✅
ECS	✅	✅	❌	✅	❌	✅	❌
Kubelet	✅	✅	✅	✅	❌	✅	❌

Documentation

Index

• Variables
• func ComputeContainerServiceIDs(entity string, image string, labels map[string]string) []string
• func Register(name string, factory ServiceListenerFactory)
• type ContainerPort
• type ID
• type Service
• type ServiceListener
• type ServiceListenerFactory

Variables

var ErrNotSupported = errors.New("AD: variable not supported by listener")

ErrNotSupported is thrown if listener doesn't support the asked variable

var ServiceListenerFactories = make(map[string]ServiceListenerFactory)

ServiceListenerFactories holds the registered factories

Functions

func ComputeContainerServiceIDs

func ComputeContainerServiceIDs(entity string, image string, labels map[string]string) []string

ComputeContainerServiceIDs takes an entity name, an image (resolved to an actual name) and labels and computes the service IDs for this container service.

func Register

func Register(name string, factory ServiceListenerFactory)

Register registers a service listener factory

Types

type ContainerPort

type ContainerPort struct {
	Port int
	Name string
}

ContainerPort represents a network port in a Service.

type ID

type ID string

ID is the representation of the unique ID of a Service

type Service

type Service interface {
	GetEntity() string                         // unique entity name
	GetTaggerEntity() string                   // tagger entity name
	GetADIdentifiers() ([]string, error)       // identifiers on which templates will be matched
	GetHosts() (map[string]string, error)      // network --> IP address
	GetPorts() ([]ContainerPort, error)        // network ports
	GetTags() ([]string, error)                // tags
	GetPid() (int, error)                      // process identifier
	GetHostname() (string, error)              // hostname.domainname for the entity
	GetCreationTime() integration.CreationTime // created before or after the agent start
	IsReady() bool                             // is the service ready
	GetCheckNames() []string                   // slice of check names defined in kubernetes annotations or docker labels
}

Service represents an application we can run a check against. It should be matched with a check template by the ConfigResolver using the ADIdentifiers field.

type ServiceListener

type ServiceListener interface {
	Listen(newSvc, delSvc chan<- Service)
	Stop()
}

ServiceListener monitors running services and triggers check (un)scheduling

It holds a cache of running services, listens to new/killed services and updates its cache, and the AutoConfig with these events.

type ServiceListenerFactory

type ServiceListenerFactory func() (ServiceListener, error)

ServiceListenerFactory builds a service listener