()
| 692 | } |
| 693 | |
| 694 | func (tx *Tx) SubmitBucket() error { |
| 695 | bucketReqs := make([]*bucketSubmitRequest, 0) |
| 696 | for ds, mapper := range tx.pendingBucketList { |
| 697 | for name, bucket := range mapper { |
| 698 | req := &bucketSubmitRequest{ |
| 699 | ds: ds, |
| 700 | name: name, |
| 701 | bucket: bucket, |
| 702 | } |
| 703 | bucketReqs = append(bucketReqs, req) |
| 704 | } |
| 705 | } |
| 706 | return tx.db.bucketMgr.SubmitPendingBucketChange(bucketReqs) |
| 707 | } |
| 708 | |
| 709 | // buildBucketInIndex build indexes on creation and deletion of buckets |
| 710 | func (tx *Tx) buildBucketInIndex() error { |
no test coverage detected