local

Documentation

Index

• type Config
  • func (c *Config) NewDataGatherer(ctx context.Context) (datagatherer.DataGatherer, error)
• type DataGatherer
  • func (g *DataGatherer) Delete() error
  • func (g *DataGatherer) Fetch() (interface{}, int, error)
  • func (g *DataGatherer) Run(stopCh <-chan struct{}) error
  • func (g *DataGatherer) WaitForCacheSync(stopCh <-chan struct{}) error

Types

type Config

type Config struct {
	// DataPath is the path to file containing the data to load.
	DataPath string `yaml:"data-path"`
}

Config is the configuration for a local DataGatherer.

func (*Config) NewDataGatherer

func (c *Config) NewDataGatherer(ctx context.Context) (datagatherer.DataGatherer, error)

NewDataGatherer returns a new DataGatherer.

type DataGatherer

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

DataGatherer is a data-gatherer that loads data from a local file.

func (*DataGatherer) Delete

func (g *DataGatherer) Delete() error

func (*DataGatherer) Fetch

func (g *DataGatherer) Fetch() (interface{}, int, error)

Fetch loads and returns the data from the LocalDatagatherer's dataPath

func (*DataGatherer) Run

func (g *DataGatherer) Run(stopCh <-chan struct{}) error

func (*DataGatherer) WaitForCacheSync

func (g *DataGatherer) WaitForCacheSync(stopCh <-chan struct{}) error