Source file src/github.com/datawire/ambassador/v2/pkg/api/envoy/service/accesslog/v3/als.pb.go

Documentation: github.com/datawire/ambassador/v2/pkg/api/envoy/service/accesslog/v3

     1  // Code generated by protoc-gen-go. DO NOT EDIT.
     2  // versions:
     3  // 	protoc-gen-go v1.25.0
     4  // 	protoc        v3.14.0
     5  // source: envoy/service/accesslog/v3/als.proto
     6  
     7  package envoy_service_accesslog_v3
     8  
     9  import (
    10  	context "context"
    11  	_ "github.com/cncf/udpa/go/udpa/annotations"
    12  	v3 "github.com/datawire/ambassador/v2/pkg/api/envoy/config/core/v3"
    13  	v31 "github.com/datawire/ambassador/v2/pkg/api/envoy/data/accesslog/v3"
    14  	_ "github.com/envoyproxy/protoc-gen-validate/validate"
    15  	proto "github.com/golang/protobuf/proto"
    16  	grpc "google.golang.org/grpc"
    17  	codes "google.golang.org/grpc/codes"
    18  	status "google.golang.org/grpc/status"
    19  	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
    20  	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
    21  	reflect "reflect"
    22  	sync "sync"
    23  )
    24  
    25  const (
    26  	// Verify that this generated code is sufficiently up-to-date.
    27  	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
    28  	// Verify that runtime/protoimpl is sufficiently up-to-date.
    29  	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
    30  )
    31  
    32  // This is a compile-time assertion that a sufficiently up-to-date version
    33  // of the legacy proto package is being used.
    34  const _ = proto.ProtoPackageIsVersion4
    35  
    36  // Empty response for the StreamAccessLogs API. Will never be sent. See below.
    37  type StreamAccessLogsResponse struct {
    38  	state         protoimpl.MessageState
    39  	sizeCache     protoimpl.SizeCache
    40  	unknownFields protoimpl.UnknownFields
    41  }
    42  
    43  func (x *StreamAccessLogsResponse) Reset() {
    44  	*x = StreamAccessLogsResponse{}
    45  	if protoimpl.UnsafeEnabled {
    46  		mi := &file_envoy_service_accesslog_v3_als_proto_msgTypes[0]
    47  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    48  		ms.StoreMessageInfo(mi)
    49  	}
    50  }
    51  
    52  func (x *StreamAccessLogsResponse) String() string {
    53  	return protoimpl.X.MessageStringOf(x)
    54  }
    55  
    56  func (*StreamAccessLogsResponse) ProtoMessage() {}
    57  
    58  func (x *StreamAccessLogsResponse) ProtoReflect() protoreflect.Message {
    59  	mi := &file_envoy_service_accesslog_v3_als_proto_msgTypes[0]
    60  	if protoimpl.UnsafeEnabled && x != nil {
    61  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    62  		if ms.LoadMessageInfo() == nil {
    63  			ms.StoreMessageInfo(mi)
    64  		}
    65  		return ms
    66  	}
    67  	return mi.MessageOf(x)
    68  }
    69  
    70  // Deprecated: Use StreamAccessLogsResponse.ProtoReflect.Descriptor instead.
    71  func (*StreamAccessLogsResponse) Descriptor() ([]byte, []int) {
    72  	return file_envoy_service_accesslog_v3_als_proto_rawDescGZIP(), []int{0}
    73  }
    74  
    75  // Stream message for the StreamAccessLogs API. Envoy will open a stream to the server and stream
    76  // access logs without ever expecting a response.
    77  type StreamAccessLogsMessage struct {
    78  	state         protoimpl.MessageState
    79  	sizeCache     protoimpl.SizeCache
    80  	unknownFields protoimpl.UnknownFields
    81  
    82  	// Identifier data that will only be sent in the first message on the stream. This is effectively
    83  	// structured metadata and is a performance optimization.
    84  	Identifier *StreamAccessLogsMessage_Identifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
    85  	// Batches of log entries of a single type. Generally speaking, a given stream should only
    86  	// ever include one type of log entry.
    87  	//
    88  	// Types that are assignable to LogEntries:
    89  	//	*StreamAccessLogsMessage_HttpLogs
    90  	//	*StreamAccessLogsMessage_TcpLogs
    91  	LogEntries isStreamAccessLogsMessage_LogEntries `protobuf_oneof:"log_entries"`
    92  }
    93  
    94  func (x *StreamAccessLogsMessage) Reset() {
    95  	*x = StreamAccessLogsMessage{}
    96  	if protoimpl.UnsafeEnabled {
    97  		mi := &file_envoy_service_accesslog_v3_als_proto_msgTypes[1]
    98  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
    99  		ms.StoreMessageInfo(mi)
   100  	}
   101  }
   102  
   103  func (x *StreamAccessLogsMessage) String() string {
   104  	return protoimpl.X.MessageStringOf(x)
   105  }
   106  
   107  func (*StreamAccessLogsMessage) ProtoMessage() {}
   108  
   109  func (x *StreamAccessLogsMessage) ProtoReflect() protoreflect.Message {
   110  	mi := &file_envoy_service_accesslog_v3_als_proto_msgTypes[1]
   111  	if protoimpl.UnsafeEnabled && x != nil {
   112  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   113  		if ms.LoadMessageInfo() == nil {
   114  			ms.StoreMessageInfo(mi)
   115  		}
   116  		return ms
   117  	}
   118  	return mi.MessageOf(x)
   119  }
   120  
   121  // Deprecated: Use StreamAccessLogsMessage.ProtoReflect.Descriptor instead.
   122  func (*StreamAccessLogsMessage) Descriptor() ([]byte, []int) {
   123  	return file_envoy_service_accesslog_v3_als_proto_rawDescGZIP(), []int{1}
   124  }
   125  
   126  func (x *StreamAccessLogsMessage) GetIdentifier() *StreamAccessLogsMessage_Identifier {
   127  	if x != nil {
   128  		return x.Identifier
   129  	}
   130  	return nil
   131  }
   132  
   133  func (m *StreamAccessLogsMessage) GetLogEntries() isStreamAccessLogsMessage_LogEntries {
   134  	if m != nil {
   135  		return m.LogEntries
   136  	}
   137  	return nil
   138  }
   139  
   140  func (x *StreamAccessLogsMessage) GetHttpLogs() *StreamAccessLogsMessage_HTTPAccessLogEntries {
   141  	if x, ok := x.GetLogEntries().(*StreamAccessLogsMessage_HttpLogs); ok {
   142  		return x.HttpLogs
   143  	}
   144  	return nil
   145  }
   146  
   147  func (x *StreamAccessLogsMessage) GetTcpLogs() *StreamAccessLogsMessage_TCPAccessLogEntries {
   148  	if x, ok := x.GetLogEntries().(*StreamAccessLogsMessage_TcpLogs); ok {
   149  		return x.TcpLogs
   150  	}
   151  	return nil
   152  }
   153  
   154  type isStreamAccessLogsMessage_LogEntries interface {
   155  	isStreamAccessLogsMessage_LogEntries()
   156  }
   157  
   158  type StreamAccessLogsMessage_HttpLogs struct {
   159  	HttpLogs *StreamAccessLogsMessage_HTTPAccessLogEntries `protobuf:"bytes,2,opt,name=http_logs,json=httpLogs,proto3,oneof"`
   160  }
   161  
   162  type StreamAccessLogsMessage_TcpLogs struct {
   163  	TcpLogs *StreamAccessLogsMessage_TCPAccessLogEntries `protobuf:"bytes,3,opt,name=tcp_logs,json=tcpLogs,proto3,oneof"`
   164  }
   165  
   166  func (*StreamAccessLogsMessage_HttpLogs) isStreamAccessLogsMessage_LogEntries() {}
   167  
   168  func (*StreamAccessLogsMessage_TcpLogs) isStreamAccessLogsMessage_LogEntries() {}
   169  
   170  type StreamAccessLogsMessage_Identifier struct {
   171  	state         protoimpl.MessageState
   172  	sizeCache     protoimpl.SizeCache
   173  	unknownFields protoimpl.UnknownFields
   174  
   175  	// The node sending the access log messages over the stream.
   176  	Node *v3.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
   177  	// The friendly name of the log configured in :ref:`CommonGrpcAccessLogConfig
   178  	// <envoy_api_msg_extensions.access_loggers.grpc.v3.CommonGrpcAccessLogConfig>`.
   179  	LogName string `protobuf:"bytes,2,opt,name=log_name,json=logName,proto3" json:"log_name,omitempty"`
   180  }
   181  
   182  func (x *StreamAccessLogsMessage_Identifier) Reset() {
   183  	*x = StreamAccessLogsMessage_Identifier{}
   184  	if protoimpl.UnsafeEnabled {
   185  		mi := &file_envoy_service_accesslog_v3_als_proto_msgTypes[2]
   186  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   187  		ms.StoreMessageInfo(mi)
   188  	}
   189  }
   190  
   191  func (x *StreamAccessLogsMessage_Identifier) String() string {
   192  	return protoimpl.X.MessageStringOf(x)
   193  }
   194  
   195  func (*StreamAccessLogsMessage_Identifier) ProtoMessage() {}
   196  
   197  func (x *StreamAccessLogsMessage_Identifier) ProtoReflect() protoreflect.Message {
   198  	mi := &file_envoy_service_accesslog_v3_als_proto_msgTypes[2]
   199  	if protoimpl.UnsafeEnabled && x != nil {
   200  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   201  		if ms.LoadMessageInfo() == nil {
   202  			ms.StoreMessageInfo(mi)
   203  		}
   204  		return ms
   205  	}
   206  	return mi.MessageOf(x)
   207  }
   208  
   209  // Deprecated: Use StreamAccessLogsMessage_Identifier.ProtoReflect.Descriptor instead.
   210  func (*StreamAccessLogsMessage_Identifier) Descriptor() ([]byte, []int) {
   211  	return file_envoy_service_accesslog_v3_als_proto_rawDescGZIP(), []int{1, 0}
   212  }
   213  
   214  func (x *StreamAccessLogsMessage_Identifier) GetNode() *v3.Node {
   215  	if x != nil {
   216  		return x.Node
   217  	}
   218  	return nil
   219  }
   220  
   221  func (x *StreamAccessLogsMessage_Identifier) GetLogName() string {
   222  	if x != nil {
   223  		return x.LogName
   224  	}
   225  	return ""
   226  }
   227  
   228  // Wrapper for batches of HTTP access log entries.
   229  type StreamAccessLogsMessage_HTTPAccessLogEntries struct {
   230  	state         protoimpl.MessageState
   231  	sizeCache     protoimpl.SizeCache
   232  	unknownFields protoimpl.UnknownFields
   233  
   234  	LogEntry []*v31.HTTPAccessLogEntry `protobuf:"bytes,1,rep,name=log_entry,json=logEntry,proto3" json:"log_entry,omitempty"`
   235  }
   236  
   237  func (x *StreamAccessLogsMessage_HTTPAccessLogEntries) Reset() {
   238  	*x = StreamAccessLogsMessage_HTTPAccessLogEntries{}
   239  	if protoimpl.UnsafeEnabled {
   240  		mi := &file_envoy_service_accesslog_v3_als_proto_msgTypes[3]
   241  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   242  		ms.StoreMessageInfo(mi)
   243  	}
   244  }
   245  
   246  func (x *StreamAccessLogsMessage_HTTPAccessLogEntries) String() string {
   247  	return protoimpl.X.MessageStringOf(x)
   248  }
   249  
   250  func (*StreamAccessLogsMessage_HTTPAccessLogEntries) ProtoMessage() {}
   251  
   252  func (x *StreamAccessLogsMessage_HTTPAccessLogEntries) ProtoReflect() protoreflect.Message {
   253  	mi := &file_envoy_service_accesslog_v3_als_proto_msgTypes[3]
   254  	if protoimpl.UnsafeEnabled && x != nil {
   255  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   256  		if ms.LoadMessageInfo() == nil {
   257  			ms.StoreMessageInfo(mi)
   258  		}
   259  		return ms
   260  	}
   261  	return mi.MessageOf(x)
   262  }
   263  
   264  // Deprecated: Use StreamAccessLogsMessage_HTTPAccessLogEntries.ProtoReflect.Descriptor instead.
   265  func (*StreamAccessLogsMessage_HTTPAccessLogEntries) Descriptor() ([]byte, []int) {
   266  	return file_envoy_service_accesslog_v3_als_proto_rawDescGZIP(), []int{1, 1}
   267  }
   268  
   269  func (x *StreamAccessLogsMessage_HTTPAccessLogEntries) GetLogEntry() []*v31.HTTPAccessLogEntry {
   270  	if x != nil {
   271  		return x.LogEntry
   272  	}
   273  	return nil
   274  }
   275  
   276  // Wrapper for batches of TCP access log entries.
   277  type StreamAccessLogsMessage_TCPAccessLogEntries struct {
   278  	state         protoimpl.MessageState
   279  	sizeCache     protoimpl.SizeCache
   280  	unknownFields protoimpl.UnknownFields
   281  
   282  	LogEntry []*v31.TCPAccessLogEntry `protobuf:"bytes,1,rep,name=log_entry,json=logEntry,proto3" json:"log_entry,omitempty"`
   283  }
   284  
   285  func (x *StreamAccessLogsMessage_TCPAccessLogEntries) Reset() {
   286  	*x = StreamAccessLogsMessage_TCPAccessLogEntries{}
   287  	if protoimpl.UnsafeEnabled {
   288  		mi := &file_envoy_service_accesslog_v3_als_proto_msgTypes[4]
   289  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   290  		ms.StoreMessageInfo(mi)
   291  	}
   292  }
   293  
   294  func (x *StreamAccessLogsMessage_TCPAccessLogEntries) String() string {
   295  	return protoimpl.X.MessageStringOf(x)
   296  }
   297  
   298  func (*StreamAccessLogsMessage_TCPAccessLogEntries) ProtoMessage() {}
   299  
   300  func (x *StreamAccessLogsMessage_TCPAccessLogEntries) ProtoReflect() protoreflect.Message {
   301  	mi := &file_envoy_service_accesslog_v3_als_proto_msgTypes[4]
   302  	if protoimpl.UnsafeEnabled && x != nil {
   303  		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
   304  		if ms.LoadMessageInfo() == nil {
   305  			ms.StoreMessageInfo(mi)
   306  		}
   307  		return ms
   308  	}
   309  	return mi.MessageOf(x)
   310  }
   311  
   312  // Deprecated: Use StreamAccessLogsMessage_TCPAccessLogEntries.ProtoReflect.Descriptor instead.
   313  func (*StreamAccessLogsMessage_TCPAccessLogEntries) Descriptor() ([]byte, []int) {
   314  	return file_envoy_service_accesslog_v3_als_proto_rawDescGZIP(), []int{1, 2}
   315  }
   316  
   317  func (x *StreamAccessLogsMessage_TCPAccessLogEntries) GetLogEntry() []*v31.TCPAccessLogEntry {
   318  	if x != nil {
   319  		return x.LogEntry
   320  	}
   321  	return nil
   322  }
   323  
   324  var File_envoy_service_accesslog_v3_als_proto protoreflect.FileDescriptor
   325  
   326  var file_envoy_service_accesslog_v3_als_proto_rawDesc = []byte{
   327  	0x0a, 0x24, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2f,
   328  	0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x6c, 0x6f, 0x67, 0x2f, 0x76, 0x33, 0x2f, 0x61, 0x6c, 0x73,
   329  	0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x1a, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65,
   330  	0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x6c, 0x6f, 0x67, 0x2e,
   331  	0x76, 0x33, 0x1a, 0x1f, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67,
   332  	0x2f, 0x63, 0x6f, 0x72, 0x65, 0x2f, 0x76, 0x33, 0x2f, 0x62, 0x61, 0x73, 0x65, 0x2e, 0x70, 0x72,
   333  	0x6f, 0x74, 0x6f, 0x1a, 0x27, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x2f,
   334  	0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x6c, 0x6f, 0x67, 0x2f, 0x76, 0x33, 0x2f, 0x61, 0x63, 0x63,
   335  	0x65, 0x73, 0x73, 0x6c, 0x6f, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1d, 0x75, 0x64,
   336  	0x70, 0x61, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x73,
   337  	0x74, 0x61, 0x74, 0x75, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x21, 0x75, 0x64, 0x70,
   338  	0x61, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x76, 0x65,
   339  	0x72, 0x73, 0x69, 0x6f, 0x6e, 0x69, 0x6e, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17,
   340  	0x76, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x65, 0x2f, 0x76, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74,
   341  	0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x56, 0x0a, 0x18, 0x53, 0x74, 0x72, 0x65, 0x61,
   342  	0x6d, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f,
   343  	0x6e, 0x73, 0x65, 0x3a, 0x3a, 0x9a, 0xc5, 0x88, 0x1e, 0x35, 0x0a, 0x33, 0x65, 0x6e, 0x76, 0x6f,
   344  	0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x61, 0x63, 0x63, 0x65, 0x73, 0x73,
   345  	0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x32, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x41, 0x63, 0x63,
   346  	0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22,
   347  	0xc1, 0x07, 0x0a, 0x17, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73,
   348  	0x4c, 0x6f, 0x67, 0x73, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x5e, 0x0a, 0x0a, 0x69,
   349  	0x64, 0x65, 0x6e, 0x74, 0x69, 0x66, 0x69, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32,
   350  	0x3e, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e,
   351  	0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x33, 0x2e, 0x53, 0x74, 0x72,
   352  	0x65, 0x61, 0x6d, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67, 0x73, 0x4d, 0x65, 0x73,
   353  	0x73, 0x61, 0x67, 0x65, 0x2e, 0x49, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x66, 0x69, 0x65, 0x72, 0x52,
   354  	0x0a, 0x69, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x66, 0x69, 0x65, 0x72, 0x12, 0x67, 0x0a, 0x09, 0x68,
   355  	0x74, 0x74, 0x70, 0x5f, 0x6c, 0x6f, 0x67, 0x73, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x48,
   356  	0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x61,
   357  	0x63, 0x63, 0x65, 0x73, 0x73, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x33, 0x2e, 0x53, 0x74, 0x72, 0x65,
   358  	0x61, 0x6d, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67, 0x73, 0x4d, 0x65, 0x73, 0x73,
   359  	0x61, 0x67, 0x65, 0x2e, 0x48, 0x54, 0x54, 0x50, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f,
   360  	0x67, 0x45, 0x6e, 0x74, 0x72, 0x69, 0x65, 0x73, 0x48, 0x00, 0x52, 0x08, 0x68, 0x74, 0x74, 0x70,
   361  	0x4c, 0x6f, 0x67, 0x73, 0x12, 0x64, 0x0a, 0x08, 0x74, 0x63, 0x70, 0x5f, 0x6c, 0x6f, 0x67, 0x73,
   362  	0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x47, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73,
   363  	0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x6c, 0x6f, 0x67,
   364  	0x2e, 0x76, 0x33, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73,
   365  	0x4c, 0x6f, 0x67, 0x73, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x54, 0x43, 0x50, 0x41,
   366  	0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67, 0x45, 0x6e, 0x74, 0x72, 0x69, 0x65, 0x73, 0x48,
   367  	0x00, 0x52, 0x07, 0x74, 0x63, 0x70, 0x4c, 0x6f, 0x67, 0x73, 0x1a, 0xb0, 0x01, 0x0a, 0x0a, 0x49,
   368  	0x64, 0x65, 0x6e, 0x74, 0x69, 0x66, 0x69, 0x65, 0x72, 0x12, 0x38, 0x0a, 0x04, 0x6e, 0x6f, 0x64,
   369  	0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1a, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e,
   370  	0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x2e, 0x63, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x33, 0x2e, 0x4e,
   371  	0x6f, 0x64, 0x65, 0x42, 0x08, 0xfa, 0x42, 0x05, 0x8a, 0x01, 0x02, 0x10, 0x01, 0x52, 0x04, 0x6e,
   372  	0x6f, 0x64, 0x65, 0x12, 0x22, 0x0a, 0x08, 0x6c, 0x6f, 0x67, 0x5f, 0x6e, 0x61, 0x6d, 0x65, 0x18,
   373  	0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x07, 0xfa, 0x42, 0x04, 0x72, 0x02, 0x10, 0x01, 0x52, 0x07,
   374  	0x6c, 0x6f, 0x67, 0x4e, 0x61, 0x6d, 0x65, 0x3a, 0x44, 0x9a, 0xc5, 0x88, 0x1e, 0x3f, 0x0a, 0x3d,
   375  	0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x61, 0x63,
   376  	0x63, 0x65, 0x73, 0x73, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x32, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61,
   377  	0x6d, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67, 0x73, 0x4d, 0x65, 0x73, 0x73, 0x61,
   378  	0x67, 0x65, 0x2e, 0x49, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x66, 0x69, 0x65, 0x72, 0x1a, 0xba, 0x01,
   379  	0x0a, 0x14, 0x48, 0x54, 0x54, 0x50, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67, 0x45,
   380  	0x6e, 0x74, 0x72, 0x69, 0x65, 0x73, 0x12, 0x52, 0x0a, 0x09, 0x6c, 0x6f, 0x67, 0x5f, 0x65, 0x6e,
   381  	0x74, 0x72, 0x79, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x2b, 0x2e, 0x65, 0x6e, 0x76, 0x6f,
   382  	0x79, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x2e, 0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x6c, 0x6f, 0x67,
   383  	0x2e, 0x76, 0x33, 0x2e, 0x48, 0x54, 0x54, 0x50, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f,
   384  	0x67, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x42, 0x08, 0xfa, 0x42, 0x05, 0x92, 0x01, 0x02, 0x08, 0x01,
   385  	0x52, 0x08, 0x6c, 0x6f, 0x67, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x3a, 0x4e, 0x9a, 0xc5, 0x88, 0x1e,
   386  	0x49, 0x0a, 0x47, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65,
   387  	0x2e, 0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x32, 0x2e, 0x53, 0x74,
   388  	0x72, 0x65, 0x61, 0x6d, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67, 0x73, 0x4d, 0x65,
   389  	0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x48, 0x54, 0x54, 0x50, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73,
   390  	0x4c, 0x6f, 0x67, 0x45, 0x6e, 0x74, 0x72, 0x69, 0x65, 0x73, 0x1a, 0xb7, 0x01, 0x0a, 0x13, 0x54,
   391  	0x43, 0x50, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67, 0x45, 0x6e, 0x74, 0x72, 0x69,
   392  	0x65, 0x73, 0x12, 0x51, 0x0a, 0x09, 0x6c, 0x6f, 0x67, 0x5f, 0x65, 0x6e, 0x74, 0x72, 0x79, 0x18,
   393  	0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x2a, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x64, 0x61,
   394  	0x74, 0x61, 0x2e, 0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x33, 0x2e,
   395  	0x54, 0x43, 0x50, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67, 0x45, 0x6e, 0x74, 0x72,
   396  	0x79, 0x42, 0x08, 0xfa, 0x42, 0x05, 0x92, 0x01, 0x02, 0x08, 0x01, 0x52, 0x08, 0x6c, 0x6f, 0x67,
   397  	0x45, 0x6e, 0x74, 0x72, 0x79, 0x3a, 0x4d, 0x9a, 0xc5, 0x88, 0x1e, 0x48, 0x0a, 0x46, 0x65, 0x6e,
   398  	0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x61, 0x63, 0x63, 0x65,
   399  	0x73, 0x73, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x32, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x41,
   400  	0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67, 0x73, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65,
   401  	0x2e, 0x54, 0x43, 0x50, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67, 0x45, 0x6e, 0x74,
   402  	0x72, 0x69, 0x65, 0x73, 0x3a, 0x39, 0x9a, 0xc5, 0x88, 0x1e, 0x34, 0x0a, 0x32, 0x65, 0x6e, 0x76,
   403  	0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x61, 0x63, 0x63, 0x65, 0x73,
   404  	0x73, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x32, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x41, 0x63,
   405  	0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67, 0x73, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x42,
   406  	0x12, 0x0a, 0x0b, 0x6c, 0x6f, 0x67, 0x5f, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x65, 0x73, 0x12, 0x03,
   407  	0xf8, 0x42, 0x01, 0x32, 0x96, 0x01, 0x0a, 0x10, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f,
   408  	0x67, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x81, 0x01, 0x0a, 0x10, 0x53, 0x74, 0x72,
   409  	0x65, 0x61, 0x6d, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67, 0x73, 0x12, 0x33, 0x2e,
   410  	0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x61, 0x63,
   411  	0x63, 0x65, 0x73, 0x73, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x33, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61,
   412  	0x6d, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67, 0x73, 0x4d, 0x65, 0x73, 0x73, 0x61,
   413  	0x67, 0x65, 0x1a, 0x34, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69,
   414  	0x63, 0x65, 0x2e, 0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x33, 0x2e,
   415  	0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67, 0x73,
   416  	0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x42, 0x41, 0x0a, 0x28,
   417  	0x69, 0x6f, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x65, 0x6e,
   418  	0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x61, 0x63, 0x63, 0x65,
   419  	0x73, 0x73, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x33, 0x42, 0x08, 0x41, 0x6c, 0x73, 0x50, 0x72, 0x6f,
   420  	0x74, 0x6f, 0x50, 0x01, 0x88, 0x01, 0x01, 0xba, 0x80, 0xc8, 0xd1, 0x06, 0x02, 0x10, 0x02, 0x62,
   421  	0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
   422  }
   423  
   424  var (
   425  	file_envoy_service_accesslog_v3_als_proto_rawDescOnce sync.Once
   426  	file_envoy_service_accesslog_v3_als_proto_rawDescData = file_envoy_service_accesslog_v3_als_proto_rawDesc
   427  )
   428  
   429  func file_envoy_service_accesslog_v3_als_proto_rawDescGZIP() []byte {
   430  	file_envoy_service_accesslog_v3_als_proto_rawDescOnce.Do(func() {
   431  		file_envoy_service_accesslog_v3_als_proto_rawDescData = protoimpl.X.CompressGZIP(file_envoy_service_accesslog_v3_als_proto_rawDescData)
   432  	})
   433  	return file_envoy_service_accesslog_v3_als_proto_rawDescData
   434  }
   435  
   436  var file_envoy_service_accesslog_v3_als_proto_msgTypes = make([]protoimpl.MessageInfo, 5)
   437  var file_envoy_service_accesslog_v3_als_proto_goTypes = []interface{}{
   438  	(*StreamAccessLogsResponse)(nil),                     // 0: envoy.service.accesslog.v3.StreamAccessLogsResponse
   439  	(*StreamAccessLogsMessage)(nil),                      // 1: envoy.service.accesslog.v3.StreamAccessLogsMessage
   440  	(*StreamAccessLogsMessage_Identifier)(nil),           // 2: envoy.service.accesslog.v3.StreamAccessLogsMessage.Identifier
   441  	(*StreamAccessLogsMessage_HTTPAccessLogEntries)(nil), // 3: envoy.service.accesslog.v3.StreamAccessLogsMessage.HTTPAccessLogEntries
   442  	(*StreamAccessLogsMessage_TCPAccessLogEntries)(nil),  // 4: envoy.service.accesslog.v3.StreamAccessLogsMessage.TCPAccessLogEntries
   443  	(*v3.Node)(nil),                // 5: envoy.config.core.v3.Node
   444  	(*v31.HTTPAccessLogEntry)(nil), // 6: envoy.data.accesslog.v3.HTTPAccessLogEntry
   445  	(*v31.TCPAccessLogEntry)(nil),  // 7: envoy.data.accesslog.v3.TCPAccessLogEntry
   446  }
   447  var file_envoy_service_accesslog_v3_als_proto_depIdxs = []int32{
   448  	2, // 0: envoy.service.accesslog.v3.StreamAccessLogsMessage.identifier:type_name -> envoy.service.accesslog.v3.StreamAccessLogsMessage.Identifier
   449  	3, // 1: envoy.service.accesslog.v3.StreamAccessLogsMessage.http_logs:type_name -> envoy.service.accesslog.v3.StreamAccessLogsMessage.HTTPAccessLogEntries
   450  	4, // 2: envoy.service.accesslog.v3.StreamAccessLogsMessage.tcp_logs:type_name -> envoy.service.accesslog.v3.StreamAccessLogsMessage.TCPAccessLogEntries
   451  	5, // 3: envoy.service.accesslog.v3.StreamAccessLogsMessage.Identifier.node:type_name -> envoy.config.core.v3.Node
   452  	6, // 4: envoy.service.accesslog.v3.StreamAccessLogsMessage.HTTPAccessLogEntries.log_entry:type_name -> envoy.data.accesslog.v3.HTTPAccessLogEntry
   453  	7, // 5: envoy.service.accesslog.v3.StreamAccessLogsMessage.TCPAccessLogEntries.log_entry:type_name -> envoy.data.accesslog.v3.TCPAccessLogEntry
   454  	1, // 6: envoy.service.accesslog.v3.AccessLogService.StreamAccessLogs:input_type -> envoy.service.accesslog.v3.StreamAccessLogsMessage
   455  	0, // 7: envoy.service.accesslog.v3.AccessLogService.StreamAccessLogs:output_type -> envoy.service.accesslog.v3.StreamAccessLogsResponse
   456  	7, // [7:8] is the sub-list for method output_type
   457  	6, // [6:7] is the sub-list for method input_type
   458  	6, // [6:6] is the sub-list for extension type_name
   459  	6, // [6:6] is the sub-list for extension extendee
   460  	0, // [0:6] is the sub-list for field type_name
   461  }
   462  
   463  func init() { file_envoy_service_accesslog_v3_als_proto_init() }
   464  func file_envoy_service_accesslog_v3_als_proto_init() {
   465  	if File_envoy_service_accesslog_v3_als_proto != nil {
   466  		return
   467  	}
   468  	if !protoimpl.UnsafeEnabled {
   469  		file_envoy_service_accesslog_v3_als_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
   470  			switch v := v.(*StreamAccessLogsResponse); i {
   471  			case 0:
   472  				return &v.state
   473  			case 1:
   474  				return &v.sizeCache
   475  			case 2:
   476  				return &v.unknownFields
   477  			default:
   478  				return nil
   479  			}
   480  		}
   481  		file_envoy_service_accesslog_v3_als_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
   482  			switch v := v.(*StreamAccessLogsMessage); i {
   483  			case 0:
   484  				return &v.state
   485  			case 1:
   486  				return &v.sizeCache
   487  			case 2:
   488  				return &v.unknownFields
   489  			default:
   490  				return nil
   491  			}
   492  		}
   493  		file_envoy_service_accesslog_v3_als_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
   494  			switch v := v.(*StreamAccessLogsMessage_Identifier); i {
   495  			case 0:
   496  				return &v.state
   497  			case 1:
   498  				return &v.sizeCache
   499  			case 2:
   500  				return &v.unknownFields
   501  			default:
   502  				return nil
   503  			}
   504  		}
   505  		file_envoy_service_accesslog_v3_als_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
   506  			switch v := v.(*StreamAccessLogsMessage_HTTPAccessLogEntries); i {
   507  			case 0:
   508  				return &v.state
   509  			case 1:
   510  				return &v.sizeCache
   511  			case 2:
   512  				return &v.unknownFields
   513  			default:
   514  				return nil
   515  			}
   516  		}
   517  		file_envoy_service_accesslog_v3_als_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
   518  			switch v := v.(*StreamAccessLogsMessage_TCPAccessLogEntries); i {
   519  			case 0:
   520  				return &v.state
   521  			case 1:
   522  				return &v.sizeCache
   523  			case 2:
   524  				return &v.unknownFields
   525  			default:
   526  				return nil
   527  			}
   528  		}
   529  	}
   530  	file_envoy_service_accesslog_v3_als_proto_msgTypes[1].OneofWrappers = []interface{}{
   531  		(*StreamAccessLogsMessage_HttpLogs)(nil),
   532  		(*StreamAccessLogsMessage_TcpLogs)(nil),
   533  	}
   534  	type x struct{}
   535  	out := protoimpl.TypeBuilder{
   536  		File: protoimpl.DescBuilder{
   537  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
   538  			RawDescriptor: file_envoy_service_accesslog_v3_als_proto_rawDesc,
   539  			NumEnums:      0,
   540  			NumMessages:   5,
   541  			NumExtensions: 0,
   542  			NumServices:   1,
   543  		},
   544  		GoTypes:           file_envoy_service_accesslog_v3_als_proto_goTypes,
   545  		DependencyIndexes: file_envoy_service_accesslog_v3_als_proto_depIdxs,
   546  		MessageInfos:      file_envoy_service_accesslog_v3_als_proto_msgTypes,
   547  	}.Build()
   548  	File_envoy_service_accesslog_v3_als_proto = out.File
   549  	file_envoy_service_accesslog_v3_als_proto_rawDesc = nil
   550  	file_envoy_service_accesslog_v3_als_proto_goTypes = nil
   551  	file_envoy_service_accesslog_v3_als_proto_depIdxs = nil
   552  }
   553  
   554  // Reference imports to suppress errors if they are not otherwise used.
   555  var _ context.Context
   556  var _ grpc.ClientConnInterface
   557  
   558  // This is a compile-time assertion to ensure that this generated file
   559  // is compatible with the grpc package it is being compiled against.
   560  const _ = grpc.SupportPackageIsVersion6
   561  
   562  // AccessLogServiceClient is the client API for AccessLogService service.
   563  //
   564  // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
   565  type AccessLogServiceClient interface {
   566  	// Envoy will connect and send StreamAccessLogsMessage messages forever. It does not expect any
   567  	// response to be sent as nothing would be done in the case of failure. The server should
   568  	// disconnect if it expects Envoy to reconnect. In the future we may decide to add a different
   569  	// API for "critical" access logs in which Envoy will buffer access logs for some period of time
   570  	// until it gets an ACK so it could then retry. This API is designed for high throughput with the
   571  	// expectation that it might be lossy.
   572  	StreamAccessLogs(ctx context.Context, opts ...grpc.CallOption) (AccessLogService_StreamAccessLogsClient, error)
   573  }
   574  
   575  type accessLogServiceClient struct {
   576  	cc grpc.ClientConnInterface
   577  }
   578  
   579  func NewAccessLogServiceClient(cc grpc.ClientConnInterface) AccessLogServiceClient {
   580  	return &accessLogServiceClient{cc}
   581  }
   582  
   583  func (c *accessLogServiceClient) StreamAccessLogs(ctx context.Context, opts ...grpc.CallOption) (AccessLogService_StreamAccessLogsClient, error) {
   584  	stream, err := c.cc.NewStream(ctx, &_AccessLogService_serviceDesc.Streams[0], "/envoy.service.accesslog.v3.AccessLogService/StreamAccessLogs", opts...)
   585  	if err != nil {
   586  		return nil, err
   587  	}
   588  	x := &accessLogServiceStreamAccessLogsClient{stream}
   589  	return x, nil
   590  }
   591  
   592  type AccessLogService_StreamAccessLogsClient interface {
   593  	Send(*StreamAccessLogsMessage) error
   594  	CloseAndRecv() (*StreamAccessLogsResponse, error)
   595  	grpc.ClientStream
   596  }
   597  
   598  type accessLogServiceStreamAccessLogsClient struct {
   599  	grpc.ClientStream
   600  }
   601  
   602  func (x *accessLogServiceStreamAccessLogsClient) Send(m *StreamAccessLogsMessage) error {
   603  	return x.ClientStream.SendMsg(m)
   604  }
   605  
   606  func (x *accessLogServiceStreamAccessLogsClient) CloseAndRecv() (*StreamAccessLogsResponse, error) {
   607  	if err := x.ClientStream.CloseSend(); err != nil {
   608  		return nil, err
   609  	}
   610  	m := new(StreamAccessLogsResponse)
   611  	if err := x.ClientStream.RecvMsg(m); err != nil {
   612  		return nil, err
   613  	}
   614  	return m, nil
   615  }
   616  
   617  // AccessLogServiceServer is the server API for AccessLogService service.
   618  type AccessLogServiceServer interface {
   619  	// Envoy will connect and send StreamAccessLogsMessage messages forever. It does not expect any
   620  	// response to be sent as nothing would be done in the case of failure. The server should
   621  	// disconnect if it expects Envoy to reconnect. In the future we may decide to add a different
   622  	// API for "critical" access logs in which Envoy will buffer access logs for some period of time
   623  	// until it gets an ACK so it could then retry. This API is designed for high throughput with the
   624  	// expectation that it might be lossy.
   625  	StreamAccessLogs(AccessLogService_StreamAccessLogsServer) error
   626  }
   627  
   628  // UnimplementedAccessLogServiceServer can be embedded to have forward compatible implementations.
   629  type UnimplementedAccessLogServiceServer struct {
   630  }
   631  
   632  func (*UnimplementedAccessLogServiceServer) StreamAccessLogs(AccessLogService_StreamAccessLogsServer) error {
   633  	return status.Errorf(codes.Unimplemented, "method StreamAccessLogs not implemented")
   634  }
   635  
   636  func RegisterAccessLogServiceServer(s *grpc.Server, srv AccessLogServiceServer) {
   637  	s.RegisterService(&_AccessLogService_serviceDesc, srv)
   638  }
   639  
   640  func _AccessLogService_StreamAccessLogs_Handler(srv interface{}, stream grpc.ServerStream) error {
   641  	return srv.(AccessLogServiceServer).StreamAccessLogs(&accessLogServiceStreamAccessLogsServer{stream})
   642  }
   643  
   644  type AccessLogService_StreamAccessLogsServer interface {
   645  	SendAndClose(*StreamAccessLogsResponse) error
   646  	Recv() (*StreamAccessLogsMessage, error)
   647  	grpc.ServerStream
   648  }
   649  
   650  type accessLogServiceStreamAccessLogsServer struct {
   651  	grpc.ServerStream
   652  }
   653  
   654  func (x *accessLogServiceStreamAccessLogsServer) SendAndClose(m *StreamAccessLogsResponse) error {
   655  	return x.ServerStream.SendMsg(m)
   656  }
   657  
   658  func (x *accessLogServiceStreamAccessLogsServer) Recv() (*StreamAccessLogsMessage, error) {
   659  	m := new(StreamAccessLogsMessage)
   660  	if err := x.ServerStream.RecvMsg(m); err != nil {
   661  		return nil, err
   662  	}
   663  	return m, nil
   664  }
   665  
   666  var _AccessLogService_serviceDesc = grpc.ServiceDesc{
   667  	ServiceName: "envoy.service.accesslog.v3.AccessLogService",
   668  	HandlerType: (*AccessLogServiceServer)(nil),
   669  	Methods:     []grpc.MethodDesc{},
   670  	Streams: []grpc.StreamDesc{
   671  		{
   672  			StreamName:    "StreamAccessLogs",
   673  			Handler:       _AccessLogService_StreamAccessLogs_Handler,
   674  			ClientStreams: true,
   675  		},
   676  	},
   677  	Metadata: "envoy/service/accesslog/v3/als.proto",
   678  }
   679  

View as plain text