Add iface defs for all types.

encoding/bool/encoding.go

@@ -0,0 +1,45 @@
+package bool
+
+import (
+	"io"
+
+	"github.com/xichen2020/eventdb/encoding/common"
+)
+
+// Encoder encodes bool values.
+type Encoder interface {
+	// Encode a collection of bools.
+	// Callers should explicitly call `Reset` before
+	// subsequent call to `Encode`.
+	Encode(values Iterator) error
+	// Bytes returns the encoded bytes of the encoder.
+	Bytes() []byte
+	// Reset should be called between `Encode` calls.
+	Reset()
+}
+
+// Decoder decodes bool values.
+type Decoder interface {
+	// Decode the source bytes.
+	// Callers should explicitly call `Reset` before
+	// subsequent call to `Decode`.
+	Decode(src common.Reader) (Iterator, error)
+	// Reset should be called between `Decode` calls.
+	Reset()
+}
+
+// Iterator lazily produces bool values decoded from a byte stream.
+type Iterator interface {
+	io.Closer
+
+	// Next returns true if there is another value
+	// in the data stream. If it returns false, err should be
+	// checked for errors.
+	Next() bool
+	// Current returns the current value in the iteration.
+	Current() bool
+	// Err returns any error encountered during iteration.
+	Err() error
+	// Reset iteration back to the first item in the collection.
+	Reset()
+}

encoding/common/common.go

@@ -0,0 +1,11 @@
+package common
+
+import (
+	"io"
+)
+
+// Reader wraps both `io.Reader` and `io.ByteReader` interfaces.
+type Reader interface {
+	io.Reader
+	io.ByteReader
+}

encoding/double/encoding.go

@@ -0,0 +1,45 @@
+package double
+
+import (
+	"io"
+
+	"github.com/xichen2020/eventdb/encoding/common"
+)
+
+// Encoder encodes float64 values.
+type Encoder interface {
+	// Encode a collection of float64s.
+	// Callers should explicitly call `Reset` before
+	// subsequent call to `Encode`.
+	Encode(values Iterator) error
+	// Bytes returns the encoded bytes of the encoder.
+	Bytes() []byte
+	// Reset should be called between `Encode` calls.
+	Reset()
+}
+
+// Decoder decodes float64 values.
+type Decoder interface {
+	// Decode the source bytes.
+	// Callers should explicitly call `Reset` before
+	// subsequent call to `Decode`.
+	Decode(src common.Reader) (Iterator, error)
+	// Reset should be called between `Decode` calls.
+	Reset()
+}
+
+// Iterator lazily produces float64 values decoded from a byte stream.
+type Iterator interface {
+	io.Closer
+
+	// Next returns true if there is another value
+	// in the data stream. If it returns false, err should be
+	// checked for errors.
+	Next() bool
+	// Current returns the current value in the iteration.
+	Current() float64
+	// Err returns any error encountered during iteration.
+	Err() error
+	// Reset iteration back to the first item in the collection.
+	Reset()
+}

encoding/int/encoding.go

@@ -1,6 +1,10 @@
 package int
 
-import "io"
+import (
+	"io"
+
+	"github.com/xichen2020/eventdb/encoding/common"
+)
 
 // Encoder encodes int values.
 type Encoder interface {
@@ -19,7 +23,7 @@ type Decoder interface {
 	// Decode the source bytes.
 	// Callers should explicitly call `Reset` before
 	// subsequent call to `Decode`.
-	Decode(src io.Reader) (Iterator, error)
+	Decode(src common.Reader) (Iterator, error)
 	// Reset should be called between `Decode` calls.
 	Reset()
 }

encoding/string/encoding.go

@@ -1,6 +1,10 @@
 package string
 
-import "io"
+import (
+	"io"
+
+	"github.com/xichen2020/eventdb/encoding/common"
+)
 
 // Encoder encodes string values.
 type Encoder interface {
@@ -19,7 +23,7 @@ type Decoder interface {
 	// Decode the source bytes.
 	// Callers should explicitly call `Reset` before
 	// subsequent call to `Decode`.
-	Decode(src io.Reader) (Iterator, error)
+	Decode(src common.Reader) (Iterator, error)
 	// Reset should be called between `Decode` calls.
 	Reset()
 }