rest

Documentation

Index

• type Source
  • func (src *Source) Close()
  • func (src *Source) Connect() (sink <-chan deps.Dep, err error)
  • func (src *Source) Init(conf *config.Config)

Types

type Source

type Source struct {
	Config *config.Config
	Ticker *time.Ticker
}

Source implements the DepSource interface for http

func (*Source) Close

func (src *Source) Close()

Close stop the fetching

func (*Source) Connect

func (src *Source) Connect() (sink <-chan deps.Dep, err error)

Connect starts fetching using the rest interface.

func (*Source) Init

func (src *Source) Init(conf *config.Config)

Init initializes the http source