protoProjector

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

type IndexEvaluatorStats struct {
	Count     stats.Int64Val
	TotalDur  stats.Int64Val
	PrevCount stats.Int64Val
	PrevDur   stats.Int64Val
	SMA       stats.Int64Val // Simple moving average

	// ErrSkip represents number of mutations skipped since the
	// last call to GetAndResetErrorSkip
	ErrSkip stats.Int64Val

	// Total number of mutations skipped since this stat object was initialized.
	ErrSkipAll stats.Int64Val
}

type Partition interface {
	// Hosts return full list of endpoints <host:port>
	// that are listening for this instance.
	Hosts(*IndexInst) []string

	// UpsertEndpoints return a list of endpoints <host:port>
	// to which Upsert message will be published.
	UpsertEndpoints(i *IndexInst, m *mc.DcpEvent, partKey, key, oldKey []byte) []string

	// UpsertDeletionEndpoints return a list of endpoints
	// <host:port> to which UpsertDeletion message will be
	// published.
	UpsertDeletionEndpoints(i *IndexInst, m *mc.DcpEvent, partKey, key, oldKey []byte) []string

	// DeletionEndpoints return a list of endpoints
	// <host:port> to which Deletion message will be published.
	DeletionEndpoints(i *IndexInst, m *mc.DcpEvent, partKey, oldKey []byte) []string
}