rets

Documentation

Index

• type Retriever
  • func NewRetriever(dcName string, nbWorkers int, interval time.Duration, ...) *Retriever
  • func (r *Retriever) DisableCatalogPolling()
  • func (r *Retriever) Run(ctx context.Context) error

Types

type Retriever

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

func NewRetriever

func NewRetriever(dcName string, nbWorkers int, interval time.Duration, consulClient *consul.Client) *Retriever

func (*Retriever) DisableCatalogPolling

func (r *Retriever) DisableCatalogPolling()

func (*Retriever) Run

func (r *Retriever) Run(ctx context.Context) error