dopplerservice

Documentation

Index

• Constants
• func Announce(localIP string, ttl time.Duration, config *config.Config, ...) chan (chan bool)
• func AnnounceLegacy(localIP string, ttl time.Duration, config *config.Config, ...) chan (chan bool)
• type DopplerEvent
• type DopplerMeta
• type Event
• type Finder
  • func NewFinder(adapter StoreAdapter, legacyPort, grpcPort int, protocols []string, ...) *Finder
  • func (f *Finder) Next() Event
  • func (f *Finder) Start()
  • func (f *Finder) WebsocketServers() []string
• type StoreAdapter

Constants

const LEGACY_ROOT = "/healthstatus/doppler"

const META_ROOT = "/doppler/meta"

Functions

func Announce

func Announce(localIP string, ttl time.Duration, config *config.Config, storeAdapter storeadapter.StoreAdapter) chan (chan bool)

func AnnounceLegacy

func AnnounceLegacy(localIP string, ttl time.Duration, config *config.Config, storeAdapter storeadapter.StoreAdapter) chan (chan bool)

Types

type DopplerEvent

type DopplerEvent struct {
	Version   int `json:"version"`
	Endpoints set `json:"endpoints"`
}

type DopplerMeta

type DopplerMeta struct {
	Version   uint32   `json:"version"`
	Endpoints []string `json:"endpoints"`
}

type Event

type Event struct {
	GRPCDopplers []string
	UDPDopplers  []string
	TLSDopplers  []string
	TCPDopplers  []string
}

type Finder

type Finder struct {
	// contains filtered or unexported fields
}

func NewFinder

func NewFinder(adapter StoreAdapter, legacyPort, grpcPort int, protocols []string, preferredDopplerZone string) *Finder

func (*Finder) Next

func (f *Finder) Next() Event

func (*Finder) Start

func (f *Finder) Start()

func (*Finder) WebsocketServers

func (f *Finder) WebsocketServers() []string

type StoreAdapter

type StoreAdapter interface {
	Watch(key string) (events <-chan storeadapter.WatchEvent, stop chan<- bool, errors <-chan error)
	ListRecursively(key string) (storeadapter.StoreNode, error)
}