goasynq

README

轻量级队列基于redis

• 延时队列 定时队列 消息队列(适合不是高并发场景)
• 基于 https://github.com/hibiken/asynq
• 监控界面 https://github.com/hibiken/asynqmon

Documentation

Index

• func DelClient(names ...string)
• func DelServer(names ...string)
• func InitClient(configs ...ClientConfig) error
• func InitServer(configs ...ServerConfig) error
• type ClientConfig
• type GoAsynqClient
  • func DefaultClient() *GoAsynqClient
  • func GetClient(names ...string) *GoAsynqClient
  • func NewClient(config ClientConfig) *GoAsynqClient
  • func (c *GoAsynqClient) Close() error
  • func (c *GoAsynqClient) Enqueue(taskTypeTopic string, payload any, opts ...asynq.Option) (*asynq.TaskInfo, error)
  • func (c *GoAsynqClient) NewTask(taskTypeTopic string, payload any, opts ...asynq.Option) (*asynq.Task, error)
• type GoAsynqServer
  • func DefaultServer() *GoAsynqServer
  • func GetServer(names ...string) *GoAsynqServer
  • func RunServer(config ServerConfig) *GoAsynqServer
  • func (s *GoAsynqServer) Handle(taskTypeTopic string, handler asynq.Handler)
  • func (s *GoAsynqServer) HandleFunc(taskTypeTopic string, handler func(context.Context, *asynq.Task) error)
  • func (s *GoAsynqServer) Stop()
• type ServerConfig

Functions

func DelClient

func DelClient(names ...string)

func DelServer

func DelServer(names ...string)

func InitClient

func InitClient(configs ...ClientConfig) error

client

func InitServer

func InitServer(configs ...ServerConfig) error

server

Types

type ClientConfig

type ClientConfig struct {
	goredis.Config
	PoolSize int
}

type GoAsynqClient

type GoAsynqClient struct {
	Client *asynq.Client
}

func DefaultClient

func DefaultClient() *GoAsynqClient

func GetClient

func GetClient(names ...string) *GoAsynqClient

func NewClient

func NewClient(config ClientConfig) *GoAsynqClient

func (*GoAsynqClient) Close

func (c *GoAsynqClient) Close() error

func (*GoAsynqClient) Enqueue

func (c *GoAsynqClient) Enqueue(taskTypeTopic string, payload any, opts ...asynq.Option) (*asynq.TaskInfo, error)

func (*GoAsynqClient) NewTask

func (c *GoAsynqClient) NewTask(taskTypeTopic string, payload any, opts ...asynq.Option) (*asynq.Task, error)

type GoAsynqServer

type GoAsynqServer struct {
	ServeMux *asynq.ServeMux
	Server   *asynq.Server
}

func DefaultServer

func DefaultServer() *GoAsynqServer

func GetServer

func GetServer(names ...string) *GoAsynqServer

func RunServer

func RunServer(config ServerConfig) *GoAsynqServer

func (*GoAsynqServer) Handle

func (s *GoAsynqServer) Handle(taskTypeTopic string, handler asynq.Handler)

func (*GoAsynqServer) HandleFunc

func (s *GoAsynqServer) HandleFunc(taskTypeTopic string, handler func(context.Context, *asynq.Task) error)

func (*GoAsynqServer) Stop

func (s *GoAsynqServer) Stop()

type ServerConfig

type ServerConfig struct {
	goredis.Config
	PoolSize    int
	Concurrency int //default 10 指定要使用的并发工作线程数量
	Queues      map[string]int
}