Function NewBundleReader

internal/storage/postgres/bundle_reader.go:25–30

(database *db.Postgres)

}

func NewBundleReader(database *db.Postgres) *BundleReader {
	return &BundleReader{
		database:  database,
		txOptions: pgx.TxOptions{IsoLevel: pgx.ReadCommitted, AccessMode: pgx.ReadWrite},
	}
}

func (b *BundleReader) Read(ctx context.Context, tenantID, name string) (bundle *base.DataBundle, err error) {
	ctx, span := internal.Tracer.Start(ctx, "bundle-reader.read-bundle")