discovery

Documentation

Index

• func NewConsulDiscovery(cfg config.DiscoveryConfig) interface{}
• func NewDockerDiscovery(cfg config.DiscoveryConfig) interface{}
• func NewExecDiscovery(cfg config.DiscoveryConfig) interface{}
• func NewJsonDiscovery(cfg config.DiscoveryConfig) interface{}
• func NewLXDDiscovery(cfg config.DiscoveryConfig) interface{}
• func NewPlaintextDiscovery(cfg config.DiscoveryConfig) interface{}
• func NewSrvDiscovery(cfg config.DiscoveryConfig) interface{}
• func NewStaticDiscovery(cfg config.DiscoveryConfig) interface{}
• type Discovery
  • func New(strategy string, cfg config.DiscoveryConfig) *Discovery
  • func (discovery *Discovery) Discover() <-chan []core.Backend
  • func (discovery *Discovery) Start()
  • func (discovery *Discovery) Stop()
• type DiscoveryOpts
• type FetchFunc

Functions

func NewConsulDiscovery

func NewConsulDiscovery(cfg config.DiscoveryConfig) interface{}

*

• Create new Discovery with Consul fetch func

func NewDockerDiscovery

func NewDockerDiscovery(cfg config.DiscoveryConfig) interface{}

*

• Create new Discovery with Docker fetch func

func NewExecDiscovery

func NewExecDiscovery(cfg config.DiscoveryConfig) interface{}

*

• Create new Discovery with Exec fetch func

func NewJsonDiscovery

func NewJsonDiscovery(cfg config.DiscoveryConfig) interface{}

*

• Create new Discovery with Json fetch func

func NewLXDDiscovery

func NewLXDDiscovery(cfg config.DiscoveryConfig) interface{}

*

• Create new Discovery with LXD fetch func

func NewPlaintextDiscovery

func NewPlaintextDiscovery(cfg config.DiscoveryConfig) interface{}

*

• Create new Discovery with Plaintext fetch func

func NewSrvDiscovery

func NewSrvDiscovery(cfg config.DiscoveryConfig) interface{}

func NewStaticDiscovery

func NewStaticDiscovery(cfg config.DiscoveryConfig) interface{}

*

• Creates new static discovery

Types

type Discovery

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

*

• Discovery

func New

func New(strategy string, cfg config.DiscoveryConfig) *Discovery

*

• Create new Discovery based on strategy

func (*Discovery) Discover

func (discovery *Discovery) Discover() <-chan []core.Backend

*

• Returns backends channel

func (*Discovery) Start

func (discovery *Discovery) Start()

*

• Pull / fetch backends loop

func (*Discovery) Stop

func (discovery *Discovery) Stop()

*

• Stop discovery

type DiscoveryOpts

type DiscoveryOpts struct {
	RetryWaitDuration time.Duration
}

*

• Options for pull discovery

type FetchFunc

type FetchFunc func(config.DiscoveryConfig) (*[]core.Backend, error)

*

• Fetch func for pullig backends