sqlite

type AdaptersFactoryFn = GenericAdaptersFactoryFn[app.Adapters]

type BackoffManager interface {
	// GetMessageErrorBackoff is used to backoff reprocessing of a single
	// specific message if its processing fails. The first time message
	// processing fails 1 is passed to this function, the second time 2 etc.
	GetMessageErrorBackoff(nackCount int) time.Duration

	// GetNoMessagesBackoff is used to backoff querying for new messages on the
	// queue. The first time in a row where the query returns no messages 1 is
	// passed to this function, then 2 is passed etc.
	GetNoMessagesBackoff(tick int) time.Duration
}

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

type DefaultBackoffManager struct {
}

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

type EventSavedEventTransport struct {
	EventID string `json:"eventID"`
}

type GenericAdaptersFactoryFn[T any] func(*sql.DB, *sql.Tx) (T, error)

type GenericTransactionProvider[T any] struct {
	// contains filtered or unexported fields
}

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

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

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

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

type PubSubTxTransactionProvider = GenericTransactionProvider[*sql.Tx]

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

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

type PubsubTransactionProvider interface {
	Transact(context.Context, func(context.Context, *sql.Tx) error) error
}

type ReceivedMessage struct {
	Message
	// contains filtered or unexported fields
}

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

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

type TestAdapters struct {
	EventRepository               *EventRepository
	RelayRepository               *RelayRepository
	ContactRepository             *ContactRepository
	PublicKeysToMonitorRepository *PublicKeysToMonitorRepository
	Publisher                     *Publisher
}

type TestAdaptersFactoryFn = GenericAdaptersFactoryFn[TestAdapters]

type TestTransactionProvider = GenericTransactionProvider[TestAdapters]

type TestedItems struct {
	TransactionProvider *TestTransactionProvider
	Subscriber          *Subscriber
	MigrationsStorage   *MigrationsStorage
	PubSub              *PubSub

	MigrationsRunner           *migrations.Runner
	Migrations                 migrations.Migrations
	MigrationsProgressCallback migrations.ProgressCallback
	TransactionRunner          *TransactionRunner
}

type TransactionFunc func(context.Context, *sql.DB, *sql.Tx) error

type TransactionProvider = GenericTransactionProvider[app.Adapters]

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

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