task

Documentation

Index

• func GiftGasProcessor(celoProvider *celo.Provider, nonceProvider nonce.Noncestore, ...) func(context.Context, *asynq.Task) error
• func GiftTokenProcessor(celoProvider *celo.Provider, nonceProvider nonce.Noncestore, ...) func(context.Context, *asynq.Task) error
• func PrepareAccount(nonceProvider nonce.Noncestore, taskerClient *tasker.TaskerClient) func(context.Context, *asynq.Task) error
• func RefillGasProcessor(celoProvider *celo.Provider, nonceProvider nonce.Noncestore, ...) func(context.Context, *asynq.Task) error
• func TransferToken(celoProvider *celo.Provider, nonceProvider nonce.Noncestore, ...) func(context.Context, *asynq.Task) error
• func TxDispatch(celoProvider *celo.Provider) func(context.Context, *asynq.Task) error
• type SystemPayload
• type TransferPayload
• type TxPayload

Functions

func GiftGasProcessor

func GiftGasProcessor(
	celoProvider *celo.Provider,
	nonceProvider nonce.Noncestore,
	lockProvider *redislock.Client,
	system *tasker.SystemContainer,
	taskerClient *tasker.TaskerClient,
) func(context.Context, *asynq.Task) error

func GiftTokenProcessor

func GiftTokenProcessor(
	celoProvider *celo.Provider,
	nonceProvider nonce.Noncestore,
	lockProvider *redislock.Client,
	system *tasker.SystemContainer,
	taskerClient *tasker.TaskerClient,
) func(context.Context, *asynq.Task) error

func PrepareAccount

func PrepareAccount(
	nonceProvider nonce.Noncestore,
	taskerClient *tasker.TaskerClient,
) func(context.Context, *asynq.Task) error

func RefillGasProcessor

func RefillGasProcessor(
	celoProvider *celo.Provider,
	nonceProvider nonce.Noncestore,
	lockProvider *redislock.Client,
	system *tasker.SystemContainer,
	taskerClient *tasker.TaskerClient,
) func(context.Context, *asynq.Task) error

func TransferToken

func TransferToken(
	celoProvider *celo.Provider,
	nonceProvider nonce.Noncestore,
	keystoreProvider keystore.Keystore,
	lockProvider *redislock.Client,
	system *tasker.SystemContainer,
	taskerClient *tasker.TaskerClient,
) func(context.Context, *asynq.Task) error

func TxDispatch

func TxDispatch(
	celoProvider *celo.Provider,
) func(context.Context, *asynq.Task) error

Types

type SystemPayload

type SystemPayload struct {
	PublicKey string `json:"publicKey"`
}

type TransferPayload

type TransferPayload struct {
	From           string `json:"from"`
	To             string `json:"to"`
	VoucherAddress string `json:"voucherAddress"`
	Amount         string `json:"amount"`
}

type TxPayload

type TxPayload struct {
	Tx *types.Transaction `json:"tx"`
}