discovery

package
v0.0.0-...-24a3ad3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 28, 2016 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewKubernetesDiscovery

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

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

Types

type ConsulDiscovery

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

ConsulDiscovery retrieves target information from a Consul server and updates them via watches.

func NewConsulDiscovery

func NewConsulDiscovery(conf *config.ConsulSDConfig) (*ConsulDiscovery, error)

NewConsulDiscovery returns a new ConsulDiscovery for the given config.

func (*ConsulDiscovery) Run

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

Run implements the TargetProvider interface.

type DNSDiscovery

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

DNSDiscovery periodically performs DNS-SD requests. It implements the TargetProvider interface.

func NewDNSDiscovery

func NewDNSDiscovery(conf *config.DNSSDConfig) *DNSDiscovery

NewDNSDiscovery returns a new DNSDiscovery which periodically refreshes its targets.

func (*DNSDiscovery) Run

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

Run implements the TargetProvider interface.

type EC2Discovery

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

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

func NewEC2Discovery

func NewEC2Discovery(conf *config.EC2SDConfig) *EC2Discovery

NewEC2Discovery returns a new EC2Discovery which periodically refreshes its targets.

func (*EC2Discovery) Run

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

Run implements the TargetProvider interface.

type FileDiscovery

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

func NewFileDiscovery(conf *config.FileSDConfig) *FileDiscovery

NewFileDiscovery returns a new file discovery for the given paths.

func (*FileDiscovery) Run

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

Run implements the TargetProvider interface.

type MarathonDiscovery

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

MarathonDiscovery provides service discovery based on a Marathon instance.

func NewMarathonDiscovery

func NewMarathonDiscovery(conf *config.MarathonSDConfig) *MarathonDiscovery

NewMarathonDiscovery creates a new Marathon based discovery.

func (*MarathonDiscovery) Run

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

Run implements the TargetProvider interface.

type NerveDiscovery

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

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

func NewNerveDiscovery

func NewNerveDiscovery(conf *config.NerveSDConfig) *NerveDiscovery

NewNerveDiscovery returns a new NerveDiscovery for the given config.

func (*NerveDiscovery) Run

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

Run implements the TargetProvider interface.

type ServersetDiscovery

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

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

func NewServersetDiscovery

func NewServersetDiscovery(conf *config.ServersetSDConfig) *ServersetDiscovery

NewServersetDiscovery returns a new ServersetDiscovery for the given config.

func (*ServersetDiscovery) Run

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

Run implements the TargetProvider interface.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL