(request *pb.ExportRequest, dir string, key x.Sensitive)
| 149 | } |
| 150 | |
| 151 | func StoreExport(request *pb.ExportRequest, dir string, key x.Sensitive) error { |
| 152 | db, err := badger.OpenManaged(badger.DefaultOptions(dir). |
| 153 | WithSyncWrites(false). |
| 154 | WithValueThreshold(1 << 10). |
| 155 | WithNumVersionsToKeep(math.MaxInt32). |
| 156 | WithEncryptionKey(key)) |
| 157 | if err != nil { |
| 158 | return err |
| 159 | } |
| 160 | defer func() { |
| 161 | if err := db.Close(); err != nil { |
| 162 | glog.Warningf("error closing the DB: %v", err) |
| 163 | } |
| 164 | }() |
| 165 | |
| 166 | _, err = exportInternal(context.Background(), request, db, true) |
| 167 | return errors.Wrapf(err, "cannot export data inside DB at %s", dir) |
| 168 | } |
| 169 | |
| 170 | // Backup handles a request coming from another node. |
| 171 | func (w *grpcWorker) Backup(ctx context.Context, req *pb.BackupRequest) (*pb.BackupResponse, error) { |
nothing calls this directly
no test coverage detected
searching dependent graphs…