Documentation
¶
Index ¶
- func ComputeMarketRate() error
- func GetTronLatestBlock(endpoint string) (int64, error)
- func HandleReceiveAddressValidity() error
- func IndexGatewayEvents() error
- func ReassignStaleOrderRequest(ctx context.Context, orderRequestChan <-chan *redis.Message)
- func ResolvePaymentOrderMishaps() error
- func RetryFailedWebhookNotifications() error
- func RetryStaleUserOperations() error
- func StartCronJobs()
- func SubscribeToRedisKeyspaceEvents()
- func SyncLockOrderFulfillments()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ComputeMarketRate ¶
func ComputeMarketRate() error
ComputeMarketRate computes the market price for fiat currencies
func GetTronLatestBlock ¶
GetTronLatestBlock fetches the latest block (timestamp in milliseconds) for Tron
func HandleReceiveAddressValidity ¶
func HandleReceiveAddressValidity() error
HandleReceiveAddressValidity handles receive address validity
func IndexGatewayEvents ¶
func IndexGatewayEvents() error
IndexGatewayEvents indexes all gateway events for missed OrderCreated, OrderRefunded, and OrderSettled events
func ReassignStaleOrderRequest ¶
ReassignStaleOrderRequest reassigns expired order requests to providers
func ResolvePaymentOrderMishaps ¶
func ResolvePaymentOrderMishaps() error
ResolvePaymentOrderMishaps resolves payment order mishaps across all networks
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 SubscribeToRedisKeyspaceEvents ¶
func SubscribeToRedisKeyspaceEvents()
SubscribeToRedisKeyspaceEvents subscribes to redis keyspace events according to redis.conf settings
func SyncLockOrderFulfillments ¶
func SyncLockOrderFulfillments()
SyncLockOrderFulfillments syncs lock order fulfillments
Types ¶
This section is empty.
Source Files