task2group

Documentation

Index

• type RedisStorage
  • func (storage *RedisStorage) GroupByTask(ctx context.Context, task string) (group string, err error)
  • func (storage *RedisStorage) Save(ctx context.Context, task string, group string) error
  • func (storage *RedisStorage) TaskByGroup(ctx context.Context, group string) (task string, err error)

Types

type RedisStorage

type RedisStorage struct {
	Client redis.UniversalClient
}

func (*RedisStorage) GroupByTask

func (storage *RedisStorage) GroupByTask(ctx context.Context, task string) (group string, err error)

func (*RedisStorage) Save

func (storage *RedisStorage) Save(ctx context.Context, task string, group string) error

func (*RedisStorage) TaskByGroup

func (storage *RedisStorage) TaskByGroup(ctx context.Context, group string) (task string, err error)