async

Documentation

Index

• Constants
• func NewApiCallTask(projectName string, data []byte) (*asynq.Task, error)
• type ApiCallProcessor
  • func NewApiCallProcessor(l log.Logger, router *gin.Engine, cli *asynq.Client) *ApiCallProcessor
  • func (p *ApiCallProcessor) ProcessTask(ctx context.Context, t *asynq.Task) error
• type ApiResultProcessor
  • func NewApiResultProcessor(l log.Logger, mgrDB sqlx.DBExecutor, kv *kvdb.RedisDB) *ApiResultProcessor
  • func (p *ApiResultProcessor) ProcessTask(ctx context.Context, t *asynq.Task) error

Constants

const (
	TaskNameApiCall   = "apiCall"
	TaskNameApiResult = "apiResult"
)

Functions

func NewApiCallTask

func NewApiCallTask(projectName string, data []byte) (*asynq.Task, error)

Types

type ApiCallProcessor

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

func NewApiCallProcessor

func NewApiCallProcessor(l log.Logger, router *gin.Engine, cli *asynq.Client) *ApiCallProcessor

func (*ApiCallProcessor) ProcessTask

func (p *ApiCallProcessor) ProcessTask(ctx context.Context, t *asynq.Task) error

type ApiResultProcessor

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

func NewApiResultProcessor

func NewApiResultProcessor(l log.Logger, mgrDB sqlx.DBExecutor, kv *kvdb.RedisDB) *ApiResultProcessor

func (*ApiResultProcessor) ProcessTask

func (p *ApiResultProcessor) ProcessTask(ctx context.Context, t *asynq.Task) error