manager

Documentation

Index

• type Cache
• 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) GetKeysByTag(tag string) ([]*key.ResponseKey, error)
  • func (m *Manager) UpdateKey(id string, uk *key.UpdateKey) (*key.ResponseKey, error)
• 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) *ReportingManager
  • 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 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) GetKeysByTag

func (m *Manager) GetKeysByTag(tag string) ([]*key.ResponseKey, error)

func (*Manager) UpdateKey

func (m *Manager) UpdateKey(id string, uk *key.UpdateKey) (*key.ResponseKey, 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) *ReportingManager

func (*ReportingManager) GetKeyReporting

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

type Storage

type Storage interface {
	GetKeysByTag(tag string) ([]*key.ResponseKey, error)
	UpdateKey(id string, key *key.UpdateKey) (*key.ResponseKey, error)
	CreateKey(key *key.RequestKey) (*key.ResponseKey, error)
	DeleteKey(id string) error
}