vendor/google.golang.org/grpc/resolver/passthrough/passthrough.go

   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 }