diff options
Diffstat (limited to 'vendor/google.golang.org/grpc/resolver/passthrough/passthrough.go')
-rw-r--r-- | vendor/google.golang.org/grpc/resolver/passthrough/passthrough.go | 57 |
1 files changed, 57 insertions, 0 deletions
diff --git a/vendor/google.golang.org/grpc/resolver/passthrough/passthrough.go b/vendor/google.golang.org/grpc/resolver/passthrough/passthrough.go new file mode 100644 index 0000000..b76010d --- /dev/null +++ b/vendor/google.golang.org/grpc/resolver/passthrough/passthrough.go | |||
@@ -0,0 +1,57 @@ | |||
1 | /* | ||
2 | * | ||
3 | * Copyright 2017 gRPC authors. | ||
4 | * | ||
5 | * Licensed under the Apache License, Version 2.0 (the "License"); | ||
6 | * you may not use this file except in compliance with the License. | ||
7 | * You may obtain a copy of the License at | ||
8 | * | ||
9 | * http://www.apache.org/licenses/LICENSE-2.0 | ||
10 | * | ||
11 | * Unless required by applicable law or agreed to in writing, software | ||
12 | * distributed under the License is distributed on an "AS IS" BASIS, | ||
13 | * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
14 | * See the License for the specific language governing permissions and | ||
15 | * limitations under the License. | ||
16 | * | ||
17 | */ | ||
18 | |||
19 | // Package passthrough implements a pass-through resolver. It sends the target | ||
20 | // name without scheme back to gRPC as resolved address. | ||
21 | package passthrough | ||
22 | |||
23 | import "google.golang.org/grpc/resolver" | ||
24 | |||
25 | const scheme = "passthrough" | ||
26 | |||
27 | type passthroughBuilder struct{} | ||
28 | |||
29 | func (*passthroughBuilder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOption) (resolver.Resolver, error) { | ||
30 | r := &passthroughResolver{ | ||
31 | target: target, | ||
32 | cc: cc, | ||
33 | } | ||
34 | r.start() | ||
35 | return r, nil | ||
36 | } | ||
37 | |||
38 | func (*passthroughBuilder) Scheme() string { | ||
39 | return scheme | ||
40 | } | ||
41 | |||
42 | type passthroughResolver struct { | ||
43 | target resolver.Target | ||
44 | cc resolver.ClientConn | ||
45 | } | ||
46 | |||
47 | func (r *passthroughResolver) start() { | ||
48 | r.cc.NewAddress([]resolver.Address{{Addr: r.target.Endpoint}}) | ||
49 | } | ||
50 | |||
51 | func (*passthroughResolver) ResolveNow(o resolver.ResolveNowOption) {} | ||
52 | |||
53 | func (*passthroughResolver) Close() {} | ||
54 | |||
55 | func init() { | ||
56 | resolver.Register(&passthroughBuilder{}) | ||
57 | } | ||