discovery

Documentation

Index

• func NewConsul(cfg *config.ConsulSDConfig) (*consul.Discovery, error)
• func NewDNS(conf *config.DNSSDConfig) *dns.Discovery
• func NewKubernetesDiscovery(conf *config.KubernetesSDConfig) (*kubernetes.Discovery, error)
• func NewMarathon(conf *config.MarathonSDConfig) *marathon.Discovery
• type AzureDiscovery
  • func NewAzureDiscovery(cfg *config.AzureSDConfig) *AzureDiscovery
  • func (ad *AzureDiscovery) Run(ctx context.Context, ch chan<- []*config.TargetGroup)
• type EC2Discovery
  • func NewEC2Discovery(conf *config.EC2SDConfig) *EC2Discovery
  • func (ed *EC2Discovery) Run(ctx context.Context, ch chan<- []*config.TargetGroup)
• type FileDiscovery
  • func NewFileDiscovery(conf *config.FileSDConfig) *FileDiscovery
  • func (fd *FileDiscovery) Run(ctx context.Context, ch chan<- []*config.TargetGroup)
• type NerveDiscovery
  • func NewNerveDiscovery(conf *config.NerveSDConfig) *NerveDiscovery
  • func (sd *NerveDiscovery) Run(ctx context.Context, ch chan<- []*config.TargetGroup)
• type ServersetDiscovery
  • func NewServersetDiscovery(conf *config.ServersetSDConfig) *ServersetDiscovery
  • func (sd *ServersetDiscovery) Run(ctx context.Context, ch chan<- []*config.TargetGroup)

Functions

func NewConsul

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

NewConsul creates a new Consul based Discovery.

func NewDNS

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

NewDNS creates a new DNS based discovery.

func NewKubernetesDiscovery

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

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

func NewMarathon

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

NewMarathon creates a new Marathon based discovery.

Types

type AzureDiscovery

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

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

func NewAzureDiscovery

func NewAzureDiscovery(cfg *config.AzureSDConfig) *AzureDiscovery

NewAzureDiscovery returns a new AzureDiscovery which periodically refreshes its targets.

func (*AzureDiscovery) Run

func (ad *AzureDiscovery) 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 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.