testingutil

func Integration ¶

func Integration() bool

func MockSFTPServer ¶ added in v0.5.3

func MockSFTPServer(t *testing.T, hostKey ssh.Signer) string

func MustCloseDB ¶

func MustCloseDB(tb testing.TB, db *litestream.DB)

MustCloseDB closes db and removes its parent directory.

func MustCloseDBs ¶

func MustCloseDBs(tb testing.TB, db *litestream.DB, sqldb *sql.DB)

MustCloseDBs closes db & sqldb and removes the parent directory.

func MustCloseSQLDB ¶

func MustCloseSQLDB(tb testing.TB, d *sql.DB)

MustCloseSQLDB closes a database/sql DB.

func MustDeleteAll ¶

func MustDeleteAll(tb testing.TB, c litestream.ReplicaClient)

MustDeleteAll deletes all objects under the client's path.

func MustOpenDB ¶

func MustOpenDB(tb testing.TB) *litestream.DB

MustOpenDB returns a new instance of a DB.

func MustOpenDBAt ¶

func MustOpenDBAt(tb testing.TB, path string) *litestream.DB

MustOpenDBAt returns a new instance of a DB for a given path.

func MustOpenDBs ¶

func MustOpenDBs(tb testing.TB) (*litestream.DB, *sql.DB)

MustOpenDBs returns a new instance of a DB & associated SQL DB.

func MustOpenSQLDB ¶

func MustOpenSQLDB(tb testing.TB, path string) *sql.DB

MustOpenSQLDB returns a database/sql DB.

func NewABSReplicaClient ¶

func NewABSReplicaClient(tb testing.TB) *abs.ReplicaClient

NewABSReplicaClient returns a new client for integration testing.

func NewB2ReplicaClient ¶ added in v0.5.7

func NewB2ReplicaClient(tb testing.TB) *s3.ReplicaClient

NewB2ReplicaClient returns a new Backblaze B2 client for integration testing. B2 uses S3-compatible API with path-style URLs and signed payloads.

func NewDB ¶

func NewDB(tb testing.TB, path string) *litestream.DB

func NewFileReplicaClient ¶

func NewFileReplicaClient(tb testing.TB) *file.ReplicaClient

NewFileReplicaClient returns a new client for integration testing.

func NewGSReplicaClient ¶

func NewGSReplicaClient(tb testing.TB) *gs.ReplicaClient

NewGSReplicaClient returns a new client for integration testing.

func NewNATSReplicaClient ¶

func NewNATSReplicaClient(tb testing.TB) *nats.ReplicaClient

NewNATSReplicaClient returns a new client for integration testing.

func NewNeonReplicaClient ¶ added in v0.5.18

func NewNeonReplicaClient(tb testing.TB) *s3.ReplicaClient

NewNeonReplicaClient returns an S3 client configured for Neon Object Storage. Neon uses per-branch endpoints with path-style URLs and signed payloads.

func NewOSSReplicaClient ¶ added in v0.5.3

func NewOSSReplicaClient(tb testing.TB) *oss.ReplicaClient

NewOSSReplicaClient returns a new client for integration testing.

func NewR2ReplicaClient ¶ added in v0.5.6

func NewR2ReplicaClient(tb testing.TB) *s3.ReplicaClient

NewR2ReplicaClient returns an S3 client configured for Cloudflare R2. Skips the test if R2 credentials are not configured.

func NewReplicaClient ¶

func NewReplicaClient(tb testing.TB, typ string) litestream.ReplicaClient

NewReplicaClient returns a new client for integration testing by type name.

func NewS3ReplicaClient ¶

func NewS3ReplicaClient(tb testing.TB) *s3.ReplicaClient

NewS3ReplicaClient returns a new client for integration testing.

func NewSFTPReplicaClient ¶

func NewSFTPReplicaClient(tb testing.TB) *sftp.ReplicaClient

NewSFTPReplicaClient returns a new client for integration testing.

func NewTigrisReplicaClient ¶ added in v0.5.3

func NewTigrisReplicaClient(tb testing.TB) *s3.ReplicaClient

NewTigrisReplicaClient returns an S3 client configured for Fly.io Tigris.

func NewWebDAVReplicaClient ¶ added in v0.5.3

func NewWebDAVReplicaClient(tb testing.TB) *webdav.ReplicaClient

NewWebDAVReplicaClient returns a new client for integration testing.

func ReplicaClientTypes ¶

func ReplicaClientTypes() []string