redisutils

Documentation

Index

• Constants
• type Download
• type RedisClient
  • func NewAuthenticatedRedisClient(ctx context.Context) (*RedisClient, error)
  • func (r *RedisClient) DownloadExists(ctx context.Context, id int64) (bool, error)
  • func (r *RedisClient) GetDownloadName(ctx context.Context, id int64) (string, error)
  • func (r *RedisClient) GetDownloadState(ctx context.Context, state string) ([]int64, error)
  • func (r *RedisClient) RegisterDownloadState(ctx context.Context, d Download) error

Constants

const (
	Downloaded             = "downloaded"
	Compressing            = "compressing"
	Compressed             = "compressed"
	Uploading              = "uploading"
	Uploaded               = "uploaded"
	Removing               = "removing"
	Removed                = "removed"
	Failed                 = "failed"
	NameKey                = "name"
	StateKey               = "state"
	CompletedDownloadsPath = "/downloads/complete"
	UploadsReadyPath       = "/downloads/uploads"
	DownloadsHash          = "downloads"
)

Types

type Download

type Download struct {
	ID    int64
	Name  string
	State string
}

type RedisClient

type RedisClient struct {
	Client *redis.Client
}

func NewAuthenticatedRedisClient

func NewAuthenticatedRedisClient(ctx context.Context) (*RedisClient, error)

func (*RedisClient) DownloadExists

func (r *RedisClient) DownloadExists(ctx context.Context, id int64) (bool, error)

func (*RedisClient) GetDownloadName

func (r *RedisClient) GetDownloadName(ctx context.Context, id int64) (string, error)

func (*RedisClient) GetDownloadState

func (r *RedisClient) GetDownloadState(ctx context.Context, state string) ([]int64, error)

func (*RedisClient) RegisterDownloadState

func (r *RedisClient) RegisterDownloadState(ctx context.Context, d Download) error