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
NewConsulDiscovery returns a new ConsulDiscovery for the given config.
func (*ConsulDiscovery) Run ¶
func (cd *ConsulDiscovery) Run(ch chan<- *config.TargetGroup, done <-chan struct{})
Run implements the TargetProvider interface.
func (*ConsulDiscovery) Sources ¶
func (cd *ConsulDiscovery) Sources() []string
Sources 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(ch chan<- *config.TargetGroup, done <-chan struct{})
Run implements the TargetProvider interface.
func (*DNSDiscovery) Sources ¶
func (dd *DNSDiscovery) Sources() []string
Sources 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(ch chan<- *config.TargetGroup, done <-chan struct{})
Run implements the TargetProvider interface.
func (*FileDiscovery) Sources ¶
func (fd *FileDiscovery) Sources() []string
Sources 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(ch chan<- *config.TargetGroup, done <-chan struct{})
Run implements the TargetProvider interface.
func (*MarathonDiscovery) Sources ¶
func (md *MarathonDiscovery) Sources() []string
Sources 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(ch chan<- *config.TargetGroup, done <-chan struct{})
Run implements the TargetProvider interface.
func (*ServersetDiscovery) Sources ¶
func (sd *ServersetDiscovery) Sources() []string
Sources implements the TargetProvider interface.
Source Files
Directories