diff options
Diffstat (limited to 'vendor/github.com/hashicorp/go-plugin/grpc_broker.pb.go')
-rw-r--r-- | vendor/github.com/hashicorp/go-plugin/grpc_broker.pb.go | 190 |
1 files changed, 190 insertions, 0 deletions
diff --git a/vendor/github.com/hashicorp/go-plugin/grpc_broker.pb.go b/vendor/github.com/hashicorp/go-plugin/grpc_broker.pb.go new file mode 100644 index 0000000..d490daf --- /dev/null +++ b/vendor/github.com/hashicorp/go-plugin/grpc_broker.pb.go | |||
@@ -0,0 +1,190 @@ | |||
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 | } | ||