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
• 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
	DefaultTlsTagName         = "glooUseTls"

	UnformattedErrorMsg = "Consul settings specify automatic detection of TLS services, " +
		"but the rootCA resource's name/namespace are not properly specified: {%s}"
	ConsulTlsInputError = func(nsString string) error {
		return eris.Errorf(UnformattedErrorMsg, nsString)
	}
)

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 tag from the gloo upstreams, where the label key is the name of the tag and the label value is "1" if the current service contains the same tag, and "0" otherwise.

func NewPlugin

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

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)
}