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.