dopplerservice

package
v74.0.2+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 16, 2017 License: Apache-2.0, BSD-3-Clause, MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
const LEGACY_ROOT = "/healthstatus/doppler"
View Source
const META_ROOT = "/doppler/meta"

Variables

This section is empty.

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)
}

Directories

Path Synopsis
This file was generated by counterfeiter
This file was generated by counterfeiter

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL