ps

type Base interface {
	Start() error

	// Destroy close partition store if it running currently.
	Close() error

	// Destroy close partition store if it running currently and remove all data file from filesystem.
	Destroy() error

	// GetMeta returns meta information about this store.
	GetPartition() *entity.Partition

	//GetEngine return engine
	GetEngine() engine.Engine

	//space change API
	GetSpace() entity.Space

	// SetSpace
	SetSpace(space *entity.Space)
}

type BatchHandler struct {
	// contains filtered or unexported fields
}

type ChangeMemberHandler struct {
	// contains filtered or unexported fields
}

type CreatePartitionHandler struct {
	// contains filtered or unexported fields
}

type DeleteByQueryHandler int

type DeletePartitionHandler struct {
	// contains filtered or unexported fields
}

type FlushHandler struct {
	// contains filtered or unexported fields
}

type ForceMergeHandler struct {
	// contains filtered or unexported fields
}

type GetDocHandler int

type GetDocsHandler int

type InitAdminHandler struct {
	// contains filtered or unexported fields
}

type InitHandler struct {
	// contains filtered or unexported fields
}

type IsLiveHandler int

type MSearchHandler int

type PartitionSizeHandler int

type PartitionStore interface {
	Base

	Raft

	UpdateSpace(ctx context.Context, space *entity.Space) error

	GetDocument(ctx context.Context, readLeader bool, docID string) (doc *response.DocResult, err error)

	GetDocuments(ctx context.Context, readLeader bool, docIds []string) (results response.DocResults, err error)

	DeleteByQuery(ctx context.Context, readLeader bool, query *request.SearchRequest) (delCount int, err error)

	Search(ctx context.Context, readLeader bool, query *request.SearchRequest) (result *response.SearchResponse, err error)

	MSearch(ctx context.Context, readLeader bool, query *request.SearchRequest) (result response.SearchResponses, err error)

	//you can use ctx to cancel the stream , when this function returned will close resultChan
	StreamSearch(ctx context.Context, readLeader bool, query *request.SearchRequest, resultChan chan *response.DocResult) error

	Write(ctx context.Context, request *pspb.DocCmd) (result *response.DocResult, err error)

	Flush(ctx context.Context) error
}

type Raft interface {
	GetLeader() (entity.NodeID, uint64)

	IsLeader() bool

	GetVersion() uint64

	GetUnreachable(id uint64) []uint64

	ChangeMember(changeType proto.ConfChangeType, server *entity.Server) error
}

type SearchHandler int

type Server struct {
	// contains filtered or unexported fields
}

type SetStoreHandler struct {
	// contains filtered or unexported fields
}

type StatsHandler struct {
	// contains filtered or unexported fields
}

type StreamSearchHandler struct {
	// contains filtered or unexported fields
}

type UpdatePartitionHandler int

type WriteHandler struct {
	// contains filtered or unexported fields
}