async

Documentation

Index

• Constants
• func ConvHttpResponse(reqHeader http.Header, resp *http.Response) (*apitypes.HttpResponse, error)
• func NewApiCallTask(prj *models.Project, chainCli *wasm.ChainClient, 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, tasks *confmq.Config) *ApiResultProcessor
  • func (p *ApiResultProcessor) ProcessTask(ctx context.Context, t *asynq.Task) error

Constants

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

Functions

func ConvHttpResponse

func ConvHttpResponse(reqHeader http.Header, resp *http.Response) (*apitypes.HttpResponse, error)

func NewApiCallTask

func NewApiCallTask(prj *models.Project, chainCli *wasm.ChainClient, 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, tasks *confmq.Config) *ApiResultProcessor

func (*ApiResultProcessor) ProcessTask

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