1// Code generated by protoc-gen-go. DO NOT EDIT.
2// source: envoy/service/accesslog/v2/als.proto
3
4package envoy_service_accesslog_v2
5
6import (
7	context "context"
8	fmt "fmt"
9	_ "github.com/cncf/udpa/go/udpa/annotations"
10	core "github.com/envoyproxy/go-control-plane/envoy/api/v2/core"
11	v2 "github.com/envoyproxy/go-control-plane/envoy/data/accesslog/v2"
12	_ "github.com/envoyproxy/protoc-gen-validate/validate"
13	proto "github.com/golang/protobuf/proto"
14	grpc "google.golang.org/grpc"
15	codes "google.golang.org/grpc/codes"
16	status "google.golang.org/grpc/status"
17	math "math"
18)
19
20// Reference imports to suppress errors if they are not otherwise used.
21var _ = proto.Marshal
22var _ = fmt.Errorf
23var _ = math.Inf
24
25// This is a compile-time assertion to ensure that this generated file
26// is compatible with the proto package it is being compiled against.
27// A compilation error at this line likely means your copy of the
28// proto package needs to be updated.
29const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
30
31type StreamAccessLogsResponse struct {
32	XXX_NoUnkeyedLiteral struct{} `json:"-"`
33	XXX_unrecognized     []byte   `json:"-"`
34	XXX_sizecache        int32    `json:"-"`
35}
36
37func (m *StreamAccessLogsResponse) Reset()         { *m = StreamAccessLogsResponse{} }
38func (m *StreamAccessLogsResponse) String() string { return proto.CompactTextString(m) }
39func (*StreamAccessLogsResponse) ProtoMessage()    {}
40func (*StreamAccessLogsResponse) Descriptor() ([]byte, []int) {
41	return fileDescriptor_e4f3a3a69261b513, []int{0}
42}
43
44func (m *StreamAccessLogsResponse) XXX_Unmarshal(b []byte) error {
45	return xxx_messageInfo_StreamAccessLogsResponse.Unmarshal(m, b)
46}
47func (m *StreamAccessLogsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
48	return xxx_messageInfo_StreamAccessLogsResponse.Marshal(b, m, deterministic)
49}
50func (m *StreamAccessLogsResponse) XXX_Merge(src proto.Message) {
51	xxx_messageInfo_StreamAccessLogsResponse.Merge(m, src)
52}
53func (m *StreamAccessLogsResponse) XXX_Size() int {
54	return xxx_messageInfo_StreamAccessLogsResponse.Size(m)
55}
56func (m *StreamAccessLogsResponse) XXX_DiscardUnknown() {
57	xxx_messageInfo_StreamAccessLogsResponse.DiscardUnknown(m)
58}
59
60var xxx_messageInfo_StreamAccessLogsResponse proto.InternalMessageInfo
61
62type StreamAccessLogsMessage struct {
63	Identifier *StreamAccessLogsMessage_Identifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
64	// Types that are valid to be assigned to LogEntries:
65	//	*StreamAccessLogsMessage_HttpLogs
66	//	*StreamAccessLogsMessage_TcpLogs
67	LogEntries           isStreamAccessLogsMessage_LogEntries `protobuf_oneof:"log_entries"`
68	XXX_NoUnkeyedLiteral struct{}                             `json:"-"`
69	XXX_unrecognized     []byte                               `json:"-"`
70	XXX_sizecache        int32                                `json:"-"`
71}
72
73func (m *StreamAccessLogsMessage) Reset()         { *m = StreamAccessLogsMessage{} }
74func (m *StreamAccessLogsMessage) String() string { return proto.CompactTextString(m) }
75func (*StreamAccessLogsMessage) ProtoMessage()    {}
76func (*StreamAccessLogsMessage) Descriptor() ([]byte, []int) {
77	return fileDescriptor_e4f3a3a69261b513, []int{1}
78}
79
80func (m *StreamAccessLogsMessage) XXX_Unmarshal(b []byte) error {
81	return xxx_messageInfo_StreamAccessLogsMessage.Unmarshal(m, b)
82}
83func (m *StreamAccessLogsMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
84	return xxx_messageInfo_StreamAccessLogsMessage.Marshal(b, m, deterministic)
85}
86func (m *StreamAccessLogsMessage) XXX_Merge(src proto.Message) {
87	xxx_messageInfo_StreamAccessLogsMessage.Merge(m, src)
88}
89func (m *StreamAccessLogsMessage) XXX_Size() int {
90	return xxx_messageInfo_StreamAccessLogsMessage.Size(m)
91}
92func (m *StreamAccessLogsMessage) XXX_DiscardUnknown() {
93	xxx_messageInfo_StreamAccessLogsMessage.DiscardUnknown(m)
94}
95
96var xxx_messageInfo_StreamAccessLogsMessage proto.InternalMessageInfo
97
98func (m *StreamAccessLogsMessage) GetIdentifier() *StreamAccessLogsMessage_Identifier {
99	if m != nil {
100		return m.Identifier
101	}
102	return nil
103}
104
105type isStreamAccessLogsMessage_LogEntries interface {
106	isStreamAccessLogsMessage_LogEntries()
107}
108
109type StreamAccessLogsMessage_HttpLogs struct {
110	HttpLogs *StreamAccessLogsMessage_HTTPAccessLogEntries `protobuf:"bytes,2,opt,name=http_logs,json=httpLogs,proto3,oneof"`
111}
112
113type StreamAccessLogsMessage_TcpLogs struct {
114	TcpLogs *StreamAccessLogsMessage_TCPAccessLogEntries `protobuf:"bytes,3,opt,name=tcp_logs,json=tcpLogs,proto3,oneof"`
115}
116
117func (*StreamAccessLogsMessage_HttpLogs) isStreamAccessLogsMessage_LogEntries() {}
118
119func (*StreamAccessLogsMessage_TcpLogs) isStreamAccessLogsMessage_LogEntries() {}
120
121func (m *StreamAccessLogsMessage) GetLogEntries() isStreamAccessLogsMessage_LogEntries {
122	if m != nil {
123		return m.LogEntries
124	}
125	return nil
126}
127
128func (m *StreamAccessLogsMessage) GetHttpLogs() *StreamAccessLogsMessage_HTTPAccessLogEntries {
129	if x, ok := m.GetLogEntries().(*StreamAccessLogsMessage_HttpLogs); ok {
130		return x.HttpLogs
131	}
132	return nil
133}
134
135func (m *StreamAccessLogsMessage) GetTcpLogs() *StreamAccessLogsMessage_TCPAccessLogEntries {
136	if x, ok := m.GetLogEntries().(*StreamAccessLogsMessage_TcpLogs); ok {
137		return x.TcpLogs
138	}
139	return nil
140}
141
142// XXX_OneofWrappers is for the internal use of the proto package.
143func (*StreamAccessLogsMessage) XXX_OneofWrappers() []interface{} {
144	return []interface{}{
145		(*StreamAccessLogsMessage_HttpLogs)(nil),
146		(*StreamAccessLogsMessage_TcpLogs)(nil),
147	}
148}
149
150type StreamAccessLogsMessage_Identifier struct {
151	Node                 *core.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
152	LogName              string     `protobuf:"bytes,2,opt,name=log_name,json=logName,proto3" json:"log_name,omitempty"`
153	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
154	XXX_unrecognized     []byte     `json:"-"`
155	XXX_sizecache        int32      `json:"-"`
156}
157
158func (m *StreamAccessLogsMessage_Identifier) Reset()         { *m = StreamAccessLogsMessage_Identifier{} }
159func (m *StreamAccessLogsMessage_Identifier) String() string { return proto.CompactTextString(m) }
160func (*StreamAccessLogsMessage_Identifier) ProtoMessage()    {}
161func (*StreamAccessLogsMessage_Identifier) Descriptor() ([]byte, []int) {
162	return fileDescriptor_e4f3a3a69261b513, []int{1, 0}
163}
164
165func (m *StreamAccessLogsMessage_Identifier) XXX_Unmarshal(b []byte) error {
166	return xxx_messageInfo_StreamAccessLogsMessage_Identifier.Unmarshal(m, b)
167}
168func (m *StreamAccessLogsMessage_Identifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
169	return xxx_messageInfo_StreamAccessLogsMessage_Identifier.Marshal(b, m, deterministic)
170}
171func (m *StreamAccessLogsMessage_Identifier) XXX_Merge(src proto.Message) {
172	xxx_messageInfo_StreamAccessLogsMessage_Identifier.Merge(m, src)
173}
174func (m *StreamAccessLogsMessage_Identifier) XXX_Size() int {
175	return xxx_messageInfo_StreamAccessLogsMessage_Identifier.Size(m)
176}
177func (m *StreamAccessLogsMessage_Identifier) XXX_DiscardUnknown() {
178	xxx_messageInfo_StreamAccessLogsMessage_Identifier.DiscardUnknown(m)
179}
180
181var xxx_messageInfo_StreamAccessLogsMessage_Identifier proto.InternalMessageInfo
182
183func (m *StreamAccessLogsMessage_Identifier) GetNode() *core.Node {
184	if m != nil {
185		return m.Node
186	}
187	return nil
188}
189
190func (m *StreamAccessLogsMessage_Identifier) GetLogName() string {
191	if m != nil {
192		return m.LogName
193	}
194	return ""
195}
196
197type StreamAccessLogsMessage_HTTPAccessLogEntries struct {
198	LogEntry             []*v2.HTTPAccessLogEntry `protobuf:"bytes,1,rep,name=log_entry,json=logEntry,proto3" json:"log_entry,omitempty"`
199	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
200	XXX_unrecognized     []byte                   `json:"-"`
201	XXX_sizecache        int32                    `json:"-"`
202}
203
204func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) Reset() {
205	*m = StreamAccessLogsMessage_HTTPAccessLogEntries{}
206}
207func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) String() string {
208	return proto.CompactTextString(m)
209}
210func (*StreamAccessLogsMessage_HTTPAccessLogEntries) ProtoMessage() {}
211func (*StreamAccessLogsMessage_HTTPAccessLogEntries) Descriptor() ([]byte, []int) {
212	return fileDescriptor_e4f3a3a69261b513, []int{1, 1}
213}
214
215func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) XXX_Unmarshal(b []byte) error {
216	return xxx_messageInfo_StreamAccessLogsMessage_HTTPAccessLogEntries.Unmarshal(m, b)
217}
218func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
219	return xxx_messageInfo_StreamAccessLogsMessage_HTTPAccessLogEntries.Marshal(b, m, deterministic)
220}
221func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) XXX_Merge(src proto.Message) {
222	xxx_messageInfo_StreamAccessLogsMessage_HTTPAccessLogEntries.Merge(m, src)
223}
224func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) XXX_Size() int {
225	return xxx_messageInfo_StreamAccessLogsMessage_HTTPAccessLogEntries.Size(m)
226}
227func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) XXX_DiscardUnknown() {
228	xxx_messageInfo_StreamAccessLogsMessage_HTTPAccessLogEntries.DiscardUnknown(m)
229}
230
231var xxx_messageInfo_StreamAccessLogsMessage_HTTPAccessLogEntries proto.InternalMessageInfo
232
233func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) GetLogEntry() []*v2.HTTPAccessLogEntry {
234	if m != nil {
235		return m.LogEntry
236	}
237	return nil
238}
239
240type StreamAccessLogsMessage_TCPAccessLogEntries struct {
241	LogEntry             []*v2.TCPAccessLogEntry `protobuf:"bytes,1,rep,name=log_entry,json=logEntry,proto3" json:"log_entry,omitempty"`
242	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
243	XXX_unrecognized     []byte                  `json:"-"`
244	XXX_sizecache        int32                   `json:"-"`
245}
246
247func (m *StreamAccessLogsMessage_TCPAccessLogEntries) Reset() {
248	*m = StreamAccessLogsMessage_TCPAccessLogEntries{}
249}
250func (m *StreamAccessLogsMessage_TCPAccessLogEntries) String() string {
251	return proto.CompactTextString(m)
252}
253func (*StreamAccessLogsMessage_TCPAccessLogEntries) ProtoMessage() {}
254func (*StreamAccessLogsMessage_TCPAccessLogEntries) Descriptor() ([]byte, []int) {
255	return fileDescriptor_e4f3a3a69261b513, []int{1, 2}
256}
257
258func (m *StreamAccessLogsMessage_TCPAccessLogEntries) XXX_Unmarshal(b []byte) error {
259	return xxx_messageInfo_StreamAccessLogsMessage_TCPAccessLogEntries.Unmarshal(m, b)
260}
261func (m *StreamAccessLogsMessage_TCPAccessLogEntries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
262	return xxx_messageInfo_StreamAccessLogsMessage_TCPAccessLogEntries.Marshal(b, m, deterministic)
263}
264func (m *StreamAccessLogsMessage_TCPAccessLogEntries) XXX_Merge(src proto.Message) {
265	xxx_messageInfo_StreamAccessLogsMessage_TCPAccessLogEntries.Merge(m, src)
266}
267func (m *StreamAccessLogsMessage_TCPAccessLogEntries) XXX_Size() int {
268	return xxx_messageInfo_StreamAccessLogsMessage_TCPAccessLogEntries.Size(m)
269}
270func (m *StreamAccessLogsMessage_TCPAccessLogEntries) XXX_DiscardUnknown() {
271	xxx_messageInfo_StreamAccessLogsMessage_TCPAccessLogEntries.DiscardUnknown(m)
272}
273
274var xxx_messageInfo_StreamAccessLogsMessage_TCPAccessLogEntries proto.InternalMessageInfo
275
276func (m *StreamAccessLogsMessage_TCPAccessLogEntries) GetLogEntry() []*v2.TCPAccessLogEntry {
277	if m != nil {
278		return m.LogEntry
279	}
280	return nil
281}
282
283func init() {
284	proto.RegisterType((*StreamAccessLogsResponse)(nil), "envoy.service.accesslog.v2.StreamAccessLogsResponse")
285	proto.RegisterType((*StreamAccessLogsMessage)(nil), "envoy.service.accesslog.v2.StreamAccessLogsMessage")
286	proto.RegisterType((*StreamAccessLogsMessage_Identifier)(nil), "envoy.service.accesslog.v2.StreamAccessLogsMessage.Identifier")
287	proto.RegisterType((*StreamAccessLogsMessage_HTTPAccessLogEntries)(nil), "envoy.service.accesslog.v2.StreamAccessLogsMessage.HTTPAccessLogEntries")
288	proto.RegisterType((*StreamAccessLogsMessage_TCPAccessLogEntries)(nil), "envoy.service.accesslog.v2.StreamAccessLogsMessage.TCPAccessLogEntries")
289}
290
291func init() {
292	proto.RegisterFile("envoy/service/accesslog/v2/als.proto", fileDescriptor_e4f3a3a69261b513)
293}
294
295var fileDescriptor_e4f3a3a69261b513 = []byte{
296	// 493 bytes of a gzipped FileDescriptorProto
297	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x93, 0x41, 0x8b, 0xd3, 0x40,
298	0x14, 0xc7, 0x77, 0xda, 0xdd, 0x6d, 0xfa, 0x7a, 0x29, 0xa3, 0xd0, 0x12, 0x14, 0x4a, 0x11, 0x2c,
299	0x0a, 0x09, 0x64, 0xf5, 0x2a, 0x34, 0x22, 0x56, 0xd0, 0xa5, 0x66, 0x7b, 0x76, 0x99, 0x4d, 0x9e,
300	0xd9, 0x91, 0x74, 0x26, 0x64, 0x66, 0x83, 0xbd, 0xe9, 0x4d, 0x3c, 0x7a, 0xf0, 0xe2, 0x37, 0xf1,
301	0x13, 0x78, 0xf5, 0xdb, 0xc8, 0x9e, 0x64, 0x26, 0xd9, 0xa8, 0xdd, 0x56, 0xd8, 0xde, 0x42, 0xe6,
302	0xff, 0x7e, 0xbf, 0x79, 0x33, 0xf3, 0xe0, 0x1e, 0x8a, 0x52, 0xae, 0x7c, 0x85, 0x45, 0xc9, 0x63,
303	0xf4, 0x59, 0x1c, 0xa3, 0x52, 0x99, 0x4c, 0xfd, 0x32, 0xf0, 0x59, 0xa6, 0xbc, 0xbc, 0x90, 0x5a,
304	0x52, 0xd7, 0xa6, 0xbc, 0x3a, 0xe5, 0x35, 0x29, 0xaf, 0x0c, 0xdc, 0x3b, 0x15, 0x81, 0xe5, 0xdc,
305	0xd4, 0xc4, 0xb2, 0x40, 0xff, 0x8c, 0x29, 0xac, 0x2a, 0xdd, 0xfb, 0xd5, 0x6a, 0xc2, 0x34, 0x5b,
306	0x83, 0x37, 0x8c, 0x2a, 0x78, 0xf7, 0x22, 0xc9, 0x99, 0xcf, 0x84, 0x90, 0x9a, 0x69, 0x2e, 0x85,
307	0xf2, 0x95, 0x66, 0xfa, 0xa2, 0xde, 0x81, 0x3b, 0x28, 0x59, 0xc6, 0x13, 0xa6, 0xd1, 0xbf, 0xfa,
308	0xa8, 0x16, 0xc6, 0x2e, 0x0c, 0x4f, 0x74, 0x81, 0x6c, 0x39, 0xb5, 0xc0, 0x97, 0x32, 0x55, 0x11,
309	0xaa, 0x5c, 0x0a, 0x85, 0xe3, 0x6f, 0x07, 0x30, 0x58, 0x5f, 0x7c, 0x85, 0x4a, 0xb1, 0x14, 0xe9,
310	0x1b, 0x00, 0x9e, 0xa0, 0xd0, 0xfc, 0x2d, 0xc7, 0x62, 0x48, 0x46, 0x64, 0xd2, 0x0b, 0x9e, 0x78,
311	0xdb, 0xfb, 0xf4, 0xb6, 0x80, 0xbc, 0x17, 0x0d, 0x25, 0xfa, 0x8b, 0x48, 0x53, 0xe8, 0x9e, 0x6b,
312	0x9d, 0x9f, 0x66, 0x32, 0x55, 0xc3, 0x96, 0xc5, 0xcf, 0x76, 0xc1, 0xcf, 0x16, 0x8b, 0x79, 0xf3,
313	0xf7, 0x99, 0xd0, 0x05, 0x47, 0x35, 0xdb, 0x8b, 0x1c, 0x03, 0x37, 0x39, 0x9a, 0x80, 0xa3, 0xe3,
314	0xda, 0xd3, 0xb6, 0x9e, 0xe7, 0xbb, 0x78, 0x16, 0x4f, 0x37, 0x69, 0x3a, 0x3a, 0xb6, 0x16, 0x37,
315	0x05, 0xf8, 0xd3, 0x28, 0x7d, 0x0c, 0xfb, 0x42, 0x26, 0x58, 0x1f, 0xdb, 0xa0, 0xf6, 0xb1, 0x9c,
316	0x1b, 0x83, 0x79, 0x02, 0xde, 0xb1, 0x4c, 0x30, 0x74, 0x2e, 0xc3, 0x83, 0xcf, 0xa4, 0xd5, 0x27,
317	0x91, 0x8d, 0xd3, 0x31, 0x38, 0x99, 0x4c, 0x4f, 0x05, 0x5b, 0xa2, 0x3d, 0x92, 0x6e, 0xd8, 0xb9,
318	0x0c, 0xf7, 0x8b, 0xd6, 0x88, 0x44, 0x9d, 0x4c, 0xa6, 0xc7, 0x6c, 0x89, 0xee, 0x3b, 0xb8, 0xbd,
319	0xa9, 0x65, 0x1a, 0x41, 0xd7, 0xd4, 0xa2, 0xd0, 0xc5, 0x6a, 0x48, 0x46, 0xed, 0x49, 0x2f, 0x78,
320	0x58, 0x7b, 0xcd, 0xe3, 0xfa, 0xb7, 0xc9, 0x6b, 0x84, 0x95, 0xdd, 0xcb, 0x17, 0xd2, 0x72, 0x48,
321	0x64, 0xf6, 0x60, 0xff, 0xb9, 0xe7, 0x70, 0x6b, 0x43, 0xdb, 0xf4, 0xf5, 0x75, 0xd5, 0x83, 0xad,
322	0xaa, 0x75, 0xc0, 0x46, 0x53, 0x48, 0xa1, 0x77, 0x85, 0x34, 0x86, 0xf6, 0xaf, 0x90, 0x04, 0x5f,
323	0x09, 0xf4, 0x9b, 0xd2, 0x93, 0xea, 0xae, 0xe8, 0x47, 0x02, 0xfd, 0xf5, 0x2b, 0xa2, 0x47, 0x3b,
324	0x5c, 0xa8, 0xfb, 0xe8, 0x26, 0x45, 0xcd, 0xc8, 0xec, 0x4d, 0x48, 0x38, 0xfd, 0xfe, 0xe1, 0xc7,
325	0xcf, 0xc3, 0x56, 0x9f, 0xc0, 0x84, 0xcb, 0x8a, 0x92, 0x17, 0xf2, 0xfd, 0xea, 0x3f, 0xc0, 0xd0,
326	0x99, 0x66, 0x6a, 0x6e, 0x06, 0x72, 0x4e, 0x3e, 0x11, 0x72, 0x76, 0x68, 0x87, 0xf3, 0xe8, 0x77,
327	0x00, 0x00, 0x00, 0xff, 0xff, 0xe1, 0x3b, 0x59, 0x76, 0x5f, 0x04, 0x00, 0x00,
328}
329
330// Reference imports to suppress errors if they are not otherwise used.
331var _ context.Context
332var _ grpc.ClientConn
333
334// This is a compile-time assertion to ensure that this generated file
335// is compatible with the grpc package it is being compiled against.
336const _ = grpc.SupportPackageIsVersion4
337
338// AccessLogServiceClient is the client API for AccessLogService service.
339//
340// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
341type AccessLogServiceClient interface {
342	StreamAccessLogs(ctx context.Context, opts ...grpc.CallOption) (AccessLogService_StreamAccessLogsClient, error)
343}
344
345type accessLogServiceClient struct {
346	cc *grpc.ClientConn
347}
348
349func NewAccessLogServiceClient(cc *grpc.ClientConn) AccessLogServiceClient {
350	return &accessLogServiceClient{cc}
351}
352
353func (c *accessLogServiceClient) StreamAccessLogs(ctx context.Context, opts ...grpc.CallOption) (AccessLogService_StreamAccessLogsClient, error) {
354	stream, err := c.cc.NewStream(ctx, &_AccessLogService_serviceDesc.Streams[0], "/envoy.service.accesslog.v2.AccessLogService/StreamAccessLogs", opts...)
355	if err != nil {
356		return nil, err
357	}
358	x := &accessLogServiceStreamAccessLogsClient{stream}
359	return x, nil
360}
361
362type AccessLogService_StreamAccessLogsClient interface {
363	Send(*StreamAccessLogsMessage) error
364	CloseAndRecv() (*StreamAccessLogsResponse, error)
365	grpc.ClientStream
366}
367
368type accessLogServiceStreamAccessLogsClient struct {
369	grpc.ClientStream
370}
371
372func (x *accessLogServiceStreamAccessLogsClient) Send(m *StreamAccessLogsMessage) error {
373	return x.ClientStream.SendMsg(m)
374}
375
376func (x *accessLogServiceStreamAccessLogsClient) CloseAndRecv() (*StreamAccessLogsResponse, error) {
377	if err := x.ClientStream.CloseSend(); err != nil {
378		return nil, err
379	}
380	m := new(StreamAccessLogsResponse)
381	if err := x.ClientStream.RecvMsg(m); err != nil {
382		return nil, err
383	}
384	return m, nil
385}
386
387// AccessLogServiceServer is the server API for AccessLogService service.
388type AccessLogServiceServer interface {
389	StreamAccessLogs(AccessLogService_StreamAccessLogsServer) error
390}
391
392// UnimplementedAccessLogServiceServer can be embedded to have forward compatible implementations.
393type UnimplementedAccessLogServiceServer struct {
394}
395
396func (*UnimplementedAccessLogServiceServer) StreamAccessLogs(srv AccessLogService_StreamAccessLogsServer) error {
397	return status.Errorf(codes.Unimplemented, "method StreamAccessLogs not implemented")
398}
399
400func RegisterAccessLogServiceServer(s *grpc.Server, srv AccessLogServiceServer) {
401	s.RegisterService(&_AccessLogService_serviceDesc, srv)
402}
403
404func _AccessLogService_StreamAccessLogs_Handler(srv interface{}, stream grpc.ServerStream) error {
405	return srv.(AccessLogServiceServer).StreamAccessLogs(&accessLogServiceStreamAccessLogsServer{stream})
406}
407
408type AccessLogService_StreamAccessLogsServer interface {
409	SendAndClose(*StreamAccessLogsResponse) error
410	Recv() (*StreamAccessLogsMessage, error)
411	grpc.ServerStream
412}
413
414type accessLogServiceStreamAccessLogsServer struct {
415	grpc.ServerStream
416}
417
418func (x *accessLogServiceStreamAccessLogsServer) SendAndClose(m *StreamAccessLogsResponse) error {
419	return x.ServerStream.SendMsg(m)
420}
421
422func (x *accessLogServiceStreamAccessLogsServer) Recv() (*StreamAccessLogsMessage, error) {
423	m := new(StreamAccessLogsMessage)
424	if err := x.ServerStream.RecvMsg(m); err != nil {
425		return nil, err
426	}
427	return m, nil
428}
429
430var _AccessLogService_serviceDesc = grpc.ServiceDesc{
431	ServiceName: "envoy.service.accesslog.v2.AccessLogService",
432	HandlerType: (*AccessLogServiceServer)(nil),
433	Methods:     []grpc.MethodDesc{},
434	Streams: []grpc.StreamDesc{
435		{
436			StreamName:    "StreamAccessLogs",
437			Handler:       _AccessLogService_StreamAccessLogs_Handler,
438			ClientStreams: true,
439		},
440	},
441	Metadata: "envoy/service/accesslog/v2/als.proto",
442}
443