Rename Batch.Indexed to Batch.Type

batch.go

@@ -18,13 +18,20 @@ type Committer interface {
 	OnClose(func(b Batch))
 }
 
+type BatchType int
+
+const (
+	BatchTypeWriteOnly BatchType = iota
+	BatchTypeReadWrite
+)
+
 type Batch interface {
 	ID() uint64
 	Len() int
 	Empty() bool
 	Reset()
 
-	Indexed() bool
+	Type() BatchType
 
 	Getter
 	Setter
@@ -66,6 +73,13 @@ func (b *_batch) ID() uint64 {
 	return b.id
 }
 
+func (b *_batch) Type() BatchType {
+	if b.Batch.Indexed() {
+		return BatchTypeReadWrite
+	}
+	return BatchTypeWriteOnly
+}
+
 func (b *_batch) Reset() {
 	b.Batch.Reset()
 

bond.go

@@ -62,13 +62,6 @@ type DeleterWithRange interface {
 	DeleteRange(start []byte, end []byte, opt WriteOptions, batch ...Batch) error
 }
 
-type BatchType int
-
-const (
-	BatchTypeWriteOnly BatchType = iota
-	BatchTypeReadWrite
-)
-
 type Batcher interface {
 	Batch(bType BatchType) Batch
 }

context_test.go

@@ -18,27 +18,27 @@ func (m *MockBatch) ID() uint64 {
 	panic("implement me")
 }
 
-func (m *MockBatch) Len() int {
+func (m *MockBatch) Type() BatchType {
 	//TODO implement me
 	panic("implement me")
 }
 
-func (m *MockBatch) Empty() bool {
+func (m *MockBatch) Len() int {
 	//TODO implement me
 	panic("implement me")
 }
 
-func (m *MockBatch) Reset() {
+func (m *MockBatch) Empty() bool {
 	//TODO implement me
 	panic("implement me")
 }
 
-func (m *MockBatch) ResetRetained() {
+func (m *MockBatch) Reset() {
 	//TODO implement me
 	panic("implement me")
 }
 
-func (m *MockBatch) Indexed() bool {
+func (m *MockBatch) ResetRetained() {
 	//TODO implement me
 	panic("implement me")
 }

table.go

@@ -342,9 +342,9 @@ func (t *_table[T]) Insert(ctx context.Context, trs []T, optBatch ...Batch) erro
 	t.mutex.RUnlock()
 
 	var (
-		batch         Batch
-		batchIndexed  Batch
-		externalBatch = len(optBatch) > 0 && optBatch[0] != nil
+		batch          Batch
+		batchReadWrite Batch
+		externalBatch  = len(optBatch) > 0 && optBatch[0] != nil
 	)
 
 	if externalBatch {
@@ -354,8 +354,8 @@ func (t *_table[T]) Insert(ctx context.Context, trs []T, optBatch ...Batch) erro
 		defer batch.Close()
 	}
 
-	if batch.Indexed() {
-		batchIndexed = batch
+	if batch.Type() == BatchTypeReadWrite {
+		batchReadWrite = batch
 	}
 
 	var (
@@ -391,7 +391,7 @@ func (t *_table[T]) Insert(ctx context.Context, trs []T, optBatch ...Batch) erro
 				LowerBound: keys[0],
 				UpperBound: t.dataKeySpaceEnd,
 			},
-		}, batchIndexed)
+		}, batchReadWrite)
 		defer iter.Close()
 
 		// process rows
@@ -456,9 +456,9 @@ func (t *_table[T]) Update(ctx context.Context, trs []T, optBatch ...Batch) erro
 	t.mutex.RUnlock()
 
 	var (
-		batch         Batch
-		batchIndexed  Batch
-		externalBatch = len(optBatch) > 0 && optBatch[0] != nil
+		batch          Batch
+		batchReadWrite Batch
+		externalBatch  = len(optBatch) > 0 && optBatch[0] != nil
 	)
 
 	if externalBatch {
@@ -468,8 +468,8 @@ func (t *_table[T]) Update(ctx context.Context, trs []T, optBatch ...Batch) erro
 		defer batch.Close()
 	}
 
-	if batch.Indexed() {
-		batchIndexed = batch
+	if batch.Type() == BatchTypeReadWrite {
+		batchReadWrite = batch
 	}
 
 	var (
@@ -510,7 +510,7 @@ func (t *_table[T]) Update(ctx context.Context, trs []T, optBatch ...Batch) erro
 				LowerBound: keys[0],
 				UpperBound: t.dataKeySpaceEnd,
 			},
-		}, batchIndexed)
+		}, batchReadWrite)
 		defer iter.Close()
 
 		for i, key := range keys {
@@ -641,9 +641,9 @@ func (t *_table[T]) Upsert(ctx context.Context, trs []T, onConflict func(old, ne
 	t.mutex.RUnlock()
 
 	var (
-		batch         Batch
-		batchIndexed  Batch
-		externalBatch = len(optBatch) > 0 && optBatch[0] != nil
+		batch          Batch
+		batchReadWrite Batch
+		externalBatch  = len(optBatch) > 0 && optBatch[0] != nil
 	)
 
 	if externalBatch {
@@ -653,8 +653,8 @@ func (t *_table[T]) Upsert(ctx context.Context, trs []T, onConflict func(old, ne
 		defer batch.Close()
 	}
 
-	if batch.Indexed() {
-		batchIndexed = batch
+	if batch.Type() == BatchTypeReadWrite {
+		batchReadWrite = batch
 	}
 
 	var (
@@ -695,7 +695,7 @@ func (t *_table[T]) Upsert(ctx context.Context, trs []T, onConflict func(old, ne
 				LowerBound: keys[0],
 				UpperBound: t.dataKeySpaceEnd,
 			},
-		}, batchIndexed)
+		}, batchReadWrite)
 		defer iter.Close()
 
 		for i := 0; i < len(keys); {