fetcher

Documentation

Index

• type DataManager
  • func NewDataManager(fetcher Fetcher, name string, interval time.Duration) *DataManager
  • func (m *DataManager) GetLastChanges() time.Time
  • func (m *DataManager) Lock()
  • func (m *DataManager) RLock()
  • func (m *DataManager) RUnlock()
  • func (m *DataManager) Start(stopCh <-chan struct{}, changesCh chan<- struct{}) error
  • func (m *DataManager) Unlock()
• type Fetcher

Types

type DataManager

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

func NewDataManager

func NewDataManager(fetcher Fetcher, name string, interval time.Duration) *DataManager

func (*DataManager) GetLastChanges

func (m *DataManager) GetLastChanges() time.Time

func (*DataManager) Lock

func (m *DataManager) Lock()

func (*DataManager) RLock

func (m *DataManager) RLock()

func (*DataManager) RUnlock

func (m *DataManager) RUnlock()

func (*DataManager) Start

func (m *DataManager) Start(stopCh <-chan struct{}, changesCh chan<- struct{}) error

func (*DataManager) Unlock

func (m *DataManager) Unlock()

type Fetcher

type Fetcher interface {
	GetData() (interface{}, error)
	ProcessData(interface{}) error
	GetLastChanges() time.Time
	GetCheckSum(interface{}) string
}