taskmanager

type TaskManager struct {
	// contains filtered or unexported fields
}

type TransferWorkflowArgs struct {
	TransferID uuid.UUID `json:"transfer_id"`
}

type TransferWorkflowWorker struct {
	river.WorkerDefaults[TransferWorkflowArgs]
	// contains filtered or unexported fields
}

type WebhookCleanupJobArgs struct{}

type WebhookCleanupWorker struct {
	river.WorkerDefaults[WebhookCleanupJobArgs]
	// contains filtered or unexported fields
}

type WebhookWaitingConfirmationsArgs struct {
	Blockchain             wconstants.BlockchainType `json:"blockchain"`
	Hash                   string                    `json:"hash"`
	Address                string                    `json:"address"`
	EventBlockchainUniqKey string                    `json:"event_blockchain_uniq_key"`
	WebhookKind            models.WebhookKind        `json:"webhook_kind"`
	WalletType             constants.WalletType      `json:"wallet_type"`
	OwnerID                uuid.UUID                 `json:"owner_id"`
	ExternalWalletID       *string                   `json:"external_wallet_id,omitempty"`
	IsSystem               bool                      `json:"is_system"`
}

type WebhookWaitingConfirmationsWorker struct {
	river.WorkerDefaults[WebhookWaitingConfirmationsArgs]
	// contains filtered or unexported fields
}