parallel

Documentation

Index

• type RedisTask
  • func NewRedisTask(ctx *context.Context, pool *redis.Pool, cmd string, args ...interface{}) *RedisTask
  • func NewRedisTaskWithName(ctx *context.Context, name string, pool *redis.Pool, cmd string, ...) *RedisTask
  • func (rt *RedisTask) Run() (result *[]byte)

Types

type RedisTask

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

RedisTask .

func NewRedisTask

func NewRedisTask(ctx *context.Context, pool *redis.Pool, cmd string, args ...interface{}) *RedisTask

NewRedisTask new redis parallel task

func NewRedisTaskWithName

func NewRedisTaskWithName(ctx *context.Context, name string, pool *redis.Pool, cmd string, args ...interface{}) *RedisTask

NewRedisTaskWithName new redis parallel task

func (*RedisTask) Run

func (rt *RedisTask) Run() (result *[]byte)

Run .