upstream

Documentation

Index

• type Upstream
  • func New(cfg config.Upstream) *Upstream
  • func (this *Upstream) Discover() <-chan []core.Backend
  • func (this *Upstream) Start()
  • func (this *Upstream) Stop()
• type UpstreamOpts

Types

type Upstream

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

*

• Upstream

func New

func New(cfg config.Upstream) *Upstream

*

• Create new Upstream based on strategy

func (*Upstream) Discover

func (this *Upstream) Discover() <-chan []core.Backend

*

• Returns backends channel

func (*Upstream) Start

func (this *Upstream) Start()

*

• Pull / fetch backends loop

func (*Upstream) Stop

func (this *Upstream) Stop()

*

• Stop discovery

type UpstreamOpts

type UpstreamOpts struct {
	RetryWaitDuration time.Duration
}

*

• Options for pull discovery