v2

package
v0.6.7 Latest Latest
Warning

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

Go to latest
Published: Jan 25, 2019 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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 (*StreamAccessLogsMessage) GetIdentifier

func (*StreamAccessLogsMessage) GetLogEntries

func (m *StreamAccessLogsMessage) GetLogEntries() isStreamAccessLogsMessage_LogEntries

func (*StreamAccessLogsMessage) GetTcpLogs

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 (dst *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 {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

StreamAccessLogsMessageValidationError is the validation error returned by StreamAccessLogsMessage.Validate if the designated constraints aren't met.

func (StreamAccessLogsMessageValidationError) Error

Error satisfies the builtin error interface

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

func (*StreamAccessLogsMessage_HTTPAccessLogEntries) Marshal

func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) Marshal() (dAtA []byte, err error)

func (*StreamAccessLogsMessage_HTTPAccessLogEntries) MarshalTo

func (*StreamAccessLogsMessage_HTTPAccessLogEntries) ProtoMessage

func (*StreamAccessLogsMessage_HTTPAccessLogEntries) Reset

func (*StreamAccessLogsMessage_HTTPAccessLogEntries) Size

func (*StreamAccessLogsMessage_HTTPAccessLogEntries) String

func (*StreamAccessLogsMessage_HTTPAccessLogEntries) Unmarshal

func (*StreamAccessLogsMessage_HTTPAccessLogEntries) Validate

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 (*StreamAccessLogsMessage_HTTPAccessLogEntries) XXX_Size

func (*StreamAccessLogsMessage_HTTPAccessLogEntries) XXX_Unmarshal

type StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError

type StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError struct {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError is the validation error returned by StreamAccessLogsMessage_HTTPAccessLogEntries.Validate if the designated constraints aren't met.

func (StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError) Error

Error satisfies the builtin error interface

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 (*StreamAccessLogsMessage_Identifier) GetNode

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 (*StreamAccessLogsMessage_Identifier) Size

func (*StreamAccessLogsMessage_Identifier) String

func (*StreamAccessLogsMessage_Identifier) Unmarshal

func (m *StreamAccessLogsMessage_Identifier) Unmarshal(dAtA []byte) error

func (*StreamAccessLogsMessage_Identifier) Validate

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 (dst *StreamAccessLogsMessage_Identifier) XXX_Merge(src proto.Message)

func (*StreamAccessLogsMessage_Identifier) XXX_Size

func (*StreamAccessLogsMessage_Identifier) XXX_Unmarshal

func (m *StreamAccessLogsMessage_Identifier) XXX_Unmarshal(b []byte) error

type StreamAccessLogsMessage_IdentifierValidationError

type StreamAccessLogsMessage_IdentifierValidationError struct {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

StreamAccessLogsMessage_IdentifierValidationError is the validation error returned by StreamAccessLogsMessage_Identifier.Validate if the designated constraints aren't met.

func (StreamAccessLogsMessage_IdentifierValidationError) Error

Error satisfies the builtin error interface

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

func (*StreamAccessLogsMessage_TCPAccessLogEntries) Marshal

func (m *StreamAccessLogsMessage_TCPAccessLogEntries) Marshal() (dAtA []byte, err error)

func (*StreamAccessLogsMessage_TCPAccessLogEntries) MarshalTo

func (*StreamAccessLogsMessage_TCPAccessLogEntries) ProtoMessage

func (*StreamAccessLogsMessage_TCPAccessLogEntries) Reset

func (*StreamAccessLogsMessage_TCPAccessLogEntries) Size

func (*StreamAccessLogsMessage_TCPAccessLogEntries) String

func (*StreamAccessLogsMessage_TCPAccessLogEntries) Unmarshal

func (*StreamAccessLogsMessage_TCPAccessLogEntries) Validate

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 (*StreamAccessLogsMessage_TCPAccessLogEntries) XXX_Size

func (*StreamAccessLogsMessage_TCPAccessLogEntries) XXX_Unmarshal

type StreamAccessLogsMessage_TCPAccessLogEntriesValidationError

type StreamAccessLogsMessage_TCPAccessLogEntriesValidationError struct {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

StreamAccessLogsMessage_TCPAccessLogEntriesValidationError is the validation error returned by StreamAccessLogsMessage_TCPAccessLogEntries.Validate if the designated constraints aren't met.

func (StreamAccessLogsMessage_TCPAccessLogEntriesValidationError) Error

Error satisfies the builtin error interface

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 (dst *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 {
	Field  string
	Reason string
	Cause  error
	Key    bool
}

StreamAccessLogsResponseValidationError is the validation error returned by StreamAccessLogsResponse.Validate if the designated constraints aren't met.

func (StreamAccessLogsResponseValidationError) Error

Error satisfies the builtin error interface

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL