Function NewBundleWriter

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

(database *db.Postgres)

}

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

func (b *BundleWriter) Write(ctx context.Context, bundles []storage.Bundle) (names []string, err error) {
	ctx, span := internal.Tracer.Start(ctx, "bundle-writer.write-bundle")