-
-
Notifications
You must be signed in to change notification settings - Fork 1.2k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
3d441f7
commit 4580fce
Showing
1 changed file
with
160 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,160 @@ | ||
|
||
## Elasticsearch plugin for Workflow Core | ||
|
||
A search index plugin for Workflow Core backed by Elasticsearch, enabling you to index your workflows and search against the data and state of them. | ||
|
||
### Configuration | ||
|
||
Use the `.UseElasticsearch` extension method on `IServiceCollection` when building your service provider | ||
|
||
```C# | ||
using Nest; | ||
... | ||
services.AddWorkflow(cfg => | ||
{ | ||
... | ||
cfg.UseElasticsearch(new ConnectionSettings(new Uri("http://localhost:9200")), "index_name"); | ||
}); | ||
``` | ||
|
||
### Usage | ||
|
||
Inject the `ISearchIndex` service into your code and use the `Search` method. | ||
|
||
``` | ||
Search(string terms, int skip, int take, params SearchFilter[] filters) | ||
``` | ||
|
||
#### terms | ||
|
||
A whitespace separated string of search terms, an empty string will match everything. | ||
This will do a full text search on the following default fields | ||
* Reference | ||
* Description | ||
* Status | ||
* Workflow Definition | ||
|
||
In addition you can search data within your own custom data object if it implements `ISearchable` | ||
|
||
```c# | ||
using WorkflowCore.Interfaces; | ||
... | ||
public class MyData : ISearchable | ||
{ | ||
public string StrValue1 { get; set; } | ||
public string StrValue2 { get; set; } | ||
|
||
public IEnumerable<string> GetSearchTokens() | ||
{ | ||
return new List<string>() | ||
{ | ||
StrValue1, | ||
StrValue2 | ||
}; | ||
} | ||
} | ||
``` | ||
|
||
##### Examples | ||
|
||
Search all fields for "puppies" | ||
```c# | ||
searchIndex.Search("puppies", 0, 10); | ||
``` | ||
|
||
#### skip & take | ||
|
||
Use `skip` and `take` to page your search results. Where `skip` is the result number to start from and `take` is the page size. | ||
|
||
#### filters | ||
|
||
You can also supply a list of filters to apply to the search, these can be applied to both the standard fields as well as any field within your custom data objects. | ||
There is no need to implement `ISearchable` on your data object in order to use filters against it. | ||
|
||
The following filter types are available | ||
* ScalarFilter | ||
* DateRangeFilter | ||
* NumericRangeFilter | ||
* StatusFilter | ||
|
||
These exist in the `WorkflowCore.Models.Search` namespace. | ||
|
||
##### Examples | ||
|
||
Filtering by reference | ||
```c# | ||
using WorkflowCore.Models.Search; | ||
... | ||
|
||
searchIndex.Search("", 0, 10, ScalarFilter.Equals(x => x.Reference, "My Reference")); | ||
``` | ||
|
||
Filtering by workflows started after a date | ||
```c# | ||
searchIndex.Search("", 0, 10, DateRangeFilter.After(x => x.CreateTime, startDate)); | ||
``` | ||
|
||
Filtering by workflows completed within a period | ||
```c# | ||
searchIndex.Search("", 0, 10, DateRangeFilter.Between(x => x.CompleteTime, startDate, endDate)); | ||
``` | ||
|
||
Filtering by workflows in a state | ||
```c# | ||
searchIndex.Search("", 0, 10, StatusFilter.Equals(WorkflowStatus.Complete)); | ||
``` | ||
|
||
Filtering against your own custom data class | ||
```c# | ||
|
||
class MyData | ||
{ | ||
public string Value1 { get; set; } | ||
public int Value2 { get; set; } | ||
} | ||
|
||
searchIndex.Search("", 0, 10, ScalarFilter.Equals<MyData>(x => x.Value1, "blue moon")); | ||
searchIndex.Search("", 0, 10, NumericRangeFilter.LessThan<MyData>(x => x.Value2, 5)) | ||
``` | ||
|
||
|
||
## Action Inputs / Outputs | ||
|
||
Added the action Input & Output overloads on the fluent step builder. | ||
|
||
```c# | ||
Input(Action<TStepBody, TData> action); | ||
``` | ||
|
||
This will allow one to manipulate properties on the step before it executes and properties on the data object after it executes, for example | ||
|
||
```c# | ||
Input((step, data) => step.Value1 = data.Value1) | ||
``` | ||
|
||
```c# | ||
.Output((step, data) => data["Value3"] = step.Output) | ||
``` | ||
|
||
```c# | ||
.Output((step, data) => data.MyCollection.Add(step.Output)) | ||
``` | ||
|
||
## Breaking changes | ||
|
||
The existing ability to assign values to entries in dictionaries or dynamic objects on `.Output` was problematic, | ||
since it broke the ability to pass collections on the Output mappings. | ||
|
||
|
||
```c# | ||
.Output(data => data["Value3"], step => step.Output) | ||
``` | ||
|
||
This feature has been removed, and it is advised to use the action Output API instead, for example | ||
|
||
|
||
```c# | ||
.Output((step, data) => data["Value3"] = step.Output) | ||
``` | ||
|
||
This functionality remains intact for JSON defined workflows. |