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

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

     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/v4alpha/als.proto
     6  
     7  package envoy_service_accesslog_v4alpha
     8  
     9  import (
    10  	context "context"
    11  	_ "github.com/cncf/udpa/go/udpa/annotations"
    12  	v4alpha "github.com/datawire/ambassador/v2/pkg/api/envoy/config/core/v4alpha"
    13  	v3 "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_v4alpha_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_v4alpha_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_v4alpha_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_v4alpha_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_v4alpha_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_v4alpha_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 *v4alpha.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.v4alpha.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_v4alpha_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_v4alpha_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_v4alpha_als_proto_rawDescGZIP(), []int{1, 0}
   212  }
   213  
   214  func (x *StreamAccessLogsMessage_Identifier) GetNode() *v4alpha.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 []*v3.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_v4alpha_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_v4alpha_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_v4alpha_als_proto_rawDescGZIP(), []int{1, 1}
   267  }
   268  
   269  func (x *StreamAccessLogsMessage_HTTPAccessLogEntries) GetLogEntry() []*v3.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 []*v3.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_v4alpha_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_v4alpha_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_v4alpha_als_proto_rawDescGZIP(), []int{1, 2}
   315  }
   316  
   317  func (x *StreamAccessLogsMessage_TCPAccessLogEntries) GetLogEntry() []*v3.TCPAccessLogEntry {
   318  	if x != nil {
   319  		return x.LogEntry
   320  	}
   321  	return nil
   322  }
   323  
   324  var File_envoy_service_accesslog_v4alpha_als_proto protoreflect.FileDescriptor
   325  
   326  var file_envoy_service_accesslog_v4alpha_als_proto_rawDesc = []byte{
   327  	0x0a, 0x29, 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, 0x34, 0x61, 0x6c, 0x70, 0x68,
   329  	0x61, 0x2f, 0x61, 0x6c, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x1f, 0x65, 0x6e, 0x76,
   330  	0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x61, 0x63, 0x63, 0x65, 0x73,
   331  	0x73, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x1a, 0x24, 0x65, 0x6e,
   332  	0x76, 0x6f, 0x79, 0x2f, 0x63, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x2f, 0x63, 0x6f, 0x72, 0x65, 0x2f,
   333  	0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2f, 0x62, 0x61, 0x73, 0x65, 0x2e, 0x70, 0x72, 0x6f,
   334  	0x74, 0x6f, 0x1a, 0x27, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2f, 0x64, 0x61, 0x74, 0x61, 0x2f, 0x61,
   335  	0x63, 0x63, 0x65, 0x73, 0x73, 0x6c, 0x6f, 0x67, 0x2f, 0x76, 0x33, 0x2f, 0x61, 0x63, 0x63, 0x65,
   336  	0x73, 0x73, 0x6c, 0x6f, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x1d, 0x75, 0x64, 0x70,
   337  	0x61, 0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x73, 0x74,
   338  	0x61, 0x74, 0x75, 0x73, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x21, 0x75, 0x64, 0x70, 0x61,
   339  	0x2f, 0x61, 0x6e, 0x6e, 0x6f, 0x74, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x2f, 0x76, 0x65, 0x72,
   340  	0x73, 0x69, 0x6f, 0x6e, 0x69, 0x6e, 0x67, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x1a, 0x17, 0x76,
   341  	0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x65, 0x2f, 0x76, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x65,
   342  	0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x56, 0x0a, 0x18, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d,
   343  	0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
   344  	0x73, 0x65, 0x3a, 0x3a, 0x9a, 0xc5, 0x88, 0x1e, 0x35, 0x0a, 0x33, 0x65, 0x6e, 0x76, 0x6f, 0x79,
   345  	0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x6c,
   346  	0x6f, 0x67, 0x2e, 0x76, 0x33, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x41, 0x63, 0x63, 0x65,
   347  	0x73, 0x73, 0x4c, 0x6f, 0x67, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0xd5,
   348  	0x07, 0x0a, 0x17, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c,
   349  	0x6f, 0x67, 0x73, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x12, 0x63, 0x0a, 0x0a, 0x69, 0x64,
   350  	0x65, 0x6e, 0x74, 0x69, 0x66, 0x69, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x43,
   351  	0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x61,
   352  	0x63, 0x63, 0x65, 0x73, 0x73, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61,
   353  	0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67,
   354  	0x73, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x49, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x66,
   355  	0x69, 0x65, 0x72, 0x52, 0x0a, 0x69, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x66, 0x69, 0x65, 0x72, 0x12,
   356  	0x6c, 0x0a, 0x09, 0x68, 0x74, 0x74, 0x70, 0x5f, 0x6c, 0x6f, 0x67, 0x73, 0x18, 0x02, 0x20, 0x01,
   357  	0x28, 0x0b, 0x32, 0x4d, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69,
   358  	0x63, 0x65, 0x2e, 0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x34, 0x61,
   359  	0x6c, 0x70, 0x68, 0x61, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x41, 0x63, 0x63, 0x65, 0x73,
   360  	0x73, 0x4c, 0x6f, 0x67, 0x73, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x48, 0x54, 0x54,
   361  	0x50, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67, 0x45, 0x6e, 0x74, 0x72, 0x69, 0x65,
   362  	0x73, 0x48, 0x00, 0x52, 0x08, 0x68, 0x74, 0x74, 0x70, 0x4c, 0x6f, 0x67, 0x73, 0x12, 0x69, 0x0a,
   363  	0x08, 0x74, 0x63, 0x70, 0x5f, 0x6c, 0x6f, 0x67, 0x73, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32,
   364  	0x4c, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e,
   365  	0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68,
   366  	0x61, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f,
   367  	0x67, 0x73, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x54, 0x43, 0x50, 0x41, 0x63, 0x63,
   368  	0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67, 0x45, 0x6e, 0x74, 0x72, 0x69, 0x65, 0x73, 0x48, 0x00, 0x52,
   369  	0x07, 0x74, 0x63, 0x70, 0x4c, 0x6f, 0x67, 0x73, 0x1a, 0xb5, 0x01, 0x0a, 0x0a, 0x49, 0x64, 0x65,
   370  	0x6e, 0x74, 0x69, 0x66, 0x69, 0x65, 0x72, 0x12, 0x3d, 0x0a, 0x04, 0x6e, 0x6f, 0x64, 0x65, 0x18,
   371  	0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x1f, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x63, 0x6f,
   372  	0x6e, 0x66, 0x69, 0x67, 0x2e, 0x63, 0x6f, 0x72, 0x65, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68,
   373  	0x61, 0x2e, 0x4e, 0x6f, 0x64, 0x65, 0x42, 0x08, 0xfa, 0x42, 0x05, 0x8a, 0x01, 0x02, 0x10, 0x01,
   374  	0x52, 0x04, 0x6e, 0x6f, 0x64, 0x65, 0x12, 0x22, 0x0a, 0x08, 0x6c, 0x6f, 0x67, 0x5f, 0x6e, 0x61,
   375  	0x6d, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x42, 0x07, 0xfa, 0x42, 0x04, 0x72, 0x02, 0x10,
   376  	0x01, 0x52, 0x07, 0x6c, 0x6f, 0x67, 0x4e, 0x61, 0x6d, 0x65, 0x3a, 0x44, 0x9a, 0xc5, 0x88, 0x1e,
   377  	0x3f, 0x0a, 0x3d, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65,
   378  	0x2e, 0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x33, 0x2e, 0x53, 0x74,
   379  	0x72, 0x65, 0x61, 0x6d, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67, 0x73, 0x4d, 0x65,
   380  	0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x49, 0x64, 0x65, 0x6e, 0x74, 0x69, 0x66, 0x69, 0x65, 0x72,
   381  	0x1a, 0xba, 0x01, 0x0a, 0x14, 0x48, 0x54, 0x54, 0x50, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c,
   382  	0x6f, 0x67, 0x45, 0x6e, 0x74, 0x72, 0x69, 0x65, 0x73, 0x12, 0x52, 0x0a, 0x09, 0x6c, 0x6f, 0x67,
   383  	0x5f, 0x65, 0x6e, 0x74, 0x72, 0x79, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x2b, 0x2e, 0x65,
   384  	0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x64, 0x61, 0x74, 0x61, 0x2e, 0x61, 0x63, 0x63, 0x65, 0x73, 0x73,
   385  	0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x33, 0x2e, 0x48, 0x54, 0x54, 0x50, 0x41, 0x63, 0x63, 0x65, 0x73,
   386  	0x73, 0x4c, 0x6f, 0x67, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x42, 0x08, 0xfa, 0x42, 0x05, 0x92, 0x01,
   387  	0x02, 0x08, 0x01, 0x52, 0x08, 0x6c, 0x6f, 0x67, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x3a, 0x4e, 0x9a,
   388  	0xc5, 0x88, 0x1e, 0x49, 0x0a, 0x47, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76,
   389  	0x69, 0x63, 0x65, 0x2e, 0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x33,
   390  	0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67,
   391  	0x73, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x2e, 0x48, 0x54, 0x54, 0x50, 0x41, 0x63, 0x63,
   392  	0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67, 0x45, 0x6e, 0x74, 0x72, 0x69, 0x65, 0x73, 0x1a, 0xb7, 0x01,
   393  	0x0a, 0x13, 0x54, 0x43, 0x50, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67, 0x45, 0x6e,
   394  	0x74, 0x72, 0x69, 0x65, 0x73, 0x12, 0x51, 0x0a, 0x09, 0x6c, 0x6f, 0x67, 0x5f, 0x65, 0x6e, 0x74,
   395  	0x72, 0x79, 0x18, 0x01, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x2a, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79,
   396  	0x2e, 0x64, 0x61, 0x74, 0x61, 0x2e, 0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x6c, 0x6f, 0x67, 0x2e,
   397  	0x76, 0x33, 0x2e, 0x54, 0x43, 0x50, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67, 0x45,
   398  	0x6e, 0x74, 0x72, 0x79, 0x42, 0x08, 0xfa, 0x42, 0x05, 0x92, 0x01, 0x02, 0x08, 0x01, 0x52, 0x08,
   399  	0x6c, 0x6f, 0x67, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x3a, 0x4d, 0x9a, 0xc5, 0x88, 0x1e, 0x48, 0x0a,
   400  	0x46, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x61,
   401  	0x63, 0x63, 0x65, 0x73, 0x73, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x33, 0x2e, 0x53, 0x74, 0x72, 0x65,
   402  	0x61, 0x6d, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67, 0x73, 0x4d, 0x65, 0x73, 0x73,
   403  	0x61, 0x67, 0x65, 0x2e, 0x54, 0x43, 0x50, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67,
   404  	0x45, 0x6e, 0x74, 0x72, 0x69, 0x65, 0x73, 0x3a, 0x39, 0x9a, 0xc5, 0x88, 0x1e, 0x34, 0x0a, 0x32,
   405  	0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x61, 0x63,
   406  	0x63, 0x65, 0x73, 0x73, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x33, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61,
   407  	0x6d, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67, 0x73, 0x4d, 0x65, 0x73, 0x73, 0x61,
   408  	0x67, 0x65, 0x42, 0x12, 0x0a, 0x0b, 0x6c, 0x6f, 0x67, 0x5f, 0x65, 0x6e, 0x74, 0x72, 0x69, 0x65,
   409  	0x73, 0x12, 0x03, 0xf8, 0x42, 0x01, 0x32, 0xa0, 0x01, 0x0a, 0x10, 0x41, 0x63, 0x63, 0x65, 0x73,
   410  	0x73, 0x4c, 0x6f, 0x67, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x12, 0x8b, 0x01, 0x0a, 0x10,
   411  	0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67, 0x73,
   412  	0x12, 0x38, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65,
   413  	0x2e, 0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70,
   414  	0x68, 0x61, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c,
   415  	0x6f, 0x67, 0x73, 0x4d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x1a, 0x39, 0x2e, 0x65, 0x6e, 0x76,
   416  	0x6f, 0x79, 0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x61, 0x63, 0x63, 0x65, 0x73,
   417  	0x73, 0x6c, 0x6f, 0x67, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x2e, 0x53, 0x74, 0x72,
   418  	0x65, 0x61, 0x6d, 0x41, 0x63, 0x63, 0x65, 0x73, 0x73, 0x4c, 0x6f, 0x67, 0x73, 0x52, 0x65, 0x73,
   419  	0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x28, 0x01, 0x42, 0x46, 0x0a, 0x2d, 0x69, 0x6f, 0x2e,
   420  	0x65, 0x6e, 0x76, 0x6f, 0x79, 0x70, 0x72, 0x6f, 0x78, 0x79, 0x2e, 0x65, 0x6e, 0x76, 0x6f, 0x79,
   421  	0x2e, 0x73, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x61, 0x63, 0x63, 0x65, 0x73, 0x73, 0x6c,
   422  	0x6f, 0x67, 0x2e, 0x76, 0x34, 0x61, 0x6c, 0x70, 0x68, 0x61, 0x42, 0x08, 0x41, 0x6c, 0x73, 0x50,
   423  	0x72, 0x6f, 0x74, 0x6f, 0x50, 0x01, 0x88, 0x01, 0x01, 0xba, 0x80, 0xc8, 0xd1, 0x06, 0x02, 0x10,
   424  	0x03, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
   425  }
   426  
   427  var (
   428  	file_envoy_service_accesslog_v4alpha_als_proto_rawDescOnce sync.Once
   429  	file_envoy_service_accesslog_v4alpha_als_proto_rawDescData = file_envoy_service_accesslog_v4alpha_als_proto_rawDesc
   430  )
   431  
   432  func file_envoy_service_accesslog_v4alpha_als_proto_rawDescGZIP() []byte {
   433  	file_envoy_service_accesslog_v4alpha_als_proto_rawDescOnce.Do(func() {
   434  		file_envoy_service_accesslog_v4alpha_als_proto_rawDescData = protoimpl.X.CompressGZIP(file_envoy_service_accesslog_v4alpha_als_proto_rawDescData)
   435  	})
   436  	return file_envoy_service_accesslog_v4alpha_als_proto_rawDescData
   437  }
   438  
   439  var file_envoy_service_accesslog_v4alpha_als_proto_msgTypes = make([]protoimpl.MessageInfo, 5)
   440  var file_envoy_service_accesslog_v4alpha_als_proto_goTypes = []interface{}{
   441  	(*StreamAccessLogsResponse)(nil),                     // 0: envoy.service.accesslog.v4alpha.StreamAccessLogsResponse
   442  	(*StreamAccessLogsMessage)(nil),                      // 1: envoy.service.accesslog.v4alpha.StreamAccessLogsMessage
   443  	(*StreamAccessLogsMessage_Identifier)(nil),           // 2: envoy.service.accesslog.v4alpha.StreamAccessLogsMessage.Identifier
   444  	(*StreamAccessLogsMessage_HTTPAccessLogEntries)(nil), // 3: envoy.service.accesslog.v4alpha.StreamAccessLogsMessage.HTTPAccessLogEntries
   445  	(*StreamAccessLogsMessage_TCPAccessLogEntries)(nil),  // 4: envoy.service.accesslog.v4alpha.StreamAccessLogsMessage.TCPAccessLogEntries
   446  	(*v4alpha.Node)(nil),                                 // 5: envoy.config.core.v4alpha.Node
   447  	(*v3.HTTPAccessLogEntry)(nil),                        // 6: envoy.data.accesslog.v3.HTTPAccessLogEntry
   448  	(*v3.TCPAccessLogEntry)(nil),                         // 7: envoy.data.accesslog.v3.TCPAccessLogEntry
   449  }
   450  var file_envoy_service_accesslog_v4alpha_als_proto_depIdxs = []int32{
   451  	2, // 0: envoy.service.accesslog.v4alpha.StreamAccessLogsMessage.identifier:type_name -> envoy.service.accesslog.v4alpha.StreamAccessLogsMessage.Identifier
   452  	3, // 1: envoy.service.accesslog.v4alpha.StreamAccessLogsMessage.http_logs:type_name -> envoy.service.accesslog.v4alpha.StreamAccessLogsMessage.HTTPAccessLogEntries
   453  	4, // 2: envoy.service.accesslog.v4alpha.StreamAccessLogsMessage.tcp_logs:type_name -> envoy.service.accesslog.v4alpha.StreamAccessLogsMessage.TCPAccessLogEntries
   454  	5, // 3: envoy.service.accesslog.v4alpha.StreamAccessLogsMessage.Identifier.node:type_name -> envoy.config.core.v4alpha.Node
   455  	6, // 4: envoy.service.accesslog.v4alpha.StreamAccessLogsMessage.HTTPAccessLogEntries.log_entry:type_name -> envoy.data.accesslog.v3.HTTPAccessLogEntry
   456  	7, // 5: envoy.service.accesslog.v4alpha.StreamAccessLogsMessage.TCPAccessLogEntries.log_entry:type_name -> envoy.data.accesslog.v3.TCPAccessLogEntry
   457  	1, // 6: envoy.service.accesslog.v4alpha.AccessLogService.StreamAccessLogs:input_type -> envoy.service.accesslog.v4alpha.StreamAccessLogsMessage
   458  	0, // 7: envoy.service.accesslog.v4alpha.AccessLogService.StreamAccessLogs:output_type -> envoy.service.accesslog.v4alpha.StreamAccessLogsResponse
   459  	7, // [7:8] is the sub-list for method output_type
   460  	6, // [6:7] is the sub-list for method input_type
   461  	6, // [6:6] is the sub-list for extension type_name
   462  	6, // [6:6] is the sub-list for extension extendee
   463  	0, // [0:6] is the sub-list for field type_name
   464  }
   465  
   466  func init() { file_envoy_service_accesslog_v4alpha_als_proto_init() }
   467  func file_envoy_service_accesslog_v4alpha_als_proto_init() {
   468  	if File_envoy_service_accesslog_v4alpha_als_proto != nil {
   469  		return
   470  	}
   471  	if !protoimpl.UnsafeEnabled {
   472  		file_envoy_service_accesslog_v4alpha_als_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
   473  			switch v := v.(*StreamAccessLogsResponse); i {
   474  			case 0:
   475  				return &v.state
   476  			case 1:
   477  				return &v.sizeCache
   478  			case 2:
   479  				return &v.unknownFields
   480  			default:
   481  				return nil
   482  			}
   483  		}
   484  		file_envoy_service_accesslog_v4alpha_als_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
   485  			switch v := v.(*StreamAccessLogsMessage); i {
   486  			case 0:
   487  				return &v.state
   488  			case 1:
   489  				return &v.sizeCache
   490  			case 2:
   491  				return &v.unknownFields
   492  			default:
   493  				return nil
   494  			}
   495  		}
   496  		file_envoy_service_accesslog_v4alpha_als_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
   497  			switch v := v.(*StreamAccessLogsMessage_Identifier); i {
   498  			case 0:
   499  				return &v.state
   500  			case 1:
   501  				return &v.sizeCache
   502  			case 2:
   503  				return &v.unknownFields
   504  			default:
   505  				return nil
   506  			}
   507  		}
   508  		file_envoy_service_accesslog_v4alpha_als_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
   509  			switch v := v.(*StreamAccessLogsMessage_HTTPAccessLogEntries); i {
   510  			case 0:
   511  				return &v.state
   512  			case 1:
   513  				return &v.sizeCache
   514  			case 2:
   515  				return &v.unknownFields
   516  			default:
   517  				return nil
   518  			}
   519  		}
   520  		file_envoy_service_accesslog_v4alpha_als_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
   521  			switch v := v.(*StreamAccessLogsMessage_TCPAccessLogEntries); i {
   522  			case 0:
   523  				return &v.state
   524  			case 1:
   525  				return &v.sizeCache
   526  			case 2:
   527  				return &v.unknownFields
   528  			default:
   529  				return nil
   530  			}
   531  		}
   532  	}
   533  	file_envoy_service_accesslog_v4alpha_als_proto_msgTypes[1].OneofWrappers = []interface{}{
   534  		(*StreamAccessLogsMessage_HttpLogs)(nil),
   535  		(*StreamAccessLogsMessage_TcpLogs)(nil),
   536  	}
   537  	type x struct{}
   538  	out := protoimpl.TypeBuilder{
   539  		File: protoimpl.DescBuilder{
   540  			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
   541  			RawDescriptor: file_envoy_service_accesslog_v4alpha_als_proto_rawDesc,
   542  			NumEnums:      0,
   543  			NumMessages:   5,
   544  			NumExtensions: 0,
   545  			NumServices:   1,
   546  		},
   547  		GoTypes:           file_envoy_service_accesslog_v4alpha_als_proto_goTypes,
   548  		DependencyIndexes: file_envoy_service_accesslog_v4alpha_als_proto_depIdxs,
   549  		MessageInfos:      file_envoy_service_accesslog_v4alpha_als_proto_msgTypes,
   550  	}.Build()
   551  	File_envoy_service_accesslog_v4alpha_als_proto = out.File
   552  	file_envoy_service_accesslog_v4alpha_als_proto_rawDesc = nil
   553  	file_envoy_service_accesslog_v4alpha_als_proto_goTypes = nil
   554  	file_envoy_service_accesslog_v4alpha_als_proto_depIdxs = nil
   555  }
   556  
   557  // Reference imports to suppress errors if they are not otherwise used.
   558  var _ context.Context
   559  var _ grpc.ClientConnInterface
   560  
   561  // This is a compile-time assertion to ensure that this generated file
   562  // is compatible with the grpc package it is being compiled against.
   563  const _ = grpc.SupportPackageIsVersion6
   564  
   565  // AccessLogServiceClient is the client API for AccessLogService service.
   566  //
   567  // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
   568  type AccessLogServiceClient interface {
   569  	// Envoy will connect and send StreamAccessLogsMessage messages forever. It does not expect any
   570  	// response to be sent as nothing would be done in the case of failure. The server should
   571  	// disconnect if it expects Envoy to reconnect. In the future we may decide to add a different
   572  	// API for "critical" access logs in which Envoy will buffer access logs for some period of time
   573  	// until it gets an ACK so it could then retry. This API is designed for high throughput with the
   574  	// expectation that it might be lossy.
   575  	StreamAccessLogs(ctx context.Context, opts ...grpc.CallOption) (AccessLogService_StreamAccessLogsClient, error)
   576  }
   577  
   578  type accessLogServiceClient struct {
   579  	cc grpc.ClientConnInterface
   580  }
   581  
   582  func NewAccessLogServiceClient(cc grpc.ClientConnInterface) AccessLogServiceClient {
   583  	return &accessLogServiceClient{cc}
   584  }
   585  
   586  func (c *accessLogServiceClient) StreamAccessLogs(ctx context.Context, opts ...grpc.CallOption) (AccessLogService_StreamAccessLogsClient, error) {
   587  	stream, err := c.cc.NewStream(ctx, &_AccessLogService_serviceDesc.Streams[0], "/envoy.service.accesslog.v4alpha.AccessLogService/StreamAccessLogs", opts...)
   588  	if err != nil {
   589  		return nil, err
   590  	}
   591  	x := &accessLogServiceStreamAccessLogsClient{stream}
   592  	return x, nil
   593  }
   594  
   595  type AccessLogService_StreamAccessLogsClient interface {
   596  	Send(*StreamAccessLogsMessage) error
   597  	CloseAndRecv() (*StreamAccessLogsResponse, error)
   598  	grpc.ClientStream
   599  }
   600  
   601  type accessLogServiceStreamAccessLogsClient struct {
   602  	grpc.ClientStream
   603  }
   604  
   605  func (x *accessLogServiceStreamAccessLogsClient) Send(m *StreamAccessLogsMessage) error {
   606  	return x.ClientStream.SendMsg(m)
   607  }
   608  
   609  func (x *accessLogServiceStreamAccessLogsClient) CloseAndRecv() (*StreamAccessLogsResponse, error) {
   610  	if err := x.ClientStream.CloseSend(); err != nil {
   611  		return nil, err
   612  	}
   613  	m := new(StreamAccessLogsResponse)
   614  	if err := x.ClientStream.RecvMsg(m); err != nil {
   615  		return nil, err
   616  	}
   617  	return m, nil
   618  }
   619  
   620  // AccessLogServiceServer is the server API for AccessLogService service.
   621  type AccessLogServiceServer interface {
   622  	// Envoy will connect and send StreamAccessLogsMessage messages forever. It does not expect any
   623  	// response to be sent as nothing would be done in the case of failure. The server should
   624  	// disconnect if it expects Envoy to reconnect. In the future we may decide to add a different
   625  	// API for "critical" access logs in which Envoy will buffer access logs for some period of time
   626  	// until it gets an ACK so it could then retry. This API is designed for high throughput with the
   627  	// expectation that it might be lossy.
   628  	StreamAccessLogs(AccessLogService_StreamAccessLogsServer) error
   629  }
   630  
   631  // UnimplementedAccessLogServiceServer can be embedded to have forward compatible implementations.
   632  type UnimplementedAccessLogServiceServer struct {
   633  }
   634  
   635  func (*UnimplementedAccessLogServiceServer) StreamAccessLogs(AccessLogService_StreamAccessLogsServer) error {
   636  	return status.Errorf(codes.Unimplemented, "method StreamAccessLogs not implemented")
   637  }
   638  
   639  func RegisterAccessLogServiceServer(s *grpc.Server, srv AccessLogServiceServer) {
   640  	s.RegisterService(&_AccessLogService_serviceDesc, srv)
   641  }
   642  
   643  func _AccessLogService_StreamAccessLogs_Handler(srv interface{}, stream grpc.ServerStream) error {
   644  	return srv.(AccessLogServiceServer).StreamAccessLogs(&accessLogServiceStreamAccessLogsServer{stream})
   645  }
   646  
   647  type AccessLogService_StreamAccessLogsServer interface {
   648  	SendAndClose(*StreamAccessLogsResponse) error
   649  	Recv() (*StreamAccessLogsMessage, error)
   650  	grpc.ServerStream
   651  }
   652  
   653  type accessLogServiceStreamAccessLogsServer struct {
   654  	grpc.ServerStream
   655  }
   656  
   657  func (x *accessLogServiceStreamAccessLogsServer) SendAndClose(m *StreamAccessLogsResponse) error {
   658  	return x.ServerStream.SendMsg(m)
   659  }
   660  
   661  func (x *accessLogServiceStreamAccessLogsServer) Recv() (*StreamAccessLogsMessage, error) {
   662  	m := new(StreamAccessLogsMessage)
   663  	if err := x.ServerStream.RecvMsg(m); err != nil {
   664  		return nil, err
   665  	}
   666  	return m, nil
   667  }
   668  
   669  var _AccessLogService_serviceDesc = grpc.ServiceDesc{
   670  	ServiceName: "envoy.service.accesslog.v4alpha.AccessLogService",
   671  	HandlerType: (*AccessLogServiceServer)(nil),
   672  	Methods:     []grpc.MethodDesc{},
   673  	Streams: []grpc.StreamDesc{
   674  		{
   675  			StreamName:    "StreamAccessLogs",
   676  			Handler:       _AccessLogService_StreamAccessLogs_Handler,
   677  			ClientStreams: true,
   678  		},
   679  	},
   680  	Metadata: "envoy/service/accesslog/v4alpha/als.proto",
   681  }
   682  

View as plain text