memdb

Documentation

Index

• type MemDb
  • func NewMemDb(ex Storage, log *zap.Logger, interval time.Duration) (*MemDb, error)
  • func (mdb *MemDb) GetKey(hash string) *key.ResponseKey
  • func (mdb *MemDb) Listen()
  • func (mdb *MemDb) RemoveKey(k *key.ResponseKey)
  • func (mdb *MemDb) SetKey(k *key.ResponseKey)
  • func (mdb *MemDb) Stop()
• type ProviderSettingsMemDb
  • func NewProviderSettingsMemDb(ex ProviderSettingsStorage, log *zap.Logger, interval time.Duration) (*ProviderSettingsMemDb, error)
  • func (mdb *ProviderSettingsMemDb) GetSetting(k string) *provider.Setting
  • func (mdb *ProviderSettingsMemDb) Listen()
  • func (mdb *ProviderSettingsMemDb) RemoveSetting(k string)
  • func (mdb *ProviderSettingsMemDb) SetSetting(k string, v *provider.Setting)
  • func (mdb *ProviderSettingsMemDb) Stop()
• type ProviderSettingsStorage
• type Storage

Types

type MemDb

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

func NewMemDb

func NewMemDb(ex Storage, log *zap.Logger, interval time.Duration) (*MemDb, error)

func (*MemDb) GetKey

func (mdb *MemDb) GetKey(hash string) *key.ResponseKey

func (*MemDb) Listen

func (mdb *MemDb) Listen()

func (*MemDb) RemoveKey

func (mdb *MemDb) RemoveKey(k *key.ResponseKey)

func (*MemDb) SetKey

func (mdb *MemDb) SetKey(k *key.ResponseKey)

func (*MemDb) Stop

func (mdb *MemDb) Stop()

type ProviderSettingsMemDb

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

func NewProviderSettingsMemDb

func NewProviderSettingsMemDb(ex ProviderSettingsStorage, log *zap.Logger, interval time.Duration) (*ProviderSettingsMemDb, error)

func (*ProviderSettingsMemDb) GetSetting

func (mdb *ProviderSettingsMemDb) GetSetting(k string) *provider.Setting

func (*ProviderSettingsMemDb) Listen

func (mdb *ProviderSettingsMemDb) Listen()

func (*ProviderSettingsMemDb) RemoveSetting

func (mdb *ProviderSettingsMemDb) RemoveSetting(k string)

func (*ProviderSettingsMemDb) SetSetting

func (mdb *ProviderSettingsMemDb) SetSetting(k string, v *provider.Setting)

func (*ProviderSettingsMemDb) Stop

func (mdb *ProviderSettingsMemDb) Stop()

type ProviderSettingsStorage

type ProviderSettingsStorage interface {
	GetAllProviderSettings() ([]*provider.Setting, error)
	GetUpdatedProviderSettings(interval time.Duration) ([]*provider.Setting, error)
}

type Storage

type Storage interface {
	GetAllKeys() ([]*key.ResponseKey, error)
	GetUpdatedKeys(interval time.Duration) ([]*key.ResponseKey, error)
}