rets

Documentation

Index

• type Retriever
  • func NewRetriever(dcName string, nbWorkers int, interval time.Duration, ...) *Retriever
  • func (r *Retriever) DisableCatalogPolling()
  • func (r *Retriever) GetEntry(fqdn string) (*entries.SignedEntry, bool)
  • func (r *Retriever) ListEntries(prefix string) []*entries.SignedEntry
  • 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) GetEntry

func (r *Retriever) GetEntry(fqdn string) (*entries.SignedEntry, bool)

func (*Retriever) ListEntries

func (r *Retriever) ListEntries(prefix string) []*entries.SignedEntry

func (*Retriever) Run

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