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