accesslogv2

package
v1.36.2-20240416201304... Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: unknown License: Apache-2.0 Imports: 7 Imported by: 3

Documentation

Index

Constants

View Source 
const StreamAccessLogsMessage_HttpLogs_case case_StreamAccessLogsMessage_LogEntries = 2
View Source 
const StreamAccessLogsMessage_LogEntries_not_set_case case_StreamAccessLogsMessage_LogEntries = 0
View Source 
const StreamAccessLogsMessage_TcpLogs_case case_StreamAccessLogsMessage_LogEntries = 3

Variables

View Source 
var File_envoy_service_accesslog_v2_als_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

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"`
	// contains filtered or unexported fields
}

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) ClearHttpLogs 

func (x *StreamAccessLogsMessage) ClearHttpLogs()

func (*StreamAccessLogsMessage) ClearIdentifier 

func (x *StreamAccessLogsMessage) ClearIdentifier()

func (*StreamAccessLogsMessage) ClearLogEntries 

func (x *StreamAccessLogsMessage) ClearLogEntries()

func (*StreamAccessLogsMessage) ClearTcpLogs 

func (x *StreamAccessLogsMessage) ClearTcpLogs()

func (*StreamAccessLogsMessage) GetHttpLogs 

func (x *StreamAccessLogsMessage) GetHttpLogs() *StreamAccessLogsMessage_HTTPAccessLogEntries

func (*StreamAccessLogsMessage) GetIdentifier 

func (x *StreamAccessLogsMessage) GetIdentifier() *StreamAccessLogsMessage_Identifier

func (*StreamAccessLogsMessage) GetLogEntries 

func (x *StreamAccessLogsMessage) GetLogEntries() isStreamAccessLogsMessage_LogEntries

func (*StreamAccessLogsMessage) GetTcpLogs 

func (x *StreamAccessLogsMessage) GetTcpLogs() *StreamAccessLogsMessage_TCPAccessLogEntries

func (*StreamAccessLogsMessage) HasHttpLogs 

func (x *StreamAccessLogsMessage) HasHttpLogs() bool

func (*StreamAccessLogsMessage) HasIdentifier 

func (x *StreamAccessLogsMessage) HasIdentifier() bool

func (*StreamAccessLogsMessage) HasLogEntries 

func (x *StreamAccessLogsMessage) HasLogEntries() bool

func (*StreamAccessLogsMessage) HasTcpLogs 

func (x *StreamAccessLogsMessage) HasTcpLogs() bool

func (*StreamAccessLogsMessage) ProtoMessage 

func (*StreamAccessLogsMessage) ProtoMessage()

func (*StreamAccessLogsMessage) ProtoReflect 

func (x *StreamAccessLogsMessage) ProtoReflect() protoreflect.Message

func (*StreamAccessLogsMessage) Reset 

func (x *StreamAccessLogsMessage) Reset()

func (*StreamAccessLogsMessage) SetHttpLogs 

func (x *StreamAccessLogsMessage) SetHttpLogs(v *StreamAccessLogsMessage_HTTPAccessLogEntries)

func (*StreamAccessLogsMessage) SetIdentifier 

func (x *StreamAccessLogsMessage) SetIdentifier(v *StreamAccessLogsMessage_Identifier)

func (*StreamAccessLogsMessage) SetTcpLogs 

func (x *StreamAccessLogsMessage) SetTcpLogs(v *StreamAccessLogsMessage_TCPAccessLogEntries)

func (*StreamAccessLogsMessage) String 

func (x *StreamAccessLogsMessage) String() string

func (*StreamAccessLogsMessage) WhichLogEntries 

func (x *StreamAccessLogsMessage) WhichLogEntries() case_StreamAccessLogsMessage_LogEntries

type StreamAccessLogsMessage_HTTPAccessLogEntries 

type StreamAccessLogsMessage_HTTPAccessLogEntries struct {
	LogEntry []*v2.HTTPAccessLogEntry `protobuf:"bytes,1,rep,name=log_entry,json=logEntry,proto3" json:"log_entry,omitempty"`
	// contains filtered or unexported fields
}

Wrapper for batches of HTTP access log entries.

func (*StreamAccessLogsMessage_HTTPAccessLogEntries) GetLogEntry 

func (x *StreamAccessLogsMessage_HTTPAccessLogEntries) GetLogEntry() []*v2.HTTPAccessLogEntry

func (*StreamAccessLogsMessage_HTTPAccessLogEntries) ProtoMessage 

func (*StreamAccessLogsMessage_HTTPAccessLogEntries) ProtoMessage()

func (*StreamAccessLogsMessage_HTTPAccessLogEntries) ProtoReflect 

func (x *StreamAccessLogsMessage_HTTPAccessLogEntries) ProtoReflect() protoreflect.Message

func (*StreamAccessLogsMessage_HTTPAccessLogEntries) Reset 

func (x *StreamAccessLogsMessage_HTTPAccessLogEntries) Reset()

func (*StreamAccessLogsMessage_HTTPAccessLogEntries) SetLogEntry 

func (x *StreamAccessLogsMessage_HTTPAccessLogEntries) SetLogEntry(v []*v2.HTTPAccessLogEntry)

func (*StreamAccessLogsMessage_HTTPAccessLogEntries) String 

func (x *StreamAccessLogsMessage_HTTPAccessLogEntries) String() string

type StreamAccessLogsMessage_HTTPAccessLogEntries_builder 

type StreamAccessLogsMessage_HTTPAccessLogEntries_builder struct {
	LogEntry []*v2.HTTPAccessLogEntry
	// contains filtered or unexported fields
}

func (StreamAccessLogsMessage_HTTPAccessLogEntries_builder) Build 

func (b0 StreamAccessLogsMessage_HTTPAccessLogEntries_builder) Build() *StreamAccessLogsMessage_HTTPAccessLogEntries

type StreamAccessLogsMessage_HttpLogs 

type StreamAccessLogsMessage_HttpLogs struct {
	HttpLogs *StreamAccessLogsMessage_HTTPAccessLogEntries `protobuf:"bytes,2,opt,name=http_logs,json=httpLogs,proto3,oneof"`
}

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"`
	// contains filtered or unexported fields
}

func (*StreamAccessLogsMessage_Identifier) ClearNode 

func (x *StreamAccessLogsMessage_Identifier) ClearNode()

func (*StreamAccessLogsMessage_Identifier) GetLogName 

func (x *StreamAccessLogsMessage_Identifier) GetLogName() string

func (*StreamAccessLogsMessage_Identifier) GetNode 

func (x *StreamAccessLogsMessage_Identifier) GetNode() *core.Node

func (*StreamAccessLogsMessage_Identifier) HasNode 

func (x *StreamAccessLogsMessage_Identifier) HasNode() bool

func (*StreamAccessLogsMessage_Identifier) ProtoMessage 

func (*StreamAccessLogsMessage_Identifier) ProtoMessage()

func (*StreamAccessLogsMessage_Identifier) ProtoReflect 

func (x *StreamAccessLogsMessage_Identifier) ProtoReflect() protoreflect.Message

func (*StreamAccessLogsMessage_Identifier) Reset 

func (x *StreamAccessLogsMessage_Identifier) Reset()

func (*StreamAccessLogsMessage_Identifier) SetLogName 

func (x *StreamAccessLogsMessage_Identifier) SetLogName(v string)

func (*StreamAccessLogsMessage_Identifier) SetNode 

func (x *StreamAccessLogsMessage_Identifier) SetNode(v *core.Node)

func (*StreamAccessLogsMessage_Identifier) String 

func (x *StreamAccessLogsMessage_Identifier) String() string

type StreamAccessLogsMessage_Identifier_builder 

type StreamAccessLogsMessage_Identifier_builder struct {

	// The node sending the access log messages over the stream.
	Node *core.Node
	// The friendly name of the log configured in :ref:`CommonGrpcAccessLogConfig
	// <envoy_api_msg_config.accesslog.v2.CommonGrpcAccessLogConfig>`.
	LogName string
	// contains filtered or unexported fields
}

func (StreamAccessLogsMessage_Identifier_builder) Build 

func (b0 StreamAccessLogsMessage_Identifier_builder) Build() *StreamAccessLogsMessage_Identifier

type StreamAccessLogsMessage_TCPAccessLogEntries 

type StreamAccessLogsMessage_TCPAccessLogEntries struct {
	LogEntry []*v2.TCPAccessLogEntry `protobuf:"bytes,1,rep,name=log_entry,json=logEntry,proto3" json:"log_entry,omitempty"`
	// contains filtered or unexported fields
}

Wrapper for batches of TCP access log entries.

func (*StreamAccessLogsMessage_TCPAccessLogEntries) GetLogEntry 

func (x *StreamAccessLogsMessage_TCPAccessLogEntries) GetLogEntry() []*v2.TCPAccessLogEntry

func (*StreamAccessLogsMessage_TCPAccessLogEntries) ProtoMessage 

func (*StreamAccessLogsMessage_TCPAccessLogEntries) ProtoMessage()

func (*StreamAccessLogsMessage_TCPAccessLogEntries) ProtoReflect 

func (x *StreamAccessLogsMessage_TCPAccessLogEntries) ProtoReflect() protoreflect.Message

func (*StreamAccessLogsMessage_TCPAccessLogEntries) Reset 

func (x *StreamAccessLogsMessage_TCPAccessLogEntries) Reset()

func (*StreamAccessLogsMessage_TCPAccessLogEntries) SetLogEntry 

func (x *StreamAccessLogsMessage_TCPAccessLogEntries) SetLogEntry(v []*v2.TCPAccessLogEntry)

func (*StreamAccessLogsMessage_TCPAccessLogEntries) String 

func (x *StreamAccessLogsMessage_TCPAccessLogEntries) String() string

type StreamAccessLogsMessage_TCPAccessLogEntries_builder 

type StreamAccessLogsMessage_TCPAccessLogEntries_builder struct {
	LogEntry []*v2.TCPAccessLogEntry
	// contains filtered or unexported fields
}

func (StreamAccessLogsMessage_TCPAccessLogEntries_builder) Build 

func (b0 StreamAccessLogsMessage_TCPAccessLogEntries_builder) Build() *StreamAccessLogsMessage_TCPAccessLogEntries

type StreamAccessLogsMessage_TcpLogs 

type StreamAccessLogsMessage_TcpLogs struct {
	TcpLogs *StreamAccessLogsMessage_TCPAccessLogEntries `protobuf:"bytes,3,opt,name=tcp_logs,json=tcpLogs,proto3,oneof"`
}

type StreamAccessLogsMessage_builder 

type StreamAccessLogsMessage_builder 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

	// Fields of oneof LogEntries:
	HttpLogs *StreamAccessLogsMessage_HTTPAccessLogEntries
	TcpLogs  *StreamAccessLogsMessage_TCPAccessLogEntries
	// contains filtered or unexported fields
}

func (StreamAccessLogsMessage_builder) Build 

func (b0 StreamAccessLogsMessage_builder) Build() *StreamAccessLogsMessage

type StreamAccessLogsResponse 

type StreamAccessLogsResponse struct {
	// contains filtered or unexported fields
}

Empty response for the StreamAccessLogs API. Will never be sent. See below.

func (*StreamAccessLogsResponse) ProtoMessage 

func (*StreamAccessLogsResponse) ProtoMessage()

func (*StreamAccessLogsResponse) ProtoReflect 

func (x *StreamAccessLogsResponse) ProtoReflect() protoreflect.Message

func (*StreamAccessLogsResponse) Reset 

func (x *StreamAccessLogsResponse) Reset()

func (*StreamAccessLogsResponse) String 

func (x *StreamAccessLogsResponse) String() string

type StreamAccessLogsResponse_builder 

type StreamAccessLogsResponse_builder struct {
	// contains filtered or unexported fields
}

func (StreamAccessLogsResponse_builder) Build 

func (b0 StreamAccessLogsResponse_builder) Build() *StreamAccessLogsResponse

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.