Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type QueryExecutor ¶
type QueryExecutor struct {
// contains filtered or unexported fields
}
QueryExecutor is used to run a query against an inmemory event store
func NewQueryExecutor ¶
func NewQueryExecutor(store goengine.EventStore, streamName goengine.StreamName, resolver goengine.MessagePayloadResolver, query goengine.Query, queryBatchSize uint) (*QueryExecutor, error)
NewQueryExecutor returns a new QueryExecutor instance
func (*QueryExecutor) Reset ¶
func (e *QueryExecutor) Reset(ctx context.Context)
Reset sets the executor to it's initial state
Source Files
Click to show internal directories.
Click to hide internal directories.