-
Notifications
You must be signed in to change notification settings - Fork 5
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
6f44082
commit 8a804cf
Showing
30 changed files
with
1,028 additions
and
143 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 |
|---|---|---|
|
|
@@ -262,3 +262,6 @@ __pycache__/ | |
|
|
||
| # Config settings | ||
| local.settings.json | ||
|
|
||
| #publish profiles | ||
| *.pubxml | ||
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
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
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
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
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
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
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
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,85 @@ | ||
| using Microsoft.Azure.WebJobs; | ||
| using Microsoft.Azure.WebJobs.Description; | ||
| using System; | ||
| using System.Collections.Generic; | ||
| using System.Linq; | ||
| using System.Text; | ||
| using System.Threading.Tasks; | ||
|
|
||
| namespace TheLongRun.Common.Attributes | ||
| { | ||
| /// <summary> | ||
| /// An attribute to mark a projection to use for reading identity group membership from | ||
| /// </summary> | ||
| /// <remarks> | ||
| /// This is not a trigger - we decide on a case by case basis what triggers a classifier | ||
| /// and the same classifier may have different invocations | ||
| /// </remarks> | ||
| [AttributeUsage(AttributeTargets.Parameter)] | ||
| [Binding] | ||
| public class ClassifierAttribute | ||
| : Attribute, | ||
| CQRSAzure.EventSourcing.IEventStreamUntypedIdentity | ||
| { | ||
|
|
||
| /// <summary> | ||
| /// The domain name the aggregate instance belongs to | ||
| /// </summary> | ||
| private readonly string _domainName; | ||
| public string DomainName | ||
| { | ||
| get | ||
| { | ||
| return _domainName; | ||
| } | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// The aggregate type to which the event stream belongs | ||
| /// </summary> | ||
| private readonly string _aggregateTypeName; | ||
| public string AggregateTypeName | ||
| { | ||
| get | ||
| { | ||
| return _aggregateTypeName; | ||
| } | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// The unique identifier of the specific instance of the aggregate | ||
| /// </summary> | ||
| private readonly string _aggregateInstanceKey; | ||
| [AutoResolve] | ||
| public string InstanceKey | ||
| { | ||
| get | ||
| { | ||
| return _aggregateInstanceKey; | ||
| } | ||
| } | ||
|
|
||
| /// <summary> | ||
| /// The specific classifier type to execute | ||
| /// </summary> | ||
| private readonly string _classifierTypeName; | ||
| public string ClassifierTypeName | ||
| { | ||
| get | ||
| { | ||
| return _classifierTypeName; | ||
| } | ||
| } | ||
|
|
||
| public ClassifierAttribute(string domainName, | ||
| string aggregateTypeName, | ||
| string aggregateInstanceKey, | ||
| string classifierTypeName) | ||
| { | ||
| _domainName = domainName; | ||
| _aggregateTypeName = aggregateTypeName; | ||
| _aggregateInstanceKey = aggregateInstanceKey; | ||
| _classifierTypeName = classifierTypeName; | ||
| } | ||
| } | ||
| } |
Oops, something went wrong.