storage

Documentation

Index

• type RedisStorage
  • func NewRedisStorage(addr, password string, db int) *RedisStorage
  • func (s *RedisStorage) GetAll(ctx context.Context) ([]*model.Proxy, error)
  • func (s *RedisStorage) GetRandom(ctx context.Context) (*model.Proxy, error)
  • func (s *RedisStorage) GetRedisClient() *redis.Client
  • func (s *RedisStorage) Remove(ctx context.Context, key string) error
  • func (s *RedisStorage) Save(ctx context.Context, proxy *model.Proxy) error
  • func (s *RedisStorage) UpdateScore(ctx context.Context, key string, score int) error
• type Storage

Types

type RedisStorage

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

func NewRedisStorage

func NewRedisStorage(addr, password string, db int) *RedisStorage

func (*RedisStorage) GetAll

func (s *RedisStorage) GetAll(ctx context.Context) ([]*model.Proxy, error)

func (*RedisStorage) GetRandom

func (s *RedisStorage) GetRandom(ctx context.Context) (*model.Proxy, error)

func (*RedisStorage) GetRedisClient

func (s *RedisStorage) GetRedisClient() *redis.Client

在 RedisStorage 结构体中添加获取客户端的方法

func (*RedisStorage) Remove

func (s *RedisStorage) Remove(ctx context.Context, key string) error

func (*RedisStorage) Save

func (s *RedisStorage) Save(ctx context.Context, proxy *model.Proxy) error

func (*RedisStorage) UpdateScore

func (s *RedisStorage) UpdateScore(ctx context.Context, key string, score int) error

type Storage

type Storage interface {
	Save(context.Context, *model.Proxy) error
	GetAll(context.Context) ([]*model.Proxy, error)
	GetRandom(context.Context) (*model.Proxy, error)
	Remove(context.Context, string) error
	UpdateScore(context.Context, string, int) error
}