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 PoliciesStorage
• 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) GetSettings(ks []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 RoutesMemDb
  • func NewRoutesMemDb(ex RoutesStorage, ps PoliciesStorage, log *zap.Logger, interval time.Duration) (*RoutesMemDb, error)
  • func (mdb *RoutesMemDb) GetPolicy(id string) *policy.Policy
  • func (mdb *RoutesMemDb) GetRoute(path string) *route.Route
  • func (mdb *RoutesMemDb) Listen()
  • func (mdb *RoutesMemDb) SetPolicy(p *policy.Policy)
  • func (mdb *RoutesMemDb) SetRoute(r *route.Route)
  • func (mdb *RoutesMemDb) Stop()
• type RoutesStorage
• 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 PoliciesStorage

type PoliciesStorage interface {
	GetAllPolicies() ([]*policy.Policy, error)
	GetUpdatedPolicies(updatedAt int64) ([]*policy.Policy, error)
}

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) GetSettings

func (mdb *ProviderSettingsMemDb) GetSettings(ks []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, ids []string) ([]*provider.Setting, error)
	GetUpdatedProviderSettings(updatedAt int64) ([]*provider.Setting, error)
}

type RoutesMemDb

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

func NewRoutesMemDb

func NewRoutesMemDb(ex RoutesStorage, ps PoliciesStorage, log *zap.Logger, interval time.Duration) (*RoutesMemDb, error)

func (*RoutesMemDb) GetPolicy

func (mdb *RoutesMemDb) GetPolicy(id string) *policy.Policy

func (*RoutesMemDb) GetRoute

func (mdb *RoutesMemDb) GetRoute(path string) *route.Route

func (*RoutesMemDb) Listen

func (mdb *RoutesMemDb) Listen()

func (*RoutesMemDb) SetPolicy

func (mdb *RoutesMemDb) SetPolicy(p *policy.Policy)

func (*RoutesMemDb) SetRoute

func (mdb *RoutesMemDb) SetRoute(r *route.Route)

func (*RoutesMemDb) Stop

func (mdb *RoutesMemDb) Stop()

type RoutesStorage

type RoutesStorage interface {
	GetRoutes() ([]*route.Route, error)
	GetUpdatedRoutes(updatedAt int64) ([]*route.Route, error)
}

type Storage

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