consul

Documentation

Overview

Package consul implements a syncer from consul to k8s.

Index

• type Source
  • func (s *Source) Aggregate(svcName connector.MicroSvcName, svcDomainName connector.MicroSvcDomainName) (map[connector.MicroSvcName]*connector.MicroSvcMeta, string)
  • func (s *Source) Run(ctx context.Context)

Types

type Source

type Source struct {
	ConsulClient *api.Client     // Consul API client
	Domain       string          // Consul DNS domain
	Sink         *connector.Sink // Sink is the sink to update with services
	Prefix       string          // Prefix is a prefix to prepend to services
	FilterTag    string          // The tag value for services registered
	PrefixTag    string
	SuffixTag    string
	PassingOnly  bool
}

Source is the source for the sync that watches Consul services and updates a Sink whenever the set of services to register changes.

func (*Source) Aggregate

func (s *Source) Aggregate(svcName connector.MicroSvcName, svcDomainName connector.MicroSvcDomainName) (map[connector.MicroSvcName]*connector.MicroSvcMeta, string)

Aggregate micro services

func (*Source) Run

func (s *Source) Run(ctx context.Context)

Run is the long-running loop for watching Consul services and updating the Sink.