18
18
19
19
import com .google .common .annotations .VisibleForTesting ;
20
20
import io .grpc .Attributes ;
21
- import io .grpc .BindableService ;
22
- import io .grpc .CompressorRegistry ;
23
- import io .grpc .DecompressorRegistry ;
24
21
import io .grpc .ExperimentalApi ;
25
- import io .grpc .HandlerRegistry ;
22
+ import io .grpc .ForwardingServerBuilder ;
23
+ import io .grpc .Internal ;
26
24
import io .grpc .Server ;
27
25
import io .grpc .ServerBuilder ;
28
- import io .grpc .ServerInterceptor ;
29
- import io .grpc .ServerServiceDefinition ;
30
- import io .grpc .ServerStreamTracer ;
31
- import io .grpc .ServerTransportFilter ;
32
26
import io .grpc .Status ;
33
27
import io .grpc .netty .InternalNettyServerBuilder ;
34
28
import io .grpc .netty .InternalProtocolNegotiator .ProtocolNegotiator ;
42
36
import java .io .File ;
43
37
import java .io .InputStream ;
44
38
import java .net .InetSocketAddress ;
45
- import java .util .concurrent .Executor ;
46
- import java .util .concurrent .TimeUnit ;
47
- import javax .annotation .Nullable ;
48
39
import javax .net .ssl .SSLException ;
49
40
50
41
/**
51
42
* A version of {@link ServerBuilder} to create xDS managed servers that will use SDS to set up SSL
52
43
* with peers. Note, this is not ready to use yet.
53
44
*/
54
- public final class XdsServerBuilder extends ServerBuilder <XdsServerBuilder > {
45
+ public final class XdsServerBuilder extends ForwardingServerBuilder <XdsServerBuilder > {
55
46
56
47
private final NettyServerBuilder delegate ;
57
48
private final int port ;
@@ -64,63 +55,9 @@ private XdsServerBuilder(NettyServerBuilder nettyDelegate, int port) {
64
55
}
65
56
66
57
@ Override
67
- public XdsServerBuilder handshakeTimeout (long timeout , TimeUnit unit ) {
68
- delegate .handshakeTimeout (timeout , unit );
69
- return this ;
70
- }
71
-
72
- @ Override
73
- public XdsServerBuilder directExecutor () {
74
- delegate .directExecutor ();
75
- return this ;
76
- }
77
-
78
- @ Override
79
- public XdsServerBuilder addStreamTracerFactory (ServerStreamTracer .Factory factory ) {
80
- delegate .addStreamTracerFactory (factory );
81
- return this ;
82
- }
83
-
84
- @ Override
85
- public XdsServerBuilder addTransportFilter (ServerTransportFilter filter ) {
86
- delegate .addTransportFilter (filter );
87
- return this ;
88
- }
89
-
90
- @ Override
91
- public XdsServerBuilder executor (Executor executor ) {
92
- delegate .executor (executor );
93
- return this ;
94
- }
95
-
96
- @ Override
97
- public XdsServerBuilder addService (ServerServiceDefinition service ) {
98
- delegate .addService (service );
99
- return this ;
100
- }
101
-
102
- @ Override
103
- public XdsServerBuilder addService (BindableService bindableService ) {
104
- delegate .addService (bindableService );
105
- return this ;
106
- }
107
-
108
- @ Override
109
- public XdsServerBuilder fallbackHandlerRegistry (@ Nullable HandlerRegistry fallbackRegistry ) {
110
- delegate .fallbackHandlerRegistry (fallbackRegistry );
111
- return this ;
112
- }
113
-
114
- @ Override
115
- public XdsServerBuilder useTransportSecurity (File certChain , File privateKey ) {
116
- delegate .useTransportSecurity (certChain , privateKey );
117
- return this ;
118
- }
119
-
120
- @ Override
121
- public XdsServerBuilder useTransportSecurity (InputStream certChain , InputStream privateKey ) {
122
- delegate .useTransportSecurity (certChain , privateKey );
123
- return this ;
58
+ @ Internal
59
+ protected ServerBuilder <?> delegate () {
60
+ return delegate ;
124
61
}
125
62
126
63
/**
@@ -163,24 +100,6 @@ public XdsServerBuilder useXdsSecurityWithTransportSecurityFallback(
163
100
return this ;
164
101
}
165
102
166
- @ Override
167
- public XdsServerBuilder decompressorRegistry (@ Nullable DecompressorRegistry registry ) {
168
- delegate .decompressorRegistry (registry );
169
- return this ;
170
- }
171
-
172
- @ Override
173
- public XdsServerBuilder compressorRegistry (@ Nullable CompressorRegistry registry ) {
174
- delegate .compressorRegistry (registry );
175
- return this ;
176
- }
177
-
178
- @ Override
179
- public XdsServerBuilder intercept (ServerInterceptor interceptor ) {
180
- delegate .intercept (interceptor );
181
- return this ;
182
- }
183
-
184
103
/** Set the fallback protocolNegotiator. Pass null to unset a previously set value. */
185
104
public XdsServerBuilder fallbackProtocolNegotiator (
186
105
ProtocolNegotiator fallbackProtocolNegotiator ) {
0 commit comments