data_provider

Documentation

Index

• type DataListener
• type DataManager
  • func NewDataManager() *DataManager
  • func (m *DataManager) AddDataProvider(name string, p *DataProvider)
  • func (m *DataManager) GetDataProvider(name string) *DataProvider
• type DataProvider
  • func NewDataProvider(lg *zap.Logger, cfg *DataProviderConfig) (*DataProvider, error)
  • func (ds *DataProvider) Close()
  • func (ds *DataProvider) GetData() ([]byte, error)
  • func (ds *DataProvider) GetNotifier() *notifier.Notifier
  • func (ds *DataProvider) LoadAndAddListener(l DataListener) error
• type DataProviderConfig

Types

type DataListener

type DataListener interface {
	Update(newData []byte) error
}

type DataManager

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

func NewDataManager

func NewDataManager() *DataManager

func (*DataManager) AddDataProvider

func (m *DataManager) AddDataProvider(name string, p *DataProvider)

func (*DataManager) GetDataProvider

func (m *DataManager) GetDataProvider(name string) *DataProvider

type DataProvider

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

func NewDataProvider

func NewDataProvider(lg *zap.Logger, cfg *DataProviderConfig) (*DataProvider, error)

func (*DataProvider) Close

func (ds *DataProvider) Close()

func (*DataProvider) GetData

func (ds *DataProvider) GetData() ([]byte, error)

func (*DataProvider) GetNotifier

func (ds *DataProvider) GetNotifier() *notifier.Notifier

func (*DataProvider) LoadAndAddListener

func (ds *DataProvider) LoadAndAddListener(l DataListener) error

LoadAndAddListener loads the DataListener, returns any error that occurs, and add this DataListener to this DataProvider.

type DataProviderConfig

type DataProviderConfig struct {
	Tag        string `yaml:"tag"`
	File       string `yaml:"file"`
	AutoReload bool   `yaml:"auto_reload"`
}