job

Documentation

Index

• Variables
• func EnqueueWithTracing(ctx context.Context, client *asynq.Client, task *asynq.Task, ...) (taskinfo *asynq.TaskInfo, err error)
• func Logging(logger klog.Logger) asynq.MiddlewareFunc
• func NewAsynqClient(opt asynq.RedisConnOpt) (*asynq.Client, func())
• func NewAsynqClientOpt(r redis.UniversalClient) asynq.RedisConnOpt
• func NewUi(root string, opt asynq.RedisConnOpt) http.Handler
• func SetTracingOption(ctx context.Context) asynq.Option
• func Stack() asynq.MiddlewareFunc
• func TracingServer() asynq.MiddlewareFunc
• type LazyAsynqServer
• type RedisFunc
  • func (r RedisFunc) MakeRedisClient() interface{}
• type Server
  • func NewServer(opt asynq.RedisConnOpt, opts ...ServerOption) *Server
  • func (s *Server) Start(ctx context.Context) error
  • func (s *Server) Stop(ctx context.Context) error
• type ServerOption
  • func WithConcurrency(c int) ServerOption
  • func WithQueues(q map[string]int) ServerOption
• type SpanKind

Variables

var DefaultProviderSet = wire.NewSet(NewAsynqClientOpt, NewAsynqClient)

Functions

func EnqueueWithTracing

func EnqueueWithTracing(ctx context.Context, client *asynq.Client, task *asynq.Task, opts ...asynq.Option) (taskinfo *asynq.TaskInfo, err error)

func Logging

func Logging(logger klog.Logger) asynq.MiddlewareFunc

func NewAsynqClient

func NewAsynqClient(opt asynq.RedisConnOpt) (*asynq.Client, func())

func NewAsynqClientOpt

func NewAsynqClientOpt(r redis.UniversalClient) asynq.RedisConnOpt

func NewUi

func NewUi(root string, opt asynq.RedisConnOpt) http.Handler

func SetTracingOption

func SetTracingOption(ctx context.Context) asynq.Option

func Stack

func Stack() asynq.MiddlewareFunc

func TracingServer

func TracingServer() asynq.MiddlewareFunc

Types

type LazyAsynqServer

type LazyAsynqServer lazy.Of[*asynq.Server]

type RedisFunc

type RedisFunc func() interface{}

func (RedisFunc) MakeRedisClient

func (r RedisFunc) MakeRedisClient() interface{}

type Server

type Server struct {
	*asynq.ServeMux
	// contains filtered or unexported fields
}

func NewServer

func NewServer(opt asynq.RedisConnOpt, opts ...ServerOption) *Server

func (*Server) Start

func (s *Server) Start(ctx context.Context) error

func (*Server) Stop

func (s *Server) Stop(ctx context.Context) error

type ServerOption

type ServerOption func(opt *asynq.Config)

func WithConcurrency

func WithConcurrency(c int) ServerOption

func WithQueues

func WithQueues(q map[string]int) ServerOption

type SpanKind

type SpanKind string

const (
	KindProducer SpanKind = "PRODUCER"
	KindConsumer SpanKind = "CONSUMER"
)