Checkpoint

event/field/field.go

@@ -2,6 +2,8 @@ package field
 
 import (
 	"fmt"
+
+	"github.com/xichen2020/eventdb/event/field"
 )
 
 // ValueType is the type of a field value.
@@ -46,6 +48,21 @@ func (t ValueType) ConvertibleFrom() ([]ValueType, error) {
 	return nil, fmt.Errorf("unknown value type %v does not have comparable types", t)
 }
 
+// ValueTypeSet is a set of value types.
+type ValueTypeSet map[field.ValueType]struct{}
+
+// Clone clones a value type set.
+func (m ValueTypeSet) Clone() ValueTypeSet {
+	if len(m) == 0 {
+		return nil
+	}
+	cloned := make(field.ValueTypeSet, len(m))
+	for k := range m {
+		cloned[k] = struct{}{}
+	}
+	return cloned
+}
+
 // ValueUnion is a value union.
 type ValueUnion struct {
 	Type         ValueType

filter/bool_filter.go

@@ -6,6 +6,8 @@ type BoolFilter interface {
 	Match(v bool) bool
 }
 
+type boolToBoolFilterFn func(bool) boolFilterFn
+
 type boolFilterFn func(v bool) bool
 
 func (fn boolFilterFn) Match(v bool) bool { return fn(v) }

filter/double_filter.go

@@ -4,17 +4,20 @@ import (
 	"math"
 )
 
-const (
-	// doubleEps is used to determine whether two floating point numbers are considered equal.
-	doubleEps = 1e-10
-)
-
 // DoubleFilter matches against double values.
 type DoubleFilter interface {
 	// Match returns true if the given value is considered a match.
 	Match(v float64) bool
 }
 
+const (
+	// doubleEps is used to determine whether two floating point numbers are considered equal.
+	doubleEps = 1e-10
+)
+
+type doubleToDoubleFilterFn func(float64) doubleFilterFn
+type intToDoubleFilterFn func(int) doubleFilterFn
+
 type doubleFilterFn func(v float64) bool
 
 func (fn doubleFilterFn) Match(v float64) bool { return fn(v) }