CalculatePricing handles pricing calculation requests

CalculatePricing calculates pricing for GPU rental requirements

CancelJob cancels a running job

CheckUserBalance checks if a user has sufficient balance for a session

Close closes the database connection pool.

Close closes the Redis connection

CloseRentalJob submits the provider's delivery: the metering receipt hash and a URI to the stored receipt. After the challenge window, SettleRentalJob

CreateAssociatedTokenAccount creates an associated token account for a wallet

CreateJob builds, signs, and submits the create_job instruction (locks USDC in the per-job escrow), returning the job PDA and tx signature for HTTP in

DefaultSecretLoader returns a chained secret loader with environment variables and an optional secrets file

DepositTokens processes a dGPU token deposit

DetectGPUsOnce performs an immediate, one-time detection of GPUs and returns them. This is useful for CLI commands or synchronous requests.

DisputeRentalJob opens a dispute on a rental's escrow with the given reason, posting the platform's bond. The bonded 2-of-3 arbitrator resolves it usi

Download retrieves a file from the specified bucket with the given key. It returns an io.ReadCloser for the file content and its metadata.

DurationHours returns the duration in hours

EnrichLoggerWithContext creates a new logger with correlation ID and request ID fields added from the context

EnsureBucket checks if a bucket exists, and creates it if it doesn't.

EnsureBucket creates a bucket if it does not already exist.

EstimateJobCost estimates the cost of running a job

ExtractClaims extracts claims from a token without validation (for debugging)

Finalize triggers settlement after the challenge window (POST api/jobs/{id}/finalize). This is the provider payout. Covenant also runs a finalize cron

GenerateTokenPair generates both access and refresh tokens

GetAbsPath returns the absolute path for a given relative path to the config file.

GetActiveSubscriptionCount returns the number of active (valid) primary task subscriptions. Currently, this is 0 or 1.

GetConnectionURL returns the URL the NATS client is connected to, or the configured URL if not connected.

GetCurrentUsage gets current usage information for a session

GetDatabaseCredentials retrieves database credentials from the secret loader

GetDatabaseURL returns the database connection URL, either from the direct URL in the config or by constructing it from individual credentials loaded

GetFinancialSummary retrieves a summary of financial data for the provider. This is a STUB method and needs a corresponding endpoint in the billing se

GetJob retrieves a job by its ID.

GetJob retrieves a job by its ID from the database.

GetLastErrorStr returns the last error encountered by the NATS client as a string. Returns an empty string if there is no last error.

GetMetrics gets real-time metrics for all GPUs

GetObjectInfo retrieves metadata for a specific object.

GetPlatformFeePercent returns the platform fee percentage

GetPowerMultiplier returns the power consumption multiplier

GetPresignedURL generates a presigned URL for an object, either for uploading (PUT) or downloading (GET). expiry is the duration for which the URL wil

GetProviderEarnings calculates provider earnings for a given period

GetProviderRates proxies to the billing service for a provider's configured hourly rates.

GetRequestID retrieves the request ID from the context

GetSupportedGPUModels returns a list of supported GPU models and their base rates

GetTokenBalance gets the USDC balance for a given wallet address

GetTokenExpiration returns the expiration time from a token

GetVRAMRatePerGB returns the VRAM rate per GB per hour

Health check

Heartbeat updates the provider's last seen time.

IndexCreatedJob registers a job with Covenant after the platform has signed and submitted the on-chain create_job instruction (POST /api/jobs). The on

Initialize sets up the PostgreSQL tables if they don't exist.

Initialize creates the necessary 'jobs' table if it doesn't already exist.

Initialize sets up the rental client

Initialize sets up the GPU provider

IsConnected checks if the NATS client is currently connected.

IsTransientError determines if an error is likely transient and can be retried

IsTransientError determines if an error is a transient database error

ListAvailableProviders fetches a list of all providers from the Provider Registry service. TODO: Add filtering capabilities based on job requirements.

ListJobs returns jobs filtered by taker wallet (GET /api/jobs). Used by the settlement crank to find delivered jobs awaiting finalize.

LockFunds locks the specified amount for a session

Login handles user login

MinBond returns the minimum dispute bond in atomic units for an escrow amount, matching the program: max(amount * bps / 10_000, min_absolute).

Monitor starts monitoring a session and sends periodic usage updates

NewDanteGPUDevicePlugin creates a new device plugin

NewGPUMonitoringService creates a new GPU monitoring service

NewGPUProvider creates a new GPU provider instance with comprehensive capabilities

NewGPURentalClient creates a comprehensive GPU rental client

NewManager wires the on-chain signer and the HTTP client. challengeSeconds is the optimistic challenge window (default 1h, the protocol minimum).

NewOryKratosService creates a new Ory Kratos service

NewRedisCacheService creates a new Redis cache service

NewSigner builds an on-chain signer. rpcURL is the Solana RPC, key is the platform keypair, programID and usdcMint come from config.

NewStructuredLogger returns a middleware that logs request details using Zap.

NewStructuredLogger returns a middleware that logs request details using Zap. (Identical to the one in api-gateway, maybe move to a shared lib later?)

NewStructuredLogger returns a middleware that logs request details using Zap.

OpenRentalJob locks `amount` USDC in a Covenant escrow for a fixed-duration rental, then indexes it. Phase 1: poster = platform (custodial), amount =

OptionalSessionMiddleware validates sessions but doesn't require authentication

ProcessDeposit processes a USDC deposit

ProcessWithdrawal processes a USDC withdrawal

RaiseDispute opens a dispute on a delivered job, posting a bond from the platform (poster). reasonHash is the SHA-256 of the dispute reason; the meter

RefreshToken handles token refresh

RefreshTokens generates new tokens using a valid refresh token

Register handles user registration

Register registers the device plugin with kubelet

RegisterRoutes registers the storage API routes with the given router.

Routes defines all HTTP routes for the provider service.

SaveJob saves the complete state of a job. This can be used for initial creation or full updates.

SendUsageUpdate sends real-time usage data to the billing service

SessionMiddleware validates user sessions using Ory Kratos