metadata

Documentation

Index

• type Fetcher
• type Poller
  • func (p *Poller) GetHealthCheckServices() (services []types.Service, err error)
  • func (p *Poller) Init(metadataURL string) error
  • func (p *Poller) OnChange(do func(string))
• type RMetaFetcher
  • func (mf RMetaFetcher) GetContainers() ([]metadata.Container, error)
  • func (mf RMetaFetcher) GetSelfHost() (metadata.Host, error)
  • func (mf RMetaFetcher) GetServices() ([]metadata.Service, error)
  • func (mf RMetaFetcher) OnChange(intervalSeconds int, do func(string))

Types

type Fetcher

type Fetcher interface {
	OnChange(intervalSeconds int, do func(string))
	GetServices() ([]metadata.Service, error)
	GetSelfHost() (metadata.Host, error)
	GetContainers() ([]metadata.Container, error)
}

type Poller

type Poller struct {
	MetaFetcher Fetcher
}

func (*Poller) GetHealthCheckServices

func (p *Poller) GetHealthCheckServices() (services []types.Service, err error)

func (*Poller) Init

func (p *Poller) Init(metadataURL string) error

func (*Poller) OnChange

func (p *Poller) OnChange(do func(string))

type RMetaFetcher

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

func (RMetaFetcher) GetContainers

func (mf RMetaFetcher) GetContainers() ([]metadata.Container, error)

func (RMetaFetcher) GetSelfHost

func (mf RMetaFetcher) GetSelfHost() (metadata.Host, error)

func (RMetaFetcher) GetServices

func (mf RMetaFetcher) GetServices() ([]metadata.Service, error)

func (RMetaFetcher) OnChange

func (mf RMetaFetcher) OnChange(intervalSeconds int, do func(string))