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) *plugin
• func UpdateUpstream(original, desired *v1.Upstream) (bool, error)

Variables

var (
	InvalidSpecTypeError = func(spec *v1.UpstreamSpec, name string) error {
		return errors.Errorf("internal error: invalid %s spec, "+
			"expected *v1.UpstreamSpec_Consul, got  %T", name, spec.UpstreamType)
	}
)

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) *plugin

func UpdateUpstream

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