memdb

Documentation

Index

• type CustomProvidersMemDb
  • func NewCustomProvidersMemDb(ex CustomProvidersStorage, log *zap.Logger, interval time.Duration) (*CustomProvidersMemDb, error)
  • func (mdb *CustomProvidersMemDb) GetProvider(name string) *custom.Provider
  • func (mdb *CustomProvidersMemDb) GetRouteConfig(name string, path string) *custom.RouteConfig
  • func (mdb *CustomProvidersMemDb) Listen()
  • func (mdb *CustomProvidersMemDb) SetProvider(provider *custom.Provider)
  • func (mdb *CustomProvidersMemDb) Stop()
• type CustomProvidersStorage
• 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(s *provider.Setting)
  • func (mdb *ProviderSettingsMemDb) Stop()
• type ProviderSettingsStorage
• type Storage

Types

type CustomProvidersMemDb

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

func NewCustomProvidersMemDb

func NewCustomProvidersMemDb(ex CustomProvidersStorage, log *zap.Logger, interval time.Duration) (*CustomProvidersMemDb, error)

func (*CustomProvidersMemDb) GetProvider

func (mdb *CustomProvidersMemDb) GetProvider(name string) *custom.Provider

func (*CustomProvidersMemDb) GetRouteConfig

func (mdb *CustomProvidersMemDb) GetRouteConfig(name string, path string) *custom.RouteConfig

func (*CustomProvidersMemDb) Listen

func (mdb *CustomProvidersMemDb) Listen()

func (*CustomProvidersMemDb) SetProvider

func (mdb *CustomProvidersMemDb) SetProvider(provider *custom.Provider)

func (*CustomProvidersMemDb) Stop

func (mdb *CustomProvidersMemDb) Stop()

type CustomProvidersStorage

type CustomProvidersStorage interface {
	GetCustomProviders() ([]*custom.Provider, error)
	GetUpdatedCustomProviders(updatedAt int64) ([]*custom.Provider, error)
}

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(s *provider.Setting)

func (*ProviderSettingsMemDb) Stop

func (mdb *ProviderSettingsMemDb) Stop()

type ProviderSettingsStorage

type ProviderSettingsStorage interface {
	GetProviderSettings(withSecret bool) ([]*provider.Setting, error)
	GetUpdatedProviderSettings(updatedAt int64) ([]*provider.Setting, error)
}

type Storage

type Storage interface {
	GetAllKeys() ([]*key.ResponseKey, error)
	GetUpdatedKeys(updatedAt int64) ([]*key.ResponseKey, error)
}