prometheus: github.com/knyar/prometheus/retrieval/discovery Index | Files | Directories

package discovery

import "github.com/knyar/prometheus/retrieval/discovery"

Index

Package Files

azure.go consul.go dns.go ec2.go file.go kubernetes.go marathon.go nerve.go serverset.go

func NewConsul Uses

func NewConsul(cfg *config.ConsulSDConfig) (*consul.Discovery, error)

NewConsul creates a new Consul based Discovery.

func NewDNS Uses

func NewDNS(conf *config.DNSSDConfig) *dns.Discovery

NewDNS creates a new DNS based discovery.

func NewKubernetesDiscovery Uses

func NewKubernetesDiscovery(conf *config.KubernetesSDConfig) (*kubernetes.Discovery, error)

NewKubernetesDiscovery creates a Kubernetes service discovery based on the passed-in configuration.

func NewMarathon Uses

func NewMarathon(conf *config.MarathonSDConfig) *marathon.Discovery

NewMarathon creates a new Marathon based discovery.

type AzureDiscovery Uses

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

AzureDiscovery periodically performs Azure-SD requests. It implements the TargetProvider interface.

func NewAzureDiscovery Uses

func NewAzureDiscovery(cfg *config.AzureSDConfig) *AzureDiscovery

NewAzureDiscovery returns a new AzureDiscovery which periodically refreshes its targets.

func (*AzureDiscovery) Run Uses

func (ad *AzureDiscovery) Run(ctx context.Context, ch chan<- []*config.TargetGroup)

Run implements the TargetProvider interface.

type EC2Discovery Uses

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

EC2Discovery periodically performs EC2-SD requests. It implements the TargetProvider interface.

func NewEC2Discovery Uses

func NewEC2Discovery(conf *config.EC2SDConfig) *EC2Discovery

NewEC2Discovery returns a new EC2Discovery which periodically refreshes its targets.

func (*EC2Discovery) Run Uses

func (ed *EC2Discovery) Run(ctx context.Context, ch chan<- []*config.TargetGroup)

Run implements the TargetProvider interface.

type FileDiscovery Uses

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

FileDiscovery provides service discovery functionality based on files that contain target groups in JSON or YAML format. Refreshing happens using file watches and periodic refreshes.

func NewFileDiscovery Uses

func NewFileDiscovery(conf *config.FileSDConfig) *FileDiscovery

NewFileDiscovery returns a new file discovery for the given paths.

func (*FileDiscovery) Run Uses

func (fd *FileDiscovery) Run(ctx context.Context, ch chan<- []*config.TargetGroup)

Run implements the TargetProvider interface.

type NerveDiscovery Uses

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

NerveDiscovery retrieves target information from a Nerve server and updates them via watches.

func NewNerveDiscovery Uses

func NewNerveDiscovery(conf *config.NerveSDConfig) *NerveDiscovery

NewNerveDiscovery returns a new NerveDiscovery for the given config.

func (*NerveDiscovery) Run Uses

func (sd *NerveDiscovery) Run(ctx context.Context, ch chan<- []*config.TargetGroup)

Run implements the TargetProvider interface.

type ServersetDiscovery Uses

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

ServersetDiscovery retrieves target information from a Serverset server and updates them via watches.

func NewServersetDiscovery Uses

func NewServersetDiscovery(conf *config.ServersetSDConfig) *ServersetDiscovery

NewServersetDiscovery returns a new ServersetDiscovery for the given config.

func (*ServersetDiscovery) Run Uses

func (sd *ServersetDiscovery) Run(ctx context.Context, ch chan<- []*config.TargetGroup)

Run implements the TargetProvider interface.

Directories

PathSynopsis
consul
dns
kubernetes
marathon

Package discovery imports 28 packages (graph). Updated 2017-06-15. Refresh now. Tools for package owners. This is a quick bug-fix fork (has fewer than three commits, and only during the week it was created).