jobs

Documentation

Index

• Constants
• type CirclePaymentToSubmitterJobOptions
• type CircleReconciliationJobOptions
• type Job
  • func NewAnchorPlatformAuthMonitoringJob(apService anchorplatform.AnchorPlatformAPIServiceInterface, ...) (Job, error)
  • func NewCirclePaymentToSubmitterJob(opts CirclePaymentToSubmitterJobOptions) Job
  • func NewCircleReconciliationJob(opts CircleReconciliationJobOptions) Job
  • func NewPatchAnchorPlatformTransactionsCompletionJob(paymentJobInterval int, ...) Job
  • func NewPaymentFromSubmitterJob(paymentJobInterval int, models *data.Models, ...) Job
  • func NewReadyPaymentsCancellationJob(models *data.Models) Job
  • func NewSendReceiverWalletsInvitationJob(options SendReceiverWalletsInvitationJobOptions) Job
  • func NewStellarPaymentToSubmitterJob(opts StellarPaymentToSubmitterJobOptions) Job
• type MockJob
  • func (m *MockJob) Execute(ctx context.Context) error
  • func (m *MockJob) GetExecutions() int
  • func (m *MockJob) GetInterval() time.Duration
  • func (m *MockJob) GetName() string
  • func (m *MockJob) IsJobMultiTenant() bool
• type MockMultiTenantJob
  • func (m *MockMultiTenantJob) Execute(ctx context.Context) error
  • func (m *MockMultiTenantJob) GetExecutions(id string) int
  • func (m *MockMultiTenantJob) GetInterval() time.Duration
  • func (m *MockMultiTenantJob) GetName() string
  • func (m *MockMultiTenantJob) IsJobMultiTenant() bool
• type SendReceiverWalletsInvitationJobOptions
• type StellarPaymentToSubmitterJobOptions

Constants

const DefaultMinimumJobIntervalSeconds = 5

Types

type CirclePaymentToSubmitterJobOptions

type CirclePaymentToSubmitterJobOptions struct {
	JobIntervalSeconds  int
	Models              *data.Models
	DistAccountResolver signing.DistributionAccountResolver
	CircleService       circle.ServiceInterface
}

type CircleReconciliationJobOptions

type CircleReconciliationJobOptions struct {
	Models              *data.Models
	DistAccountResolver signing.DistributionAccountResolver
	CircleService       circle.ServiceInterface
}

type Job

type Job interface {
	Execute(context.Context) error
	GetInterval() time.Duration
	GetName() string
	IsJobMultiTenant() bool
}

func NewAnchorPlatformAuthMonitoringJob

func NewAnchorPlatformAuthMonitoringJob(apService anchorplatform.AnchorPlatformAPIServiceInterface, monitorService monitor.MonitorServiceInterface, crashTrackerClient crashtracker.CrashTrackerClient) (Job, error)

NewAnchorPlatformAuthMonitoringJob is a factory method that creates a new instance of anchorPlatformAuthMonitoringJob.

func NewCirclePaymentToSubmitterJob

func NewCirclePaymentToSubmitterJob(opts CirclePaymentToSubmitterJobOptions) Job

func NewCircleReconciliationJob

func NewCircleReconciliationJob(opts CircleReconciliationJobOptions) Job

func NewPatchAnchorPlatformTransactionsCompletionJob

func NewPatchAnchorPlatformTransactionsCompletionJob(paymentJobInterval int, apAPISvc anchorplatform.AnchorPlatformAPIServiceInterface, models *data.Models) Job

func NewPaymentFromSubmitterJob

func NewPaymentFromSubmitterJob(paymentJobInterval int, models *data.Models, tssDBConnectionPool db.DBConnectionPool) Job

func NewReadyPaymentsCancellationJob

func NewReadyPaymentsCancellationJob(models *data.Models) Job

func NewSendReceiverWalletsInvitationJob

func NewSendReceiverWalletsInvitationJob(options SendReceiverWalletsInvitationJobOptions) Job

func NewStellarPaymentToSubmitterJob

func NewStellarPaymentToSubmitterJob(opts StellarPaymentToSubmitterJobOptions) Job

type MockJob

type MockJob struct {
	Name       string
	Interval   time.Duration
	Executions int
	// contains filtered or unexported fields
}

MockJob is a mock job created for testing purposes

func (*MockJob) Execute

func (m *MockJob) Execute(ctx context.Context) error

func (*MockJob) GetExecutions

func (m *MockJob) GetExecutions() int

func (*MockJob) GetInterval

func (m *MockJob) GetInterval() time.Duration

func (*MockJob) GetName

func (m *MockJob) GetName() string

func (*MockJob) IsJobMultiTenant

func (m *MockJob) IsJobMultiTenant() bool

type MockMultiTenantJob

type MockMultiTenantJob struct {
	Name       string
	Interval   time.Duration
	Executions sync.Map
}

MockMultiTenantJob is a mock multi-tenant job created for testing purposes

func (*MockMultiTenantJob) Execute

func (m *MockMultiTenantJob) Execute(ctx context.Context) error

func (*MockMultiTenantJob) GetExecutions

func (m *MockMultiTenantJob) GetExecutions(id string) int

func (*MockMultiTenantJob) GetInterval

func (m *MockMultiTenantJob) GetInterval() time.Duration

func (*MockMultiTenantJob) GetName

func (m *MockMultiTenantJob) GetName() string

func (*MockMultiTenantJob) IsJobMultiTenant

func (m *MockMultiTenantJob) IsJobMultiTenant() bool

type SendReceiverWalletsInvitationJobOptions

type SendReceiverWalletsInvitationJobOptions struct {
	Models                      *data.Models
	MessageDispatcher           message.MessageDispatcherInterface
	MaxInvitationResendAttempts int64
	Sep10SigningPrivateKey      string
	CrashTrackerClient          crashtracker.CrashTrackerClient
	JobIntervalSeconds          int
}

type StellarPaymentToSubmitterJobOptions

type StellarPaymentToSubmitterJobOptions struct {
	JobIntervalSeconds  int
	Models              *data.Models
	TSSDBConnectionPool db.DBConnectionPool
	DistAccountResolver signing.DistributionAccountResolver
}