scheduler

Documentation

Index

• Constants
• func StartScheduler(adminDBConnectionPool db.DBConnectionPool, ...)
• type Scheduler
• type SchedulerJobRegisterOption
  • func WithAPAuthEnforcementJob(apService anchorplatform.AnchorPlatformAPIServiceInterface, ...) SchedulerJobRegisterOption
  • func WithCirclePaymentToSubmitterJobOption(options jobs.CirclePaymentToSubmitterJobOptions) SchedulerJobRegisterOption
  • func WithCircleReconciliationJobOption(options jobs.CircleReconciliationJobOptions) SchedulerJobRegisterOption
  • func WithPatchAnchorPlatformTransactionsCompletionJobOption(paymentJobInterval int, ...) SchedulerJobRegisterOption
  • func WithPaymentFromSubmitterJobOption(paymentJobInterval int, models *data.Models, ...) SchedulerJobRegisterOption
  • func WithReadyPaymentsCancellationJobOption(models *data.Models) SchedulerJobRegisterOption
  • func WithSendReceiverWalletsInvitationJobOption(o jobs.SendReceiverWalletsInvitationJobOptions) SchedulerJobRegisterOption
  • func WithStellarPaymentToSubmitterJobOption(options jobs.StellarPaymentToSubmitterJobOptions) SchedulerJobRegisterOption
• type SchedulerOptions

Constants

const SchedulerWorkerCount = 5

SchedulerWorkerCount is the number of workers that will be started to process jobs

Functions

func StartScheduler

func StartScheduler(adminDBConnectionPool db.DBConnectionPool, crashTrackerClient crashtracker.CrashTrackerClient, schedulerJobRegisters ...SchedulerJobRegisterOption)

StartScheduler initializes and starts the scheduler. This method blocks until the scheduler is stopped.

Types

type Scheduler

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

Scheduler manages a list of jobs and executes them at their specified intervals. It uses a job queue to distribute jobs to workers.

type SchedulerJobRegisterOption

type SchedulerJobRegisterOption func(*Scheduler)

func WithAPAuthEnforcementJob

func WithAPAuthEnforcementJob(apService anchorplatform.AnchorPlatformAPIServiceInterface, monitorService monitor.MonitorServiceInterface, crashTrackerClient crashtracker.CrashTrackerClient) SchedulerJobRegisterOption

func WithCirclePaymentToSubmitterJobOption

func WithCirclePaymentToSubmitterJobOption(options jobs.CirclePaymentToSubmitterJobOptions) SchedulerJobRegisterOption

func WithCircleReconciliationJobOption

func WithCircleReconciliationJobOption(options jobs.CircleReconciliationJobOptions) SchedulerJobRegisterOption

func WithPatchAnchorPlatformTransactionsCompletionJobOption

func WithPatchAnchorPlatformTransactionsCompletionJobOption(paymentJobInterval int, apAPISvc anchorplatform.AnchorPlatformAPIServiceInterface, models *data.Models) SchedulerJobRegisterOption

func WithPaymentFromSubmitterJobOption

func WithPaymentFromSubmitterJobOption(paymentJobInterval int, models *data.Models, tssDBConnectionPool db.DBConnectionPool) SchedulerJobRegisterOption

func WithReadyPaymentsCancellationJobOption

func WithReadyPaymentsCancellationJobOption(models *data.Models) SchedulerJobRegisterOption

func WithSendReceiverWalletsInvitationJobOption

func WithSendReceiverWalletsInvitationJobOption(o jobs.SendReceiverWalletsInvitationJobOptions) SchedulerJobRegisterOption

func WithStellarPaymentToSubmitterJobOption

func WithStellarPaymentToSubmitterJobOption(options jobs.StellarPaymentToSubmitterJobOptions) SchedulerJobRegisterOption

type SchedulerOptions

type SchedulerOptions struct {
	PaymentJobIntervalSeconds            int
	ReceiverInvitationJobIntervalSeconds int
}