manager

Documentation

Index

• type Cache
• type CustomProvidersManager
  • func NewCustomProvidersManager(s CustomProvidersStorage, mem CustomProvidersMemStorage) *CustomProvidersManager
  • func (m *CustomProvidersManager) CreateCustomProvider(provider *custom.Provider) (*custom.Provider, error)
  • func (m *CustomProvidersManager) GetCustomProviderFromMem(name string) *custom.Provider
  • func (m *CustomProvidersManager) GetCustomProviders() ([]*custom.Provider, error)
  • func (m *CustomProvidersManager) GetRouteConfigFromMem(name, path string) *custom.RouteConfig
  • func (m *CustomProvidersManager) UpdateCustomProvider(id string, provider *custom.UpdateProvider) (*custom.Provider, error)
• type CustomProvidersMemStorage
• type CustomProvidersStorage
• type Encrypter
• type Manager
  • func NewManager(s Storage, e Encrypter) *Manager
  • func (m *Manager) CreateKey(rk *key.RequestKey) (*key.ResponseKey, error)
  • func (m *Manager) DeleteKey(id string) error
  • func (m *Manager) GetKeys(tags []string, model string) ([]*key.ResponseKey, error)
  • func (m *Manager) UpdateKey(id string, uk *key.UpdateKey) (*key.ResponseKey, error)
• type ProviderSettingsManager
  • func NewProviderSettingsManager(s ProviderSettingsStorage, memdb ProviderSettingsMemStorage) *ProviderSettingsManager
  • func (m *ProviderSettingsManager) CreateSetting(setting *provider.Setting) (*provider.Setting, error)
  • func (m *ProviderSettingsManager) GetSetting(id string) (*provider.Setting, error)
  • func (m *ProviderSettingsManager) GetSettings() ([]*provider.Setting, error)
  • func (m *ProviderSettingsManager) UpdateSetting(id string, setting *provider.UpdateSetting) (*provider.Setting, error)
• type ProviderSettingsMemStorage
• type ProviderSettingsStorage
• type RateLimitManager
  • func NewRateLimitManager(c Cache) *RateLimitManager
  • func (rlm *RateLimitManager) Increment(keyId string, timeUnit key.TimeUnit) error
• type ReportingManager
  • func NewReportingManager(cs costStorage, ks keyStorage, es eventStorage) *ReportingManager
  • func (rm *ReportingManager) GetEvent(customId string) (*event.Event, error)
  • func (rm *ReportingManager) GetEventReporting(e *event.ReportingRequest) (*event.ReportingResponse, error)
  • func (rm *ReportingManager) GetEvents(customId string) ([]*event.Event, error)
  • func (rm *ReportingManager) GetKeyReporting(keyId string) (*key.KeyReporting, error)
• type Storage

Types

type Cache

type Cache interface {
	IncrementCounter(keyId string, rateLimitUnit key.TimeUnit, incr int64) error
}

type CustomProvidersManager

type CustomProvidersManager struct {
	Storage CustomProvidersStorage
	Mem     CustomProvidersMemStorage
}

func NewCustomProvidersManager

func NewCustomProvidersManager(s CustomProvidersStorage, mem CustomProvidersMemStorage) *CustomProvidersManager

func (*CustomProvidersManager) CreateCustomProvider

func (m *CustomProvidersManager) CreateCustomProvider(provider *custom.Provider) (*custom.Provider, error)

func (*CustomProvidersManager) GetCustomProviderFromMem

func (m *CustomProvidersManager) GetCustomProviderFromMem(name string) *custom.Provider

func (*CustomProvidersManager) GetCustomProviders

func (m *CustomProvidersManager) GetCustomProviders() ([]*custom.Provider, error)

func (*CustomProvidersManager) GetRouteConfigFromMem

func (m *CustomProvidersManager) GetRouteConfigFromMem(name, path string) *custom.RouteConfig

func (*CustomProvidersManager) UpdateCustomProvider

func (m *CustomProvidersManager) UpdateCustomProvider(id string, provider *custom.UpdateProvider) (*custom.Provider, error)

type CustomProvidersMemStorage

type CustomProvidersMemStorage interface {
	GetProvider(name string) *custom.Provider
	GetRouteConfig(name, path string) *custom.RouteConfig
}

type CustomProvidersStorage

type CustomProvidersStorage interface {
	CreateCustomProvider(provider *custom.Provider) (*custom.Provider, error)
	GetCustomProviders() ([]*custom.Provider, error)
	GetCustomProviderByName(name string) (*custom.Provider, error)
	GetCustomProvider(id string) (*custom.Provider, error)
	UpdateCustomProvider(id string, provider *custom.UpdateProvider) (*custom.Provider, error)
}

type Encrypter

type Encrypter interface {
	Encrypt(secret string) string
}

type Manager

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

func NewManager

func NewManager(s Storage, e Encrypter) *Manager

func (*Manager) CreateKey

func (m *Manager) CreateKey(rk *key.RequestKey) (*key.ResponseKey, error)

func (*Manager) DeleteKey

func (m *Manager) DeleteKey(id string) error

func (*Manager) GetKeys

func (m *Manager) GetKeys(tags []string, model string) ([]*key.ResponseKey, error)

func (*Manager) UpdateKey

func (m *Manager) UpdateKey(id string, uk *key.UpdateKey) (*key.ResponseKey, error)

type ProviderSettingsManager

type ProviderSettingsManager struct {
	Storage ProviderSettingsStorage
	MemDb   ProviderSettingsMemStorage
}

func NewProviderSettingsManager

func NewProviderSettingsManager(s ProviderSettingsStorage, memdb ProviderSettingsMemStorage) *ProviderSettingsManager

func (*ProviderSettingsManager) CreateSetting

func (m *ProviderSettingsManager) CreateSetting(setting *provider.Setting) (*provider.Setting, error)

func (*ProviderSettingsManager) GetSetting

func (m *ProviderSettingsManager) GetSetting(id string) (*provider.Setting, error)

func (*ProviderSettingsManager) GetSettings

func (m *ProviderSettingsManager) GetSettings() ([]*provider.Setting, error)

func (*ProviderSettingsManager) UpdateSetting

func (m *ProviderSettingsManager) UpdateSetting(id string, setting *provider.UpdateSetting) (*provider.Setting, error)

type ProviderSettingsMemStorage

type ProviderSettingsMemStorage interface {
	GetSetting(id string) *provider.Setting
}

type ProviderSettingsStorage

type ProviderSettingsStorage interface {
	UpdateProviderSetting(id string, setting *provider.UpdateSetting) (*provider.Setting, error)
	CreateProviderSetting(setting *provider.Setting) (*provider.Setting, error)
	GetProviderSetting(id string) (*provider.Setting, error)
	GetCustomProviderByName(name string) (*custom.Provider, error)
	GetProviderSettings(withSecret bool) ([]*provider.Setting, error)
}

type RateLimitManager

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

func NewRateLimitManager

func NewRateLimitManager(c Cache) *RateLimitManager

func (*RateLimitManager) Increment

func (rlm *RateLimitManager) Increment(keyId string, timeUnit key.TimeUnit) error

type ReportingManager

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

func NewReportingManager

func NewReportingManager(cs costStorage, ks keyStorage, es eventStorage) *ReportingManager

func (*ReportingManager) GetEvent

func (rm *ReportingManager) GetEvent(customId string) (*event.Event, error)

func (*ReportingManager) GetEventReporting

func (rm *ReportingManager) GetEventReporting(e *event.ReportingRequest) (*event.ReportingResponse, error)

func (*ReportingManager) GetEvents

func (rm *ReportingManager) GetEvents(customId string) ([]*event.Event, error)

func (*ReportingManager) GetKeyReporting

func (rm *ReportingManager) GetKeyReporting(keyId string) (*key.KeyReporting, error)

type Storage

type Storage interface {
	GetKeys(tags []string, provider string) ([]*key.ResponseKey, error)
	UpdateKey(id string, key *key.UpdateKey) (*key.ResponseKey, error)
	CreateKey(key *key.RequestKey) (*key.ResponseKey, error)
	DeleteKey(id string) error
	GetProviderSetting(id string) (*provider.Setting, error)
}