consul

Documentation

Index

• Variables
• func BuildDataCenterMetadata(dataCenters []string, upstreams []*v1.Upstream) map[string]string
• func BuildTagMetadata(tags []string, upstreams []*v1.Upstream) map[string]string
• func NewPlugin(client consul.ConsulWatcher, resolver DnsResolver, ...) *plugin
• func UpdateUpstream(original, desired *v1.Upstream) (bool, error)
• type ConsulDnsResolver
  • func (c *ConsulDnsResolver) Resolve(ctx context.Context, address string) ([]net.IPAddr, error)
• type DnsResolver

Variables

var (
	DefaultDnsAddress         = "127.0.0.1:8600"
	DefaultDnsPollingInterval = 5 * time.Second
)

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

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

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

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

Types

type ConsulDnsResolver

type ConsulDnsResolver struct {
	DnsAddress string
}

func (*ConsulDnsResolver) Resolve

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

type DnsResolver

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