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
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
|
// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.vespa.http.client;
import com.yahoo.vespa.http.client.config.Endpoint;
import com.yahoo.vespa.http.client.core.Document;
import com.yahoo.vespa.http.client.core.Exceptions;
import net.jcip.annotations.Immutable;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.List;
/**
* The result of a stream operation. A Result refers to a single document,
* but may contain more than one Result.Detail instances, as these pertains to a
* single endpoint, and a Result may wrap data for multiple endpoints.
*
* @author Einar M R Rosenvinge
*/
// This should be an interface, but in order to be binary compatible during refactoring we made it abstract.
public class Result {
public enum ResultType {
OPERATION_EXECUTED,
TRANSITIVE_ERROR,
CONDITION_NOT_MET,
FATAL_ERROR
}
private final Document document;
private final boolean success;
private final List<Detail> details;
private final String localTrace;
public Result(Document document, Collection<Detail> values, StringBuilder localTrace) {
this.document = document;
this.details = Collections.unmodifiableList(new ArrayList<>(values));
boolean totalSuccess = true;
for (Detail d : details) {
if (d.getResultType() != ResultType.OPERATION_EXECUTED) {totalSuccess = false; }
}
this.success = totalSuccess;
this.localTrace = localTrace == null ? null : localTrace.toString();
}
/**
* Returns the document ID that this Result is for.
*
* @return the document ID that this Result is for.
*/
public String getDocumentId() {
return document.getDocumentId();
}
/**
* Returns the document data.
* @return data as bytebuffer.
*/
public CharSequence getDocumentDataAsCharSequence() {
return document.getDataAsString();
}
/**
* Returns the context of the object if any.
* @return context.
*/
public Object getContext() {
return document.getContext();
}
/**
* Returns true if the operation(s) was successful. If at least one {@link Detail}
* in {@link #getDetails()} is unsuccessful, this will return false.
*
* @return true if the operation was successful.
*/
public boolean isSuccess() {
return success;
}
public List<Detail> getDetails() { return details; }
/**
* Checks if operation has been set up with local tracing.
* @return true if operation has local trace.
*/
public boolean hasLocalTrace() {
return localTrace != null;
}
/**
* Information in a Result for a single operation sent to a single endpoint.
*/
@Immutable
public static final class Detail {
private final ResultType resultType;
private final Endpoint endpoint;
private final Exception exception;
private final String traceMessage;
private final long timeStampMillis = System.currentTimeMillis();
public Detail(Endpoint endpoint, ResultType resultType, String traceMessage, Exception e) {
this.endpoint = endpoint;
this.resultType = resultType;
this.exception = e;
this.traceMessage = traceMessage;
}
public Detail(Endpoint endpoint) {
this.endpoint = endpoint;
this.resultType = ResultType.OPERATION_EXECUTED;
this.exception = null;
this.traceMessage = null;
}
/**
* Returns the endpoint from which the result was received.
*
* @return the endpoint from which the result was received.
*/
public Endpoint getEndpoint() {
return endpoint;
}
/**
* Check if operation was successful.
*
* @return true if the operation was successful.
*/
public boolean isSuccess() {
return resultType == ResultType.OPERATION_EXECUTED;
}
/**
* Returns the result of the operation.
*/
public ResultType getResultType() {
return resultType;
}
/**
* Returns any exception related to this Detail, if unsuccessful. Might be null.
*
* @return any exception related to this Detail, if unsuccessful. Might be null.
*/
public Exception getException() {
return exception;
}
/**
* Returns trace message if any from gateway.
* @return null or trace message.
*/
public String getTraceMessage() {
return traceMessage;
}
@Override
public String toString() {
StringBuilder b = new StringBuilder();
b.append("Detail ");
b.append("resultType=").append(resultType);
if (exception != null) {
b.append(" exception='").append(Exceptions.toMessageString(exception)).append("'");
}
if (traceMessage != null && ! traceMessage.isEmpty()) {
b.append(" trace='").append(traceMessage).append("'");
}
b.append(" endpoint=").append(endpoint);
b.append(" resultTimeLocally=").append(timeStampMillis).append("\n");
return b.toString();
}
}
@Override
public String toString() {
StringBuilder b = new StringBuilder();
b.append("Result for '").append(document.getDocumentId());
if (localTrace != null) {
b.append(localTrace);
}
return b.toString();
}
}
|
