Documentation ¶
Index ¶
- func NewPool(addr string) *redigo.Pool
- type ApiKeyStorage
- func (s *ApiKeyStorage) Delete(key string) error
- func (s *ApiKeyStorage) GetAll() (apikey.ApiKeyMap, error)
- func (s *ApiKeyStorage) GetByKey(key string) (*apikey.ApiKey, error)
- func (s *ApiKeyStorage) GetByName(name string) (*apikey.ApiKey, error)
- func (s *ApiKeyStorage) Save(apikey apikey.ApiKey) error
- type MediaStorage
- type NamedTransformationStorage
- func (s *NamedTransformationStorage) Delete(name string) error
- func (s *NamedTransformationStorage) DeleteAll() error
- func (s *NamedTransformationStorage) Get(name string) (*transform.NamedTransformation, error)
- func (s *NamedTransformationStorage) GetAll() (transform.NamedTransformationMap, error)
- func (s *NamedTransformationStorage) Save(namedTransformation transform.NamedTransformation) error
- type TaskStorage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ApiKeyStorage ¶
type ApiKeyStorage struct {
// contains filtered or unexported fields
}
func NewApiKeyStorage ¶
func NewApiKeyStorage(redisPool *redigo.Pool) *ApiKeyStorage
func (*ApiKeyStorage) Delete ¶
func (s *ApiKeyStorage) Delete(key string) error
func (*ApiKeyStorage) GetByKey ¶
func (s *ApiKeyStorage) GetByKey(key string) (*apikey.ApiKey, error)
type MediaStorage ¶
type MediaStorage struct {
// contains filtered or unexported fields
}
func NewMediaStorage ¶
func NewMediaStorage(redisPool *redigo.Pool) *MediaStorage
func (*MediaStorage) GetMultiple ¶
type NamedTransformationStorage ¶
type NamedTransformationStorage struct {
// contains filtered or unexported fields
}
func NewNamedTransformationStorage ¶
func NewNamedTransformationStorage(redisPool *redigo.Pool) *NamedTransformationStorage
func (*NamedTransformationStorage) Delete ¶
func (s *NamedTransformationStorage) Delete(name string) error
func (*NamedTransformationStorage) DeleteAll ¶
func (s *NamedTransformationStorage) DeleteAll() error
func (*NamedTransformationStorage) Get ¶
func (s *NamedTransformationStorage) Get(name string) (*transform.NamedTransformation, error)
func (*NamedTransformationStorage) GetAll ¶
func (s *NamedTransformationStorage) GetAll() (transform.NamedTransformationMap, error)
func (*NamedTransformationStorage) Save ¶
func (s *NamedTransformationStorage) Save(namedTransformation transform.NamedTransformation) error
type TaskStorage ¶
type TaskStorage struct {
// contains filtered or unexported fields
}
func NewTaskStorage ¶
func NewTaskStorage(redisPool *redigo.Pool) *TaskStorage
func (*TaskStorage) DequeueTask ¶
func (s *TaskStorage) DequeueTask() (*scheduler.Task, error)
func (*TaskStorage) EnqueueTask ¶
func (s *TaskStorage) EnqueueTask(task *scheduler.Task) error
Click to show internal directories.
Click to hide internal directories.