eureka

Documentation

Overview

Package eureka implements a syncer from eureka 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 {
	EurekaClient *fargo.EurekaConnection // Eureka API client
	Domain       string                  // Eureka 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.