Documentation
¶
Index ¶
- func ComputeMarketRate() error
- func FetchProviderBalances() error
- func GetTronLatestBlock(endpoint string) (int64, error)
- func HandleReceiveAddressValidity() error
- func IndexGatewayEvents() error
- func ProcessStuckValidatedOrders() 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()
- func TaskIndexBlockchainEvents() error
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 FetchProviderBalances ¶ added in v0.0.2
func FetchProviderBalances() error
FetchProviderBalances fetches balance updates from all providers
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 ProcessStuckValidatedOrders ¶ added in v0.0.2
func ProcessStuckValidatedOrders() error
ProcessStuckValidatedOrders processes orders stuck on validated status by indexing provider addresses
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
func TaskIndexBlockchainEvents ¶ added in v0.0.2
func TaskIndexBlockchainEvents() error
TaskIndexBlockchainEvents indexes transfer events for all enabled tokens
Types ¶
This section is empty.
Source Files