diff --git a/internal/storage/payload.go b/internal/storage/payload.go index ec624ad0a7..4b5a5ae60f 100644 --- a/internal/storage/payload.go +++ b/internal/storage/payload.go @@ -30,6 +30,7 @@ import ( "github.com/milvus-io/milvus/internal/proto/schemapb" ) +// PayloadWriterInterface abstracts PayloadWriter type PayloadWriterInterface interface { AddDataToPayload(msgs interface{}, dim ...int) error AddBoolToPayload(msgs []bool) error @@ -49,6 +50,7 @@ type PayloadWriterInterface interface { Close() } +// PayloadReaderInterface abstracts PayloadReader type PayloadReaderInterface interface { GetDataFromPayload(idx ...int) (interface{}, int, error) GetBoolFromPayload() ([]bool, error)