Documentation ¶
Index ¶
- Variables
- func RegisterAccessLogServiceServer(s *grpc.Server, srv AccessLogServiceServer)
- type AccessLogServiceClient
- type AccessLogServiceServer
- type AccessLogService_StreamAccessLogsClient
- type AccessLogService_StreamAccessLogsServer
- type StreamAccessLogsMessage
- func (*StreamAccessLogsMessage) Descriptor() ([]byte, []int)
- func (m *StreamAccessLogsMessage) GetHttpLogs() *StreamAccessLogsMessage_HTTPAccessLogEntries
- func (m *StreamAccessLogsMessage) GetIdentifier() *StreamAccessLogsMessage_Identifier
- func (m *StreamAccessLogsMessage) GetLogEntries() isStreamAccessLogsMessage_LogEntries
- func (m *StreamAccessLogsMessage) GetTcpLogs() *StreamAccessLogsMessage_TCPAccessLogEntries
- func (m *StreamAccessLogsMessage) Marshal() (dAtA []byte, err error)
- func (m *StreamAccessLogsMessage) MarshalTo(dAtA []byte) (int, error)
- func (*StreamAccessLogsMessage) ProtoMessage()
- func (m *StreamAccessLogsMessage) Reset()
- func (m *StreamAccessLogsMessage) Size() (n int)
- func (m *StreamAccessLogsMessage) String() string
- func (m *StreamAccessLogsMessage) Unmarshal(dAtA []byte) error
- func (m *StreamAccessLogsMessage) Validate() error
- func (m *StreamAccessLogsMessage) XXX_DiscardUnknown()
- func (m *StreamAccessLogsMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamAccessLogsMessage) XXX_Merge(src proto.Message)
- func (*StreamAccessLogsMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *StreamAccessLogsMessage) XXX_Size() int
- func (m *StreamAccessLogsMessage) XXX_Unmarshal(b []byte) error
- type StreamAccessLogsMessageValidationError
- func (e StreamAccessLogsMessageValidationError) Cause() error
- func (e StreamAccessLogsMessageValidationError) Error() string
- func (e StreamAccessLogsMessageValidationError) ErrorName() string
- func (e StreamAccessLogsMessageValidationError) Field() string
- func (e StreamAccessLogsMessageValidationError) Key() bool
- func (e StreamAccessLogsMessageValidationError) Reason() string
- type StreamAccessLogsMessage_HTTPAccessLogEntries
- func (*StreamAccessLogsMessage_HTTPAccessLogEntries) Descriptor() ([]byte, []int)
- func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) GetLogEntry() []*v2.HTTPAccessLogEntry
- func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) Marshal() (dAtA []byte, err error)
- func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) MarshalTo(dAtA []byte) (int, error)
- func (*StreamAccessLogsMessage_HTTPAccessLogEntries) ProtoMessage()
- func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) Reset()
- func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) Size() (n int)
- func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) String() string
- func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) Unmarshal(dAtA []byte) error
- func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) Validate() error
- func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) XXX_DiscardUnknown()
- func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) XXX_Merge(src proto.Message)
- func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) XXX_Size() int
- func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) XXX_Unmarshal(b []byte) error
- type StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError
- func (e StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError) Cause() error
- func (e StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError) Error() string
- func (e StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError) ErrorName() string
- func (e StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError) Field() string
- func (e StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError) Key() bool
- func (e StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError) Reason() string
- type StreamAccessLogsMessage_HttpLogs
- type StreamAccessLogsMessage_Identifier
- func (*StreamAccessLogsMessage_Identifier) Descriptor() ([]byte, []int)
- func (m *StreamAccessLogsMessage_Identifier) GetLogName() string
- func (m *StreamAccessLogsMessage_Identifier) GetNode() *core.Node
- func (m *StreamAccessLogsMessage_Identifier) Marshal() (dAtA []byte, err error)
- func (m *StreamAccessLogsMessage_Identifier) MarshalTo(dAtA []byte) (int, error)
- func (*StreamAccessLogsMessage_Identifier) ProtoMessage()
- func (m *StreamAccessLogsMessage_Identifier) Reset()
- func (m *StreamAccessLogsMessage_Identifier) Size() (n int)
- func (m *StreamAccessLogsMessage_Identifier) String() string
- func (m *StreamAccessLogsMessage_Identifier) Unmarshal(dAtA []byte) error
- func (m *StreamAccessLogsMessage_Identifier) Validate() error
- func (m *StreamAccessLogsMessage_Identifier) XXX_DiscardUnknown()
- func (m *StreamAccessLogsMessage_Identifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamAccessLogsMessage_Identifier) XXX_Merge(src proto.Message)
- func (m *StreamAccessLogsMessage_Identifier) XXX_Size() int
- func (m *StreamAccessLogsMessage_Identifier) XXX_Unmarshal(b []byte) error
- type StreamAccessLogsMessage_IdentifierValidationError
- func (e StreamAccessLogsMessage_IdentifierValidationError) Cause() error
- func (e StreamAccessLogsMessage_IdentifierValidationError) Error() string
- func (e StreamAccessLogsMessage_IdentifierValidationError) ErrorName() string
- func (e StreamAccessLogsMessage_IdentifierValidationError) Field() string
- func (e StreamAccessLogsMessage_IdentifierValidationError) Key() bool
- func (e StreamAccessLogsMessage_IdentifierValidationError) Reason() string
- type StreamAccessLogsMessage_TCPAccessLogEntries
- func (*StreamAccessLogsMessage_TCPAccessLogEntries) Descriptor() ([]byte, []int)
- func (m *StreamAccessLogsMessage_TCPAccessLogEntries) GetLogEntry() []*v2.TCPAccessLogEntry
- func (m *StreamAccessLogsMessage_TCPAccessLogEntries) Marshal() (dAtA []byte, err error)
- func (m *StreamAccessLogsMessage_TCPAccessLogEntries) MarshalTo(dAtA []byte) (int, error)
- func (*StreamAccessLogsMessage_TCPAccessLogEntries) ProtoMessage()
- func (m *StreamAccessLogsMessage_TCPAccessLogEntries) Reset()
- func (m *StreamAccessLogsMessage_TCPAccessLogEntries) Size() (n int)
- func (m *StreamAccessLogsMessage_TCPAccessLogEntries) String() string
- func (m *StreamAccessLogsMessage_TCPAccessLogEntries) Unmarshal(dAtA []byte) error
- func (m *StreamAccessLogsMessage_TCPAccessLogEntries) Validate() error
- func (m *StreamAccessLogsMessage_TCPAccessLogEntries) XXX_DiscardUnknown()
- func (m *StreamAccessLogsMessage_TCPAccessLogEntries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamAccessLogsMessage_TCPAccessLogEntries) XXX_Merge(src proto.Message)
- func (m *StreamAccessLogsMessage_TCPAccessLogEntries) XXX_Size() int
- func (m *StreamAccessLogsMessage_TCPAccessLogEntries) XXX_Unmarshal(b []byte) error
- type StreamAccessLogsMessage_TCPAccessLogEntriesValidationError
- func (e StreamAccessLogsMessage_TCPAccessLogEntriesValidationError) Cause() error
- func (e StreamAccessLogsMessage_TCPAccessLogEntriesValidationError) Error() string
- func (e StreamAccessLogsMessage_TCPAccessLogEntriesValidationError) ErrorName() string
- func (e StreamAccessLogsMessage_TCPAccessLogEntriesValidationError) Field() string
- func (e StreamAccessLogsMessage_TCPAccessLogEntriesValidationError) Key() bool
- func (e StreamAccessLogsMessage_TCPAccessLogEntriesValidationError) Reason() string
- type StreamAccessLogsMessage_TcpLogs
- type StreamAccessLogsResponse
- func (*StreamAccessLogsResponse) Descriptor() ([]byte, []int)
- func (m *StreamAccessLogsResponse) Marshal() (dAtA []byte, err error)
- func (m *StreamAccessLogsResponse) MarshalTo(dAtA []byte) (int, error)
- func (*StreamAccessLogsResponse) ProtoMessage()
- func (m *StreamAccessLogsResponse) Reset()
- func (m *StreamAccessLogsResponse) Size() (n int)
- func (m *StreamAccessLogsResponse) String() string
- func (m *StreamAccessLogsResponse) Unmarshal(dAtA []byte) error
- func (m *StreamAccessLogsResponse) Validate() error
- func (m *StreamAccessLogsResponse) XXX_DiscardUnknown()
- func (m *StreamAccessLogsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamAccessLogsResponse) XXX_Merge(src proto.Message)
- func (m *StreamAccessLogsResponse) XXX_Size() int
- func (m *StreamAccessLogsResponse) XXX_Unmarshal(b []byte) error
- type StreamAccessLogsResponseValidationError
- func (e StreamAccessLogsResponseValidationError) Cause() error
- func (e StreamAccessLogsResponseValidationError) Error() string
- func (e StreamAccessLogsResponseValidationError) ErrorName() string
- func (e StreamAccessLogsResponseValidationError) Field() string
- func (e StreamAccessLogsResponseValidationError) Key() bool
- func (e StreamAccessLogsResponseValidationError) Reason() string
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthAls = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowAls = fmt.Errorf("proto: integer overflow") )
Functions ¶
func RegisterAccessLogServiceServer ¶
func RegisterAccessLogServiceServer(s *grpc.Server, srv AccessLogServiceServer)
Types ¶
type AccessLogServiceClient ¶
type AccessLogServiceClient interface { // Envoy will connect and send StreamAccessLogsMessage messages forever. It does not expect any // response to be sent as nothing would be done in the case of failure. The server should // disconnect if it expects Envoy to reconnect. In the future we may decide to add a different // API for "critical" access logs in which Envoy will buffer access logs for some period of time // until it gets an ACK so it could then retry. This API is designed for high throughput with the // expectation that it might be lossy. StreamAccessLogs(ctx context.Context, opts ...grpc.CallOption) (AccessLogService_StreamAccessLogsClient, error) }
AccessLogServiceClient is the client API for AccessLogService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewAccessLogServiceClient ¶
func NewAccessLogServiceClient(cc *grpc.ClientConn) AccessLogServiceClient
type AccessLogServiceServer ¶
type AccessLogServiceServer interface { // Envoy will connect and send StreamAccessLogsMessage messages forever. It does not expect any // response to be sent as nothing would be done in the case of failure. The server should // disconnect if it expects Envoy to reconnect. In the future we may decide to add a different // API for "critical" access logs in which Envoy will buffer access logs for some period of time // until it gets an ACK so it could then retry. This API is designed for high throughput with the // expectation that it might be lossy. StreamAccessLogs(AccessLogService_StreamAccessLogsServer) error }
AccessLogServiceServer is the server API for AccessLogService service.
type AccessLogService_StreamAccessLogsClient ¶
type AccessLogService_StreamAccessLogsClient interface { Send(*StreamAccessLogsMessage) error CloseAndRecv() (*StreamAccessLogsResponse, error) grpc.ClientStream }
type AccessLogService_StreamAccessLogsServer ¶
type AccessLogService_StreamAccessLogsServer interface { SendAndClose(*StreamAccessLogsResponse) error Recv() (*StreamAccessLogsMessage, error) grpc.ServerStream }
type StreamAccessLogsMessage ¶
type StreamAccessLogsMessage struct { // Identifier data that will only be sent in the first message on the stream. This is effectively // structured metadata and is a performance optimization. Identifier *StreamAccessLogsMessage_Identifier `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"` // Batches of log entries of a single type. Generally speaking, a given stream should only // ever include one type of log entry. // // Types that are valid to be assigned to LogEntries: // *StreamAccessLogsMessage_HttpLogs // *StreamAccessLogsMessage_TcpLogs LogEntries isStreamAccessLogsMessage_LogEntries `protobuf_oneof:"log_entries"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Stream message for the StreamAccessLogs API. Envoy will open a stream to the server and stream access logs without ever expecting a response.
func (*StreamAccessLogsMessage) Descriptor ¶
func (*StreamAccessLogsMessage) Descriptor() ([]byte, []int)
func (*StreamAccessLogsMessage) GetHttpLogs ¶
func (m *StreamAccessLogsMessage) GetHttpLogs() *StreamAccessLogsMessage_HTTPAccessLogEntries
func (*StreamAccessLogsMessage) GetIdentifier ¶
func (m *StreamAccessLogsMessage) GetIdentifier() *StreamAccessLogsMessage_Identifier
func (*StreamAccessLogsMessage) GetLogEntries ¶
func (m *StreamAccessLogsMessage) GetLogEntries() isStreamAccessLogsMessage_LogEntries
func (*StreamAccessLogsMessage) GetTcpLogs ¶
func (m *StreamAccessLogsMessage) GetTcpLogs() *StreamAccessLogsMessage_TCPAccessLogEntries
func (*StreamAccessLogsMessage) Marshal ¶
func (m *StreamAccessLogsMessage) Marshal() (dAtA []byte, err error)
func (*StreamAccessLogsMessage) MarshalTo ¶
func (m *StreamAccessLogsMessage) MarshalTo(dAtA []byte) (int, error)
func (*StreamAccessLogsMessage) ProtoMessage ¶
func (*StreamAccessLogsMessage) ProtoMessage()
func (*StreamAccessLogsMessage) Reset ¶
func (m *StreamAccessLogsMessage) Reset()
func (*StreamAccessLogsMessage) Size ¶
func (m *StreamAccessLogsMessage) Size() (n int)
func (*StreamAccessLogsMessage) String ¶
func (m *StreamAccessLogsMessage) String() string
func (*StreamAccessLogsMessage) Unmarshal ¶
func (m *StreamAccessLogsMessage) Unmarshal(dAtA []byte) error
func (*StreamAccessLogsMessage) Validate ¶
func (m *StreamAccessLogsMessage) Validate() error
Validate checks the field values on StreamAccessLogsMessage with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*StreamAccessLogsMessage) XXX_DiscardUnknown ¶
func (m *StreamAccessLogsMessage) XXX_DiscardUnknown()
func (*StreamAccessLogsMessage) XXX_Marshal ¶
func (m *StreamAccessLogsMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamAccessLogsMessage) XXX_Merge ¶
func (m *StreamAccessLogsMessage) XXX_Merge(src proto.Message)
func (*StreamAccessLogsMessage) XXX_OneofFuncs ¶
func (*StreamAccessLogsMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*StreamAccessLogsMessage) XXX_Size ¶
func (m *StreamAccessLogsMessage) XXX_Size() int
func (*StreamAccessLogsMessage) XXX_Unmarshal ¶
func (m *StreamAccessLogsMessage) XXX_Unmarshal(b []byte) error
type StreamAccessLogsMessageValidationError ¶
type StreamAccessLogsMessageValidationError struct {
// contains filtered or unexported fields
}
StreamAccessLogsMessageValidationError is the validation error returned by StreamAccessLogsMessage.Validate if the designated constraints aren't met.
func (StreamAccessLogsMessageValidationError) Cause ¶
func (e StreamAccessLogsMessageValidationError) Cause() error
Cause function returns cause value.
func (StreamAccessLogsMessageValidationError) Error ¶
func (e StreamAccessLogsMessageValidationError) Error() string
Error satisfies the builtin error interface
func (StreamAccessLogsMessageValidationError) ErrorName ¶ added in v0.7.0
func (e StreamAccessLogsMessageValidationError) ErrorName() string
ErrorName returns error name.
func (StreamAccessLogsMessageValidationError) Field ¶
func (e StreamAccessLogsMessageValidationError) Field() string
Field function returns field value.
func (StreamAccessLogsMessageValidationError) Key ¶
func (e StreamAccessLogsMessageValidationError) Key() bool
Key function returns key value.
func (StreamAccessLogsMessageValidationError) Reason ¶
func (e StreamAccessLogsMessageValidationError) Reason() string
Reason function returns reason value.
type StreamAccessLogsMessage_HTTPAccessLogEntries ¶
type StreamAccessLogsMessage_HTTPAccessLogEntries struct { LogEntry []*v2.HTTPAccessLogEntry `protobuf:"bytes,1,rep,name=log_entry,json=logEntry,proto3" json:"log_entry,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Wrapper for batches of HTTP access log entries.
func (*StreamAccessLogsMessage_HTTPAccessLogEntries) Descriptor ¶
func (*StreamAccessLogsMessage_HTTPAccessLogEntries) Descriptor() ([]byte, []int)
func (*StreamAccessLogsMessage_HTTPAccessLogEntries) GetLogEntry ¶
func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) GetLogEntry() []*v2.HTTPAccessLogEntry
func (*StreamAccessLogsMessage_HTTPAccessLogEntries) Marshal ¶
func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) Marshal() (dAtA []byte, err error)
func (*StreamAccessLogsMessage_HTTPAccessLogEntries) MarshalTo ¶
func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) MarshalTo(dAtA []byte) (int, error)
func (*StreamAccessLogsMessage_HTTPAccessLogEntries) ProtoMessage ¶
func (*StreamAccessLogsMessage_HTTPAccessLogEntries) ProtoMessage()
func (*StreamAccessLogsMessage_HTTPAccessLogEntries) Reset ¶
func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) Reset()
func (*StreamAccessLogsMessage_HTTPAccessLogEntries) Size ¶
func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) Size() (n int)
func (*StreamAccessLogsMessage_HTTPAccessLogEntries) String ¶
func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) String() string
func (*StreamAccessLogsMessage_HTTPAccessLogEntries) Unmarshal ¶
func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) Unmarshal(dAtA []byte) error
func (*StreamAccessLogsMessage_HTTPAccessLogEntries) Validate ¶
func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) Validate() error
Validate checks the field values on StreamAccessLogsMessage_HTTPAccessLogEntries with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*StreamAccessLogsMessage_HTTPAccessLogEntries) XXX_DiscardUnknown ¶
func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) XXX_DiscardUnknown()
func (*StreamAccessLogsMessage_HTTPAccessLogEntries) XXX_Marshal ¶
func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamAccessLogsMessage_HTTPAccessLogEntries) XXX_Merge ¶
func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) XXX_Merge(src proto.Message)
func (*StreamAccessLogsMessage_HTTPAccessLogEntries) XXX_Size ¶
func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) XXX_Size() int
func (*StreamAccessLogsMessage_HTTPAccessLogEntries) XXX_Unmarshal ¶
func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) XXX_Unmarshal(b []byte) error
type StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError ¶
type StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError struct {
// contains filtered or unexported fields
}
StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError is the validation error returned by StreamAccessLogsMessage_HTTPAccessLogEntries.Validate if the designated constraints aren't met.
func (StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError) Cause ¶
func (e StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError) Cause() error
Cause function returns cause value.
func (StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError) Error ¶
func (e StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError) Error() string
Error satisfies the builtin error interface
func (StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError) ErrorName ¶ added in v0.7.0
func (e StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError) ErrorName() string
ErrorName returns error name.
func (StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError) Field ¶
func (e StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError) Field() string
Field function returns field value.
func (StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError) Key ¶
func (e StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError) Key() bool
Key function returns key value.
func (StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError) Reason ¶
func (e StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError) Reason() string
Reason function returns reason value.
type StreamAccessLogsMessage_HttpLogs ¶
type StreamAccessLogsMessage_HttpLogs struct {
HttpLogs *StreamAccessLogsMessage_HTTPAccessLogEntries `protobuf:"bytes,2,opt,name=http_logs,json=httpLogs,proto3,oneof"`
}
func (*StreamAccessLogsMessage_HttpLogs) MarshalTo ¶
func (m *StreamAccessLogsMessage_HttpLogs) MarshalTo(dAtA []byte) (int, error)
func (*StreamAccessLogsMessage_HttpLogs) Size ¶
func (m *StreamAccessLogsMessage_HttpLogs) Size() (n int)
type StreamAccessLogsMessage_Identifier ¶
type StreamAccessLogsMessage_Identifier struct { // The node sending the access log messages over the stream. Node *core.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"` // The friendly name of the log configured in :ref:`CommonGrpcAccessLogConfig // <envoy_api_msg_config.accesslog.v2.CommonGrpcAccessLogConfig>`. LogName string `protobuf:"bytes,2,opt,name=log_name,json=logName,proto3" json:"log_name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StreamAccessLogsMessage_Identifier) Descriptor ¶
func (*StreamAccessLogsMessage_Identifier) Descriptor() ([]byte, []int)
func (*StreamAccessLogsMessage_Identifier) GetLogName ¶
func (m *StreamAccessLogsMessage_Identifier) GetLogName() string
func (*StreamAccessLogsMessage_Identifier) GetNode ¶
func (m *StreamAccessLogsMessage_Identifier) GetNode() *core.Node
func (*StreamAccessLogsMessage_Identifier) Marshal ¶
func (m *StreamAccessLogsMessage_Identifier) Marshal() (dAtA []byte, err error)
func (*StreamAccessLogsMessage_Identifier) MarshalTo ¶
func (m *StreamAccessLogsMessage_Identifier) MarshalTo(dAtA []byte) (int, error)
func (*StreamAccessLogsMessage_Identifier) ProtoMessage ¶
func (*StreamAccessLogsMessage_Identifier) ProtoMessage()
func (*StreamAccessLogsMessage_Identifier) Reset ¶
func (m *StreamAccessLogsMessage_Identifier) Reset()
func (*StreamAccessLogsMessage_Identifier) Size ¶
func (m *StreamAccessLogsMessage_Identifier) Size() (n int)
func (*StreamAccessLogsMessage_Identifier) String ¶
func (m *StreamAccessLogsMessage_Identifier) String() string
func (*StreamAccessLogsMessage_Identifier) Unmarshal ¶
func (m *StreamAccessLogsMessage_Identifier) Unmarshal(dAtA []byte) error
func (*StreamAccessLogsMessage_Identifier) Validate ¶
func (m *StreamAccessLogsMessage_Identifier) Validate() error
Validate checks the field values on StreamAccessLogsMessage_Identifier with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*StreamAccessLogsMessage_Identifier) XXX_DiscardUnknown ¶
func (m *StreamAccessLogsMessage_Identifier) XXX_DiscardUnknown()
func (*StreamAccessLogsMessage_Identifier) XXX_Marshal ¶
func (m *StreamAccessLogsMessage_Identifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamAccessLogsMessage_Identifier) XXX_Merge ¶
func (m *StreamAccessLogsMessage_Identifier) XXX_Merge(src proto.Message)
func (*StreamAccessLogsMessage_Identifier) XXX_Size ¶
func (m *StreamAccessLogsMessage_Identifier) XXX_Size() int
func (*StreamAccessLogsMessage_Identifier) XXX_Unmarshal ¶
func (m *StreamAccessLogsMessage_Identifier) XXX_Unmarshal(b []byte) error
type StreamAccessLogsMessage_IdentifierValidationError ¶
type StreamAccessLogsMessage_IdentifierValidationError struct {
// contains filtered or unexported fields
}
StreamAccessLogsMessage_IdentifierValidationError is the validation error returned by StreamAccessLogsMessage_Identifier.Validate if the designated constraints aren't met.
func (StreamAccessLogsMessage_IdentifierValidationError) Cause ¶
func (e StreamAccessLogsMessage_IdentifierValidationError) Cause() error
Cause function returns cause value.
func (StreamAccessLogsMessage_IdentifierValidationError) Error ¶
func (e StreamAccessLogsMessage_IdentifierValidationError) Error() string
Error satisfies the builtin error interface
func (StreamAccessLogsMessage_IdentifierValidationError) ErrorName ¶ added in v0.7.0
func (e StreamAccessLogsMessage_IdentifierValidationError) ErrorName() string
ErrorName returns error name.
func (StreamAccessLogsMessage_IdentifierValidationError) Field ¶
func (e StreamAccessLogsMessage_IdentifierValidationError) Field() string
Field function returns field value.
func (StreamAccessLogsMessage_IdentifierValidationError) Key ¶
func (e StreamAccessLogsMessage_IdentifierValidationError) Key() bool
Key function returns key value.
func (StreamAccessLogsMessage_IdentifierValidationError) Reason ¶
func (e StreamAccessLogsMessage_IdentifierValidationError) Reason() string
Reason function returns reason value.
type StreamAccessLogsMessage_TCPAccessLogEntries ¶
type StreamAccessLogsMessage_TCPAccessLogEntries struct { LogEntry []*v2.TCPAccessLogEntry `protobuf:"bytes,1,rep,name=log_entry,json=logEntry,proto3" json:"log_entry,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
[#not-implemented-hide:] Wrapper for batches of TCP access log entries.
func (*StreamAccessLogsMessage_TCPAccessLogEntries) Descriptor ¶
func (*StreamAccessLogsMessage_TCPAccessLogEntries) Descriptor() ([]byte, []int)
func (*StreamAccessLogsMessage_TCPAccessLogEntries) GetLogEntry ¶
func (m *StreamAccessLogsMessage_TCPAccessLogEntries) GetLogEntry() []*v2.TCPAccessLogEntry
func (*StreamAccessLogsMessage_TCPAccessLogEntries) Marshal ¶
func (m *StreamAccessLogsMessage_TCPAccessLogEntries) Marshal() (dAtA []byte, err error)
func (*StreamAccessLogsMessage_TCPAccessLogEntries) MarshalTo ¶
func (m *StreamAccessLogsMessage_TCPAccessLogEntries) MarshalTo(dAtA []byte) (int, error)
func (*StreamAccessLogsMessage_TCPAccessLogEntries) ProtoMessage ¶
func (*StreamAccessLogsMessage_TCPAccessLogEntries) ProtoMessage()
func (*StreamAccessLogsMessage_TCPAccessLogEntries) Reset ¶
func (m *StreamAccessLogsMessage_TCPAccessLogEntries) Reset()
func (*StreamAccessLogsMessage_TCPAccessLogEntries) Size ¶
func (m *StreamAccessLogsMessage_TCPAccessLogEntries) Size() (n int)
func (*StreamAccessLogsMessage_TCPAccessLogEntries) String ¶
func (m *StreamAccessLogsMessage_TCPAccessLogEntries) String() string
func (*StreamAccessLogsMessage_TCPAccessLogEntries) Unmarshal ¶
func (m *StreamAccessLogsMessage_TCPAccessLogEntries) Unmarshal(dAtA []byte) error
func (*StreamAccessLogsMessage_TCPAccessLogEntries) Validate ¶
func (m *StreamAccessLogsMessage_TCPAccessLogEntries) Validate() error
Validate checks the field values on StreamAccessLogsMessage_TCPAccessLogEntries with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*StreamAccessLogsMessage_TCPAccessLogEntries) XXX_DiscardUnknown ¶
func (m *StreamAccessLogsMessage_TCPAccessLogEntries) XXX_DiscardUnknown()
func (*StreamAccessLogsMessage_TCPAccessLogEntries) XXX_Marshal ¶
func (m *StreamAccessLogsMessage_TCPAccessLogEntries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamAccessLogsMessage_TCPAccessLogEntries) XXX_Merge ¶
func (m *StreamAccessLogsMessage_TCPAccessLogEntries) XXX_Merge(src proto.Message)
func (*StreamAccessLogsMessage_TCPAccessLogEntries) XXX_Size ¶
func (m *StreamAccessLogsMessage_TCPAccessLogEntries) XXX_Size() int
func (*StreamAccessLogsMessage_TCPAccessLogEntries) XXX_Unmarshal ¶
func (m *StreamAccessLogsMessage_TCPAccessLogEntries) XXX_Unmarshal(b []byte) error
type StreamAccessLogsMessage_TCPAccessLogEntriesValidationError ¶
type StreamAccessLogsMessage_TCPAccessLogEntriesValidationError struct {
// contains filtered or unexported fields
}
StreamAccessLogsMessage_TCPAccessLogEntriesValidationError is the validation error returned by StreamAccessLogsMessage_TCPAccessLogEntries.Validate if the designated constraints aren't met.
func (StreamAccessLogsMessage_TCPAccessLogEntriesValidationError) Cause ¶
func (e StreamAccessLogsMessage_TCPAccessLogEntriesValidationError) Cause() error
Cause function returns cause value.
func (StreamAccessLogsMessage_TCPAccessLogEntriesValidationError) Error ¶
func (e StreamAccessLogsMessage_TCPAccessLogEntriesValidationError) Error() string
Error satisfies the builtin error interface
func (StreamAccessLogsMessage_TCPAccessLogEntriesValidationError) ErrorName ¶ added in v0.7.0
func (e StreamAccessLogsMessage_TCPAccessLogEntriesValidationError) ErrorName() string
ErrorName returns error name.
func (StreamAccessLogsMessage_TCPAccessLogEntriesValidationError) Field ¶
func (e StreamAccessLogsMessage_TCPAccessLogEntriesValidationError) Field() string
Field function returns field value.
func (StreamAccessLogsMessage_TCPAccessLogEntriesValidationError) Key ¶
func (e StreamAccessLogsMessage_TCPAccessLogEntriesValidationError) Key() bool
Key function returns key value.
func (StreamAccessLogsMessage_TCPAccessLogEntriesValidationError) Reason ¶
func (e StreamAccessLogsMessage_TCPAccessLogEntriesValidationError) Reason() string
Reason function returns reason value.
type StreamAccessLogsMessage_TcpLogs ¶
type StreamAccessLogsMessage_TcpLogs struct {
TcpLogs *StreamAccessLogsMessage_TCPAccessLogEntries `protobuf:"bytes,3,opt,name=tcp_logs,json=tcpLogs,proto3,oneof"`
}
func (*StreamAccessLogsMessage_TcpLogs) MarshalTo ¶
func (m *StreamAccessLogsMessage_TcpLogs) MarshalTo(dAtA []byte) (int, error)
func (*StreamAccessLogsMessage_TcpLogs) Size ¶
func (m *StreamAccessLogsMessage_TcpLogs) Size() (n int)
type StreamAccessLogsResponse ¶
type StreamAccessLogsResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Empty response for the StreamAccessLogs API. Will never be sent. See below.
func (*StreamAccessLogsResponse) Descriptor ¶
func (*StreamAccessLogsResponse) Descriptor() ([]byte, []int)
func (*StreamAccessLogsResponse) Marshal ¶
func (m *StreamAccessLogsResponse) Marshal() (dAtA []byte, err error)
func (*StreamAccessLogsResponse) MarshalTo ¶
func (m *StreamAccessLogsResponse) MarshalTo(dAtA []byte) (int, error)
func (*StreamAccessLogsResponse) ProtoMessage ¶
func (*StreamAccessLogsResponse) ProtoMessage()
func (*StreamAccessLogsResponse) Reset ¶
func (m *StreamAccessLogsResponse) Reset()
func (*StreamAccessLogsResponse) Size ¶
func (m *StreamAccessLogsResponse) Size() (n int)
func (*StreamAccessLogsResponse) String ¶
func (m *StreamAccessLogsResponse) String() string
func (*StreamAccessLogsResponse) Unmarshal ¶
func (m *StreamAccessLogsResponse) Unmarshal(dAtA []byte) error
func (*StreamAccessLogsResponse) Validate ¶
func (m *StreamAccessLogsResponse) Validate() error
Validate checks the field values on StreamAccessLogsResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*StreamAccessLogsResponse) XXX_DiscardUnknown ¶
func (m *StreamAccessLogsResponse) XXX_DiscardUnknown()
func (*StreamAccessLogsResponse) XXX_Marshal ¶
func (m *StreamAccessLogsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamAccessLogsResponse) XXX_Merge ¶
func (m *StreamAccessLogsResponse) XXX_Merge(src proto.Message)
func (*StreamAccessLogsResponse) XXX_Size ¶
func (m *StreamAccessLogsResponse) XXX_Size() int
func (*StreamAccessLogsResponse) XXX_Unmarshal ¶
func (m *StreamAccessLogsResponse) XXX_Unmarshal(b []byte) error
type StreamAccessLogsResponseValidationError ¶
type StreamAccessLogsResponseValidationError struct {
// contains filtered or unexported fields
}
StreamAccessLogsResponseValidationError is the validation error returned by StreamAccessLogsResponse.Validate if the designated constraints aren't met.
func (StreamAccessLogsResponseValidationError) Cause ¶
func (e StreamAccessLogsResponseValidationError) Cause() error
Cause function returns cause value.
func (StreamAccessLogsResponseValidationError) Error ¶
func (e StreamAccessLogsResponseValidationError) Error() string
Error satisfies the builtin error interface
func (StreamAccessLogsResponseValidationError) ErrorName ¶ added in v0.7.0
func (e StreamAccessLogsResponseValidationError) ErrorName() string
ErrorName returns error name.
func (StreamAccessLogsResponseValidationError) Field ¶
func (e StreamAccessLogsResponseValidationError) Field() string
Field function returns field value.
func (StreamAccessLogsResponseValidationError) Key ¶
func (e StreamAccessLogsResponseValidationError) Key() bool
Key function returns key value.
func (StreamAccessLogsResponseValidationError) Reason ¶
func (e StreamAccessLogsResponseValidationError) Reason() string
Reason function returns reason value.