consul

Documentation

Index

• Constants
• Variables
• func BuildDataCenterMetadata(dataCenters []string, upstreams []*v1.Upstream) map[string]string
• func BuildTagMetadata(tags []string, upstreams []*v1.Upstream) map[string]string
• func NewDnsResolverWithFallback(resolver DnsResolver) *dnsResolverWithFallback
• func NewPlugin(client consul.ConsulWatcher, resolver DnsResolver, ...) *plugin
• type DnsResolver
  • func NewConsulDnsResolver(address string) DnsResolver

Constants

const (
	ExtensionName             = "consul"
	DefaultDnsAddress         = "127.0.0.1:8600"
	DefaultDnsPollingInterval = 5 * time.Second
	DefaultTlsTagName         = "glooUseTls"
)

Variables

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

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 NewDnsResolverWithFallback

func NewDnsResolverWithFallback(resolver DnsResolver) *dnsResolverWithFallback

func NewPlugin

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

Types

type DnsResolver

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

func NewConsulDnsResolver

func NewConsulDnsResolver(address string) DnsResolver