Versions in this module Expand all Collapse all v0 v0.3.0 Apr 21, 2020 Changes in this version + type Engine interface + ApplySnapshot func(peers []proto.Peer, iter proto.SnapIterator) error + Close func() + GetMapping func() *mapping.IndexMapping + GetPartitionID func() entity.PartitionID + GetSpace func() *entity.Space + IndexStatus func() int + MapDocument func(doc *pspb.DocCmd) ([]*pspb.Field, map[string]pspb.FieldType, error) + NewSnapshot func() (proto.Snapshot, error) + Optimize func() error + RTReader func() RTReader + Reader func() Reader + UpdateMapping func(space *entity.Space) error + Writer func() Writer + type RTReader interface + RTReadDoc func(ctx context.Context, docID string) *response.DocResult + type Reader interface + Capacity func(ctx context.Context) (int64, error) + DocCount func(ctx context.Context) (uint64, error) + GetDoc func(ctx context.Context, docID string) *response.DocResult + GetDocs func(ctx context.Context, docIDs []string) []*response.DocResult + MSearch func(ctx context.Context, request *request.SearchRequest) response.SearchResponses + MSearchIDs func(ctx context.Context, request *request.SearchRequest) ([]byte, error) + ReadSN func(ctx context.Context) (int64, error) + Search func(ctx context.Context, req *request.SearchRequest) *response.SearchResponse + StreamSearch func(ctx context.Context, req *request.SearchRequest, ...) error + type Writer interface + Commit func(ctx context.Context, sn int64) (chan error, error) + Create func(ctx context.Context, docCmd *pspb.DocCmd) *response.DocResult + Delete func(ctx context.Context, docCmd *pspb.DocCmd) *response.DocResult + Flush func(ctx context.Context, sn int64) error + Update func(ctx context.Context, docCmd *pspb.DocCmd) *response.DocResult + Write func(ctx context.Context, docCmd *pspb.DocCmd) *response.DocResult Incompatible versions in this module v3.2.0+incompatible Sep 7, 2020 v3.1.0+incompatible May 29, 2020