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

   1 // Code generated by protoc-gen-go. DO NOT EDIT.
   2 // source: grpc_broker.proto
   3
   4 package plugin
   5
   6 import (
   7         fmt "fmt"
   8         proto "github.com/golang/protobuf/proto"
   9         context "golang.org/x/net/context"
  10         grpc "google.golang.org/grpc"
  11         math "math"
  12 )
  13
  14 // Reference imports to suppress errors if they are not otherwise used.
  15 var _ = proto.Marshal
  16 var _ = fmt.Errorf
  17 var _ = math.Inf
  18
  19 // This is a compile-time assertion to ensure that this generated file
  20 // is compatible with the proto package it is being compiled against.
  21 // A compilation error at this line likely means your copy of the
  22 // proto package needs to be updated.
  23 const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
  24
  25 type ConnInfo struct {
  26         ServiceId            uint32   `protobuf:"varint,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
  27         Network              string   `protobuf:"bytes,2,opt,name=network,proto3" json:"network,omitempty"`
  28         Address              string   `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
  29         XXX_NoUnkeyedLiteral struct{} `json:"-"`
  30         XXX_unrecognized     []byte   `json:"-"`
  31         XXX_sizecache        int32    `json:"-"`
  32 }
  33
  34 func (m *ConnInfo) Reset()         { *m = ConnInfo{} }
  35 func (m *ConnInfo) String() string { return proto.CompactTextString(m) }
  36 func (*ConnInfo) ProtoMessage()    {}
  37 func (*ConnInfo) Descriptor() ([]byte, []int) {
  38         return fileDescriptor_802e9beed3ec3b28, []int{0}
  39 }
  40
  41 func (m *ConnInfo) XXX_Unmarshal(b []byte) error {
  42         return xxx_messageInfo_ConnInfo.Unmarshal(m, b)
  43 }
  44 func (m *ConnInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  45         return xxx_messageInfo_ConnInfo.Marshal(b, m, deterministic)
  46 }
  47 func (m *ConnInfo) XXX_Merge(src proto.Message) {
  48         xxx_messageInfo_ConnInfo.Merge(m, src)
  49 }
  50 func (m *ConnInfo) XXX_Size() int {
  51         return xxx_messageInfo_ConnInfo.Size(m)
  52 }
  53 func (m *ConnInfo) XXX_DiscardUnknown() {
  54         xxx_messageInfo_ConnInfo.DiscardUnknown(m)
  55 }
  56
  57 var xxx_messageInfo_ConnInfo proto.InternalMessageInfo
  58
  59 func (m *ConnInfo) GetServiceId() uint32 {
  60         if m != nil {
  61                 return m.ServiceId
  62         }
  63         return 0
  64 }
  65
  66 func (m *ConnInfo) GetNetwork() string {
  67         if m != nil {
  68                 return m.Network
  69         }
  70         return ""
  71 }
  72
  73 func (m *ConnInfo) GetAddress() string {
  74         if m != nil {
  75                 return m.Address
  76         }
  77         return ""
  78 }
  79
  80 func init() {
  81         proto.RegisterType((*ConnInfo)(nil), "plugin.ConnInfo")
  82 }
  83
  84 func init() { proto.RegisterFile("grpc_broker.proto", fileDescriptor_802e9beed3ec3b28) }
  85
  86 var fileDescriptor_802e9beed3ec3b28 = []byte{
  87         // 175 bytes of a gzipped FileDescriptorProto
  88         0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0x12, 0x4c, 0x2f, 0x2a, 0x48,
  89         0x8e, 0x4f, 0x2a, 0xca, 0xcf, 0x4e, 0x2d, 0xd2, 0x2b, 0x28, 0xca, 0x2f, 0xc9, 0x17, 0x62, 0x2b,
  90         0xc8, 0x29, 0x4d, 0xcf, 0xcc, 0x53, 0x8a, 0xe5, 0xe2, 0x70, 0xce, 0xcf, 0xcb, 0xf3, 0xcc, 0x4b,
  91         0xcb, 0x17, 0x92, 0xe5, 0xe2, 0x2a, 0x4e, 0x2d, 0x2a, 0xcb, 0x4c, 0x4e, 0x8d, 0xcf, 0x4c, 0x91,
  92         0x60, 0x54, 0x60, 0xd4, 0xe0, 0x0d, 0xe2, 0x84, 0x8a, 0x78, 0xa6, 0x08, 0x49, 0x70, 0xb1, 0xe7,
  93         0xa5, 0x96, 0x94, 0xe7, 0x17, 0x65, 0x4b, 0x30, 0x29, 0x30, 0x6a, 0x70, 0x06, 0xc1, 0xb8, 0x20,
  94         0x99, 0xc4, 0x94, 0x94, 0xa2, 0xd4, 0xe2, 0x62, 0x09, 0x66, 0x88, 0x0c, 0x94, 0x6b, 0xe4, 0xcc,
  95         0xc5, 0xe5, 0x1e, 0x14, 0xe0, 0xec, 0x04, 0xb6, 0x5a, 0xc8, 0x94, 0x8b, 0x3b, 0xb8, 0x24, 0xb1,
  96         0xa8, 0x24, 0xb8, 0xa4, 0x28, 0x35, 0x31, 0x57, 0x48, 0x40, 0x0f, 0xe2, 0x08, 0x3d, 0x98, 0x0b,
  97         0xa4, 0x30, 0x44, 0x34, 0x18, 0x0d, 0x18, 0x9d, 0x38, 0xa2, 0xa0, 0xae, 0x4d, 0x62, 0x03, 0x3b,
  98         0xde, 0x18, 0x10, 0x00, 0x00, 0xff, 0xff, 0x10, 0x15, 0x39, 0x47, 0xd1, 0x00, 0x00, 0x00,
  99 }
 100
 101 // Reference imports to suppress errors if they are not otherwise used.
 102 var _ context.Context
 103 var _ grpc.ClientConn
 104
 105 // This is a compile-time assertion to ensure that this generated file
 106 // is compatible with the grpc package it is being compiled against.
 107 const _ = grpc.SupportPackageIsVersion4
 108
 109 // GRPCBrokerClient is the client API for GRPCBroker service.
 110 //
 111 // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
 112 type GRPCBrokerClient interface {
 113         StartStream(ctx context.Context, opts ...grpc.CallOption) (GRPCBroker_StartStreamClient, error)
 114 }
 115
 116 type gRPCBrokerClient struct {
 117         cc *grpc.ClientConn
 118 }
 119
 120 func NewGRPCBrokerClient(cc *grpc.ClientConn) GRPCBrokerClient {
 121         return &gRPCBrokerClient{cc}
 122 }
 123
 124 func (c *gRPCBrokerClient) StartStream(ctx context.Context, opts ...grpc.CallOption) (GRPCBroker_StartStreamClient, error) {
 125         stream, err := c.cc.NewStream(ctx, &_GRPCBroker_serviceDesc.Streams[0], "/plugin.GRPCBroker/StartStream", opts...)
 126         if err != nil {
 127                 return nil, err
 128         }
 129         x := &gRPCBrokerStartStreamClient{stream}
 130         return x, nil
 131 }
 132
 133 type GRPCBroker_StartStreamClient interface {
 134         Send(*ConnInfo) error
 135         Recv() (*ConnInfo, error)
 136         grpc.ClientStream
 137 }
 138
 139 type gRPCBrokerStartStreamClient struct {
 140         grpc.ClientStream
 141 }
 142
 143 func (x *gRPCBrokerStartStreamClient) Send(m *ConnInfo) error {
 144         return x.ClientStream.SendMsg(m)
 145 }
 146
 147 func (x *gRPCBrokerStartStreamClient) Recv() (*ConnInfo, error) {
 148         m := new(ConnInfo)
 149         if err := x.ClientStream.RecvMsg(m); err != nil {
 150                 return nil, err
 151         }
 152         return m, nil
 153 }
 154
 155 // GRPCBrokerServer is the server API for GRPCBroker service.
 156 type GRPCBrokerServer interface {
 157         StartStream(GRPCBroker_StartStreamServer) error
 158 }
 159
 160 func RegisterGRPCBrokerServer(s *grpc.Server, srv GRPCBrokerServer) {
 161         s.RegisterService(&_GRPCBroker_serviceDesc, srv)
 162 }
 163
 164 func _GRPCBroker_StartStream_Handler(srv interface{}, stream grpc.ServerStream) error {
 165         return srv.(GRPCBrokerServer).StartStream(&gRPCBrokerStartStreamServer{stream})
 166 }
 167
 168 type GRPCBroker_StartStreamServer interface {
 169         Send(*ConnInfo) error
 170         Recv() (*ConnInfo, error)
 171         grpc.ServerStream
 172 }
 173
 174 type gRPCBrokerStartStreamServer struct {
 175         grpc.ServerStream
 176 }
 177
 178 func (x *gRPCBrokerStartStreamServer) Send(m *ConnInfo) error {
 179         return x.ServerStream.SendMsg(m)
 180 }
 181
 182 func (x *gRPCBrokerStartStreamServer) Recv() (*ConnInfo, error) {
 183         m := new(ConnInfo)
 184         if err := x.ServerStream.RecvMsg(m); err != nil {
 185                 return nil, err
 186         }
 187         return m, nil
 188 }
 189
 190 var _GRPCBroker_serviceDesc = grpc.ServiceDesc{
 191         ServiceName: "plugin.GRPCBroker",
 192         HandlerType: (*GRPCBrokerServer)(nil),
 193         Methods:     []grpc.MethodDesc{},
 194         Streams: []grpc.StreamDesc{
 195                 {
 196                         StreamName:    "StartStream",
 197                         Handler:       _GRPCBroker_StartStream_Handler,
 198                         ServerStreams: true,
 199                         ClientStreams: true,
 200                 },
 201         },
 202         Metadata: "grpc_broker.proto",
 203 }