vendor/google.golang.org/grpc/grpclb/grpc_lb_v1/service/service.pb.go

   1 // Code generated by protoc-gen-go. DO NOT EDIT.
   2 // source: grpc_lb_v1/service/service.proto
   3
   4 /*
   5 Package service is a generated protocol buffer package.
   6
   7 It is generated from these files:
   8         grpc_lb_v1/service/service.proto
   9
  10 It has these top-level messages:
  11 */
  12 package service
  13
  14 import proto "github.com/golang/protobuf/proto"
  15 import fmt "fmt"
  16 import math "math"
  17 import grpc_lb_v1 "google.golang.org/grpc/grpclb/grpc_lb_v1/messages"
  18
  19 import (
  20         context "golang.org/x/net/context"
  21         grpc "google.golang.org/grpc"
  22 )
  23
  24 // Reference imports to suppress errors if they are not otherwise used.
  25 var _ = proto.Marshal
  26 var _ = fmt.Errorf
  27 var _ = math.Inf
  28
  29 // This is a compile-time assertion to ensure that this generated file
  30 // is compatible with the proto package it is being compiled against.
  31 // A compilation error at this line likely means your copy of the
  32 // proto package needs to be updated.
  33 const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
  34
  35 // Reference imports to suppress errors if they are not otherwise used.
  36 var _ context.Context
  37 var _ grpc.ClientConn
  38
  39 // This is a compile-time assertion to ensure that this generated file
  40 // is compatible with the grpc package it is being compiled against.
  41 const _ = grpc.SupportPackageIsVersion4
  42
  43 // Client API for LoadBalancer service
  44
  45 type LoadBalancerClient interface {
  46         // Bidirectional rpc to get a list of servers.
  47         BalanceLoad(ctx context.Context, opts ...grpc.CallOption) (LoadBalancer_BalanceLoadClient, error)
  48 }
  49
  50 type loadBalancerClient struct {
  51         cc *grpc.ClientConn
  52 }
  53
  54 func NewLoadBalancerClient(cc *grpc.ClientConn) LoadBalancerClient {
  55         return &loadBalancerClient{cc}
  56 }
  57
  58 func (c *loadBalancerClient) BalanceLoad(ctx context.Context, opts ...grpc.CallOption) (LoadBalancer_BalanceLoadClient, error) {
  59         stream, err := grpc.NewClientStream(ctx, &_LoadBalancer_serviceDesc.Streams[0], c.cc, "/grpc.lb.v1.LoadBalancer/BalanceLoad", opts...)
  60         if err != nil {
  61                 return nil, err
  62         }
  63         x := &loadBalancerBalanceLoadClient{stream}
  64         return x, nil
  65 }
  66
  67 type LoadBalancer_BalanceLoadClient interface {
  68         Send(*grpc_lb_v1.LoadBalanceRequest) error
  69         Recv() (*grpc_lb_v1.LoadBalanceResponse, error)
  70         grpc.ClientStream
  71 }
  72
  73 type loadBalancerBalanceLoadClient struct {
  74         grpc.ClientStream
  75 }
  76
  77 func (x *loadBalancerBalanceLoadClient) Send(m *grpc_lb_v1.LoadBalanceRequest) error {
  78         return x.ClientStream.SendMsg(m)
  79 }
  80
  81 func (x *loadBalancerBalanceLoadClient) Recv() (*grpc_lb_v1.LoadBalanceResponse, error) {
  82         m := new(grpc_lb_v1.LoadBalanceResponse)
  83         if err := x.ClientStream.RecvMsg(m); err != nil {
  84                 return nil, err
  85         }
  86         return m, nil
  87 }
  88
  89 // Server API for LoadBalancer service
  90
  91 type LoadBalancerServer interface {
  92         // Bidirectional rpc to get a list of servers.
  93         BalanceLoad(LoadBalancer_BalanceLoadServer) error
  94 }
  95
  96 func RegisterLoadBalancerServer(s *grpc.Server, srv LoadBalancerServer) {
  97         s.RegisterService(&_LoadBalancer_serviceDesc, srv)
  98 }
  99
 100 func _LoadBalancer_BalanceLoad_Handler(srv interface{}, stream grpc.ServerStream) error {
 101         return srv.(LoadBalancerServer).BalanceLoad(&loadBalancerBalanceLoadServer{stream})
 102 }
 103
 104 type LoadBalancer_BalanceLoadServer interface {
 105         Send(*grpc_lb_v1.LoadBalanceResponse) error
 106         Recv() (*grpc_lb_v1.LoadBalanceRequest, error)
 107         grpc.ServerStream
 108 }
 109
 110 type loadBalancerBalanceLoadServer struct {
 111         grpc.ServerStream
 112 }
 113
 114 func (x *loadBalancerBalanceLoadServer) Send(m *grpc_lb_v1.LoadBalanceResponse) error {
 115         return x.ServerStream.SendMsg(m)
 116 }
 117
 118 func (x *loadBalancerBalanceLoadServer) Recv() (*grpc_lb_v1.LoadBalanceRequest, error) {
 119         m := new(grpc_lb_v1.LoadBalanceRequest)
 120         if err := x.ServerStream.RecvMsg(m); err != nil {
 121                 return nil, err
 122         }
 123         return m, nil
 124 }
 125
 126 var _LoadBalancer_serviceDesc = grpc.ServiceDesc{
 127         ServiceName: "grpc.lb.v1.LoadBalancer",
 128         HandlerType: (*LoadBalancerServer)(nil),
 129         Methods:     []grpc.MethodDesc{},
 130         Streams: []grpc.StreamDesc{
 131                 {
 132                         StreamName:    "BalanceLoad",
 133                         Handler:       _LoadBalancer_BalanceLoad_Handler,
 134                         ServerStreams: true,
 135                         ClientStreams: true,
 136                 },
 137         },
 138         Metadata: "grpc_lb_v1/service/service.proto",
 139 }
 140
 141 func init() { proto.RegisterFile("grpc_lb_v1/service/service.proto", fileDescriptor0) }
 142
 143 var fileDescriptor0 = []byte{
 144         // 142 bytes of a gzipped FileDescriptorProto
 145         0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0x52, 0x48, 0x2f, 0x2a, 0x48,
 146         0x8e, 0xcf, 0x49, 0x8a, 0x2f, 0x33, 0xd4, 0x2f, 0x4e, 0x2d, 0x2a, 0xcb, 0x4c, 0x4e, 0x85, 0xd1,
 147         0x7a, 0x05, 0x45, 0xf9, 0x25, 0xf9, 0x42, 0x5c, 0x20, 0x15, 0x7a, 0x39, 0x49, 0x7a, 0x65, 0x86,
 148         0x52, 0x4a, 0x48, 0xaa, 0x73, 0x53, 0x8b, 0x8b, 0x13, 0xd3, 0x53, 0x8b, 0xe1, 0x0c, 0x88, 0x7a,
 149         0xa3, 0x24, 0x2e, 0x1e, 0x9f, 0xfc, 0xc4, 0x14, 0xa7, 0xc4, 0x9c, 0xc4, 0xbc, 0xe4, 0xd4, 0x22,
 150         0xa1, 0x20, 0x2e, 0x6e, 0x28, 0x1b, 0x24, 0x2c, 0x24, 0xa7, 0x87, 0x30, 0x4f, 0x0f, 0x49, 0x61,
 151         0x50, 0x6a, 0x61, 0x69, 0x6a, 0x71, 0x89, 0x94, 0x3c, 0x4e, 0xf9, 0xe2, 0x82, 0xfc, 0xbc, 0xe2,
 152         0x54, 0x0d, 0x46, 0x03, 0x46, 0x27, 0xce, 0x28, 0x76, 0xa8, 0x23, 0x93, 0xd8, 0xc0, 0xb6, 0x1a,
 153         0x03, 0x02, 0x00, 0x00, 0xff, 0xff, 0x39, 0x4e, 0xb0, 0xf8, 0xc9, 0x00, 0x00, 0x00,
 154 }