Source file src/github.com/emissary-ingress/emissary/v3/pkg/api/envoy/service/accesslog/v2/als.pb.go

Documentation: github.com/emissary-ingress/emissary/v3/pkg/api/envoy/service/accesslog/v2

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

View as plain text