job

package

v0.0.4 Latest Latest Go to latest Published: Jul 9, 2022 License: Apache-2.0 Imports: 15 Imported by: 4

Details

This section is empty.

View Source

var DefaultProviderSet = wire.NewSet(NewAsynqClientOpt, NewAsynqClient)

func EnqueueWithTracing(ctx context.Context, client *asynq.Client, task *asynq.Task, opts ...asynq.Option) (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 lazy.Of[*asynq.Server]

type RedisFunc func() interface{}

func (r RedisFunc) MakeRedisClient() interface{}

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

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(opt *asynq.Config)

func WithConcurrency(c int) ServerOption

func WithQueues(q map[string]int) ServerOption

type SpanKind string

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