ServiceControl/src/ServiceControl.Audit.Persistence.Tests.RavenDB/ApprovalFiles/IndexDefinitionTests.VerifyGeneratedDefinitions.approved.txt at ab94a81dfcc366ff54b96bd4f543c9cab6ba01dd · Particular/ServiceControl · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
Index: FailedAuditImportIndex
Type: Map
SourceType: Documents
Maps:
  docs.FailedAuditImports.Select(cc => new {
    Id = Id(cc)
})
Reduce: (none)
Fields:
Configuration:
  Indexing.Static.SearchEngineType=Lucene
AdditionalSources:
AdditionalAssemblies: 0
OutputReduceToCollection: (none)

Index: MessagesViewIndex
Type: Map
SourceType: Documents
Maps:
  docs.ProcessedMessages.Select(message => new {
    MessageId = ((string) message.MessageMetadata["MessageId"]),
    MessageType = ((string) message.MessageMetadata["MessageType"]),
    IsSystemMessage = ((bool) message.MessageMetadata["IsSystemMessage"]),
    Status = ((bool) message.MessageMetadata["IsRetried"]) ? 4 : 3,
    TimeSent = ((DateTime) message.MessageMetadata["TimeSent"]),
    ProcessedAt = message.ProcessedAt,
    ReceivingEndpointName = ((message.MessageMetadata["ReceivingEndpoint"])).Name,
    SendingEndpointName = ((message.MessageMetadata["SendingEndpoint"])).Name,
    CriticalTime = ((TimeSpan ? ) message.MessageMetadata["CriticalTime"]),
    ProcessingTime = ((TimeSpan ? ) message.MessageMetadata["ProcessingTime"]),
    DeliveryTime = ((TimeSpan ? ) message.MessageMetadata["DeliveryTime"]),
    Query = Enumerable.ToArray(DynamicEnumerable.Union(message.MessageMetadata.ToDictionary(e1 => e1.Key, e1 => e1.Value).Select(_ => _.Value.ToString()), new string[] {
        String.Join(" ", message.Headers.ToDictionary(e1 => e1.Key, e1 => e1.Value).Select(x => x.Value))
    })),
    ConversationId = ((string) message.MessageMetadata["ConversationId"])
})
Reduce: (none)
Fields:
  Query: Storage=, Indexing=Search, TermVector=, Suggestions=, Analyzer=Lucene.Net.Analysis.Standard.StandardAnalyzer, Lucene.Net, Version=3.0.3.0, Culture=neutral, PublicKeyToken=85089178b9ac3181, HasSpatial=False
Configuration:
  Indexing.Static.SearchEngineType=Lucene
AdditionalSources:
AdditionalAssemblies: 0
OutputReduceToCollection: (none)

Index: MessagesViewIndexWithFullTextSearch
Type: Map
SourceType: Documents
Maps:
  docs.ProcessedMessages.Select(message => new {
    MessageId = ((string) message.MessageMetadata["MessageId"]),
    MessageType = ((string) message.MessageMetadata["MessageType"]),
    IsSystemMessage = ((bool) message.MessageMetadata["IsSystemMessage"]),
    Status = ((bool) message.MessageMetadata["IsRetried"]) ? 4 : 3,
    TimeSent = ((DateTime) message.MessageMetadata["TimeSent"]),
    ProcessedAt = message.ProcessedAt,
    ReceivingEndpointName = ((message.MessageMetadata["ReceivingEndpoint"])).Name,
    SendingEndpointName = ((message.MessageMetadata["SendingEndpoint"])).Name,
    CriticalTime = ((TimeSpan ? ) message.MessageMetadata["CriticalTime"]),
    ProcessingTime = ((TimeSpan ? ) message.MessageMetadata["ProcessingTime"]),
    DeliveryTime = ((TimeSpan ? ) message.MessageMetadata["DeliveryTime"]),
    Query = Enumerable.ToArray(DynamicEnumerable.Union(message.MessageMetadata.ToDictionary(e1 => e1.Key, e1 => e1.Value).Select(_ => _.Value.ToString()), new string[] {
        String.Join(" ", message.Headers.ToDictionary(e1 => e1.Key, e1 => e1.Value).Select(x => x.Value)),
        this.LoadAttachment(message, "body").GetContentAsString()
    })),
    ConversationId = ((string) message.MessageMetadata["ConversationId"])
})
Reduce: (none)
Fields:
  Query: Storage=, Indexing=Search, TermVector=, Suggestions=, Analyzer=Lucene.Net.Analysis.Standard.StandardAnalyzer, Lucene.Net, Version=3.0.3.0, Culture=neutral, PublicKeyToken=85089178b9ac3181, HasSpatial=False
Configuration:
  Indexing.Static.SearchEngineType=Lucene
AdditionalSources:
AdditionalAssemblies: 0
OutputReduceToCollection: (none)

Index: SagaDetailsIndex
Type: MapReduce
SourceType: Documents
Maps:
  docs.SagaHistories.Select(doc => new {
    SagaId = doc.SagaId,
    Id = doc.SagaId,
    SagaType = doc.SagaType,
    Changes = doc.Changes
})
  docs.SagaSnapshots.Select(doc => new {
    SagaId = doc.SagaId,
    Id = doc.SagaId,
    SagaType = doc.SagaType,
    Changes = new[] {
        new {
            Endpoint = doc.Endpoint,
            FinishTime = doc.FinishTime,
            InitiatingMessage = doc.InitiatingMessage,
            OutgoingMessages = doc.OutgoingMessages,
            StartTime = doc.StartTime,
            StateAfterChange = doc.StateAfterChange,
            Status = doc.Status
        }
    }
})
Reduce: results.GroupBy(result => result.SagaId).Select(g => new {
    g = g,
    first = DynamicEnumerable.FirstOrDefault(g)
}).Select(this0 => new {
    Id = this0.first.SagaId,
    SagaId = this0.first.SagaId,
    SagaType = this0.first.SagaType,
    Changes = Enumerable.ToList(DynamicEnumerable.OrderByDescending(this0.g.SelectMany(x => x.Changes), x0 => x0.FinishTime).Take(50000))
})
Fields:
  Changes: Storage=, Indexing=No, TermVector=, Suggestions=, Analyzer=(none), HasSpatial=False
  SagaId: Storage=, Indexing=Exact, TermVector=, Suggestions=, Analyzer=(none), HasSpatial=False
  SagaType: Storage=, Indexing=No, TermVector=, Suggestions=, Analyzer=(none), HasSpatial=False
Configuration:
  Indexing.Static.SearchEngineType=Lucene
AdditionalSources:
AdditionalAssemblies: 0
OutputReduceToCollection: (none)