jobs

Documentation

Index

• Constants
• type Job
  • func NewAnchorPlatformAuthMonitoringJob(apService anchorplatform.AnchorPlatformAPIServiceInterface, ...) (Job, error)
  • func NewPatchAnchorPlatformTransactionsCompletionJob(paymentJobInterval int, ...) Job
  • func NewPaymentFromSubmitterJob(paymentJobInterval int, models *data.Models, ...) Job
  • func NewPaymentToSubmitterJob(jobIntervalSeconds int, models *data.Models, ...) Job
  • func NewReadyPaymentsCancellationJob(models *data.Models) Job
  • func NewSendReceiverWalletsSMSInvitationJob(options SendReceiverWalletsSMSInvitationJobOptions) 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 SendReceiverWalletsSMSInvitationJobOptions

Constants

const DefaultMinimumJobIntervalSeconds = 5

Types

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 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 NewPaymentToSubmitterJob

func NewPaymentToSubmitterJob(jobIntervalSeconds int, models *data.Models, tssDBConnectionPool db.DBConnectionPool) Job

func NewReadyPaymentsCancellationJob

func NewReadyPaymentsCancellationJob(models *data.Models) Job

func NewSendReceiverWalletsSMSInvitationJob

func NewSendReceiverWalletsSMSInvitationJob(options SendReceiverWalletsSMSInvitationJobOptions) 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 SendReceiverWalletsSMSInvitationJobOptions

type SendReceiverWalletsSMSInvitationJobOptions struct {
	Models                         *data.Models
	MessengerClient                message.MessengerClient
	MaxInvitationSMSResendAttempts int64
	Sep10SigningPrivateKey         string
	CrashTrackerClient             crashtracker.CrashTrackerClient
	JobIntervalSeconds             int
}