tasks

Documentation

Index

• func ComputeMarketRate() error
• func GetTronLatestBlock(endpoint string) (int64, error)
• func HandleReceiveAddressValidity() error
• func ReassignStaleOrderRequest(ctx context.Context, orderRequestChan <-chan *redis.Message)
• func RetryFailedWebhookNotifications() error
• func RetryStaleUserOperations() error
• func StartCronJobs()
• func SubscribeToRedisKeyspaceEvents()
• func SyncLockOrderFulfillments()
• func TaskIndexBlockchainEvents() error

Functions

func ComputeMarketRate

func ComputeMarketRate() error

ComputeMarketRate computes the market price for fiat currencies

func GetTronLatestBlock

func GetTronLatestBlock(endpoint string) (int64, error)

GetTronLatestBlock fetches the latest block (timestamp in milliseconds) for Tron

func HandleReceiveAddressValidity

func HandleReceiveAddressValidity() error

HandleReceiveAddressValidity handles receive address validity

func ReassignStaleOrderRequest

func ReassignStaleOrderRequest(ctx context.Context, orderRequestChan <-chan *redis.Message)

ReassignStaleOrderRequest reassigns expired order requests to providers

func RetryFailedWebhookNotifications

func RetryFailedWebhookNotifications() error

Retry failed webhook notifications

func RetryStaleUserOperations

func RetryStaleUserOperations() error

RetryStaleUserOperations retries stale user operations TODO: Fetch failed orders from a separate db table and process them

func StartCronJobs

func StartCronJobs()

StartCronJobs starts cron jobs

func SubscribeToRedisKeyspaceEvents

func SubscribeToRedisKeyspaceEvents()

SubscribeToRedisKeyspaceEvents subscribes to redis keyspace events according to redis.conf settings

func SyncLockOrderFulfillments

func SyncLockOrderFulfillments()

SyncLockOrderFulfillments syncs lock order fulfillments

func TaskIndexBlockchainEvents

func TaskIndexBlockchainEvents() error

TaskIndexBlockchainEvents indexes transfer events for all enabled tokens