consul

package
v1.5.0-beta15 Latest Latest
Warning

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

Go to latest
Published: Aug 4, 2020 License: Apache-2.0 Imports: 33 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	DefaultDnsAddress         = "127.0.0.1:8600"
	DefaultDnsPollingInterval = 5 * time.Second
)
View Source
var (
	InvalidSpecTypeError = func(us *v1.Upstream, name string) error {
		return eris.Errorf("internal error: invalid %s spec, "+
			"expected *v1.Upstream_Consul, got  %T", name, us)
	}
)

Functions

func BuildDataCenterMetadata added in v0.17.4

func BuildDataCenterMetadata(dataCenters []string, upstreams []*v1.Upstream) map[string]string

Similarly to what we do with tags, create a label for each data center and set it to "1" if the service instance is running in that data center.

func BuildTagMetadata added in v0.17.4

func BuildTagMetadata(tags []string, upstreams []*v1.Upstream) map[string]string

The ServiceTags on the Consul Upstream(s) represent all tags for Consul services with the given ServiceName across data centers. We create an endpoint label for each of these tags, where the label key is the name of the tag and the label value is "1" if the current service contains the same tag, else "0".

func NewPlugin

func NewPlugin(client consul.ConsulWatcher, resolver DnsResolver, dnsPollingInterval *time.Duration) *plugin

func UpdateUpstream added in v0.18.3

func UpdateUpstream(original, desired *v1.Upstream) (bool, error)

Types

type ConsulDnsResolver added in v1.3.7

type ConsulDnsResolver struct {
	DnsAddress string
}

func (*ConsulDnsResolver) Resolve added in v1.3.7

func (c *ConsulDnsResolver) Resolve(ctx context.Context, address string) ([]net.IPAddr, error)

type DnsResolver added in v1.3.7

type DnsResolver interface {
	Resolve(ctx context.Context, address string) ([]net.IPAddr, error)
}

Directories

Path Synopsis
Package mock_consul is a generated GoMock package.
Package mock_consul is a generated GoMock package.

Jump to

Keyboard shortcuts

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