vendor/github.com/hashicorp/go-plugin/grpc_broker.pb.go

   1 // Code generated by protoc-gen-go. DO NOT EDIT.
   2 // source: grpc_broker.proto
   3
   4 /*
   5 Package plugin is a generated protocol buffer package.
   6
   7 It is generated from these files:
   8         grpc_broker.proto
   9
  10 It has these top-level messages:
  11         ConnInfo
  12 */
  13 package plugin
  14
  15 import proto "github.com/golang/protobuf/proto"
  16 import fmt "fmt"
  17 import math "math"
  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 type ConnInfo struct {
  36         ServiceId uint32 `protobuf:"varint,1,opt,name=service_id,json=serviceId" json:"service_id,omitempty"`
  37         Network   string `protobuf:"bytes,2,opt,name=network" json:"network,omitempty"`
  38         Address   string `protobuf:"bytes,3,opt,name=address" json:"address,omitempty"`
  39 }
  40
  41 func (m *ConnInfo) Reset()                    { *m = ConnInfo{} }
  42 func (m *ConnInfo) String() string            { return proto.CompactTextString(m) }
  43 func (*ConnInfo) ProtoMessage()               {}
  44 func (*ConnInfo) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0} }
  45
  46 func (m *ConnInfo) GetServiceId() uint32 {
  47         if m != nil {
  48                 return m.ServiceId
  49         }
  50         return 0
  51 }
  52
  53 func (m *ConnInfo) GetNetwork() string {
  54         if m != nil {
  55                 return m.Network
  56         }
  57         return ""
  58 }
  59
  60 func (m *ConnInfo) GetAddress() string {
  61         if m != nil {
  62                 return m.Address
  63         }
  64         return ""
  65 }
  66
  67 func init() {
  68         proto.RegisterType((*ConnInfo)(nil), "plugin.ConnInfo")
  69 }
  70
  71 // Reference imports to suppress errors if they are not otherwise used.
  72 var _ context.Context
  73 var _ grpc.ClientConn
  74
  75 // This is a compile-time assertion to ensure that this generated file
  76 // is compatible with the grpc package it is being compiled against.
  77 const _ = grpc.SupportPackageIsVersion4
  78
  79 // Client API for GRPCBroker service
  80
  81 type GRPCBrokerClient interface {
  82         StartStream(ctx context.Context, opts ...grpc.CallOption) (GRPCBroker_StartStreamClient, error)
  83 }
  84
  85 type gRPCBrokerClient struct {
  86         cc *grpc.ClientConn
  87 }
  88
  89 func NewGRPCBrokerClient(cc *grpc.ClientConn) GRPCBrokerClient {
  90         return &gRPCBrokerClient{cc}
  91 }
  92
  93 func (c *gRPCBrokerClient) StartStream(ctx context.Context, opts ...grpc.CallOption) (GRPCBroker_StartStreamClient, error) {
  94         stream, err := grpc.NewClientStream(ctx, &_GRPCBroker_serviceDesc.Streams[0], c.cc, "/plugin.GRPCBroker/StartStream", opts...)
  95         if err != nil {
  96                 return nil, err
  97         }
  98         x := &gRPCBrokerStartStreamClient{stream}
  99         return x, nil
 100 }
 101
 102 type GRPCBroker_StartStreamClient interface {
 103         Send(*ConnInfo) error
 104         Recv() (*ConnInfo, error)
 105         grpc.ClientStream
 106 }
 107
 108 type gRPCBrokerStartStreamClient struct {
 109         grpc.ClientStream
 110 }
 111
 112 func (x *gRPCBrokerStartStreamClient) Send(m *ConnInfo) error {
 113         return x.ClientStream.SendMsg(m)
 114 }
 115
 116 func (x *gRPCBrokerStartStreamClient) Recv() (*ConnInfo, error) {
 117         m := new(ConnInfo)
 118         if err := x.ClientStream.RecvMsg(m); err != nil {
 119                 return nil, err
 120         }
 121         return m, nil
 122 }
 123
 124 // Server API for GRPCBroker service
 125
 126 type GRPCBrokerServer interface {
 127         StartStream(GRPCBroker_StartStreamServer) error
 128 }
 129
 130 func RegisterGRPCBrokerServer(s *grpc.Server, srv GRPCBrokerServer) {
 131         s.RegisterService(&_GRPCBroker_serviceDesc, srv)
 132 }
 133
 134 func _GRPCBroker_StartStream_Handler(srv interface{}, stream grpc.ServerStream) error {
 135         return srv.(GRPCBrokerServer).StartStream(&gRPCBrokerStartStreamServer{stream})
 136 }
 137
 138 type GRPCBroker_StartStreamServer interface {
 139         Send(*ConnInfo) error
 140         Recv() (*ConnInfo, error)
 141         grpc.ServerStream
 142 }
 143
 144 type gRPCBrokerStartStreamServer struct {
 145         grpc.ServerStream
 146 }
 147
 148 func (x *gRPCBrokerStartStreamServer) Send(m *ConnInfo) error {
 149         return x.ServerStream.SendMsg(m)
 150 }
 151
 152 func (x *gRPCBrokerStartStreamServer) Recv() (*ConnInfo, error) {
 153         m := new(ConnInfo)
 154         if err := x.ServerStream.RecvMsg(m); err != nil {
 155                 return nil, err
 156         }
 157         return m, nil
 158 }
 159
 160 var _GRPCBroker_serviceDesc = grpc.ServiceDesc{
 161         ServiceName: "plugin.GRPCBroker",
 162         HandlerType: (*GRPCBrokerServer)(nil),
 163         Methods:     []grpc.MethodDesc{},
 164         Streams: []grpc.StreamDesc{
 165                 {
 166                         StreamName:    "StartStream",
 167                         Handler:       _GRPCBroker_StartStream_Handler,
 168                         ServerStreams: true,
 169                         ClientStreams: true,
 170                 },
 171         },
 172         Metadata: "grpc_broker.proto",
 173 }
 174
 175 func init() { proto.RegisterFile("grpc_broker.proto", fileDescriptor0) }
 176
 177 var fileDescriptor0 = []byte{
 178         // 170 bytes of a gzipped FileDescriptorProto
 179         0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0x12, 0x4c, 0x2f, 0x2a, 0x48,
 180         0x8e, 0x4f, 0x2a, 0xca, 0xcf, 0x4e, 0x2d, 0xd2, 0x2b, 0x28, 0xca, 0x2f, 0xc9, 0x17, 0x62, 0x2b,
 181         0xc8, 0x29, 0x4d, 0xcf, 0xcc, 0x53, 0x8a, 0xe5, 0xe2, 0x70, 0xce, 0xcf, 0xcb, 0xf3, 0xcc, 0x4b,
 182         0xcb, 0x17, 0x92, 0xe5, 0xe2, 0x2a, 0x4e, 0x2d, 0x2a, 0xcb, 0x4c, 0x4e, 0x8d, 0xcf, 0x4c, 0x91,
 183         0x60, 0x54, 0x60, 0xd4, 0xe0, 0x0d, 0xe2, 0x84, 0x8a, 0x78, 0xa6, 0x08, 0x49, 0x70, 0xb1, 0xe7,
 184         0xa5, 0x96, 0x94, 0xe7, 0x17, 0x65, 0x4b, 0x30, 0x29, 0x30, 0x6a, 0x70, 0x06, 0xc1, 0xb8, 0x20,
 185         0x99, 0xc4, 0x94, 0x94, 0xa2, 0xd4, 0xe2, 0x62, 0x09, 0x66, 0x88, 0x0c, 0x94, 0x6b, 0xe4, 0xcc,
 186         0xc5, 0xe5, 0x1e, 0x14, 0xe0, 0xec, 0x04, 0xb6, 0x5a, 0xc8, 0x94, 0x8b, 0x3b, 0xb8, 0x24, 0xb1,
 187         0xa8, 0x24, 0xb8, 0xa4, 0x28, 0x35, 0x31, 0x57, 0x48, 0x40, 0x0f, 0xe2, 0x08, 0x3d, 0x98, 0x0b,
 188         0xa4, 0x30, 0x44, 0x34, 0x18, 0x0d, 0x18, 0x93, 0xd8, 0xc0, 0x4e, 0x36, 0x06, 0x04, 0x00, 0x00,
 189         0xff, 0xff, 0x7b, 0x5d, 0xfb, 0xe1, 0xc7, 0x00, 0x00, 0x00,
 190 }