sqlite

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

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 DefaultBackoffManager struct {
}

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 ProcessedEventRepository struct {
	// contains filtered or unexported fields
}

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

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

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

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

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

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

type TestAdapters struct {
	SessionRepository        *SessionRepository
	AccountRepository        *AccountRepository
	PublicKeyRepository      *PublicKeyRepository
	ProcessedEventRepository *ProcessedEventRepository
	UserTokensRepository     *UserTokensRepository
	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
}

type TransactionProvider = GenericTransactionProvider[app.Adapters]

type TweetCreatedEventTransport struct {
	AccountID string         `json:"accountID"`
	Tweet     TweetTransport `json:"tweet"`
	Event     []byte         `json:"event"`
	CreatedAt time.Time      `json:"createdAt"`
}

type TweetTransport struct {
	Text string `json:"text"`
}

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