Versions in this module Expand all Collapse all v0 v0.6.1 Oct 15, 2018 v0.6.0 Sep 25, 2018 v0.5.0 Aug 14, 2018 Changes in this version + var ErrIntOverflowAls = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthAls = fmt.Errorf("proto: negative length found during unmarshaling") + func RegisterAccessLogServiceServer(s *grpc.Server, srv AccessLogServiceServer) + type AccessLogServiceClient interface + StreamAccessLogs func(ctx context.Context, opts ...grpc.CallOption) (AccessLogService_StreamAccessLogsClient, error) + func NewAccessLogServiceClient(cc *grpc.ClientConn) AccessLogServiceClient + type AccessLogServiceServer interface + StreamAccessLogs func(AccessLogService_StreamAccessLogsServer) error + type AccessLogService_StreamAccessLogsClient interface + CloseAndRecv func() (*StreamAccessLogsResponse, error) + Send func(*StreamAccessLogsMessage) error + type AccessLogService_StreamAccessLogsServer interface + Recv func() (*StreamAccessLogsMessage, error) + SendAndClose func(*StreamAccessLogsResponse) error + type StreamAccessLogsMessage struct + Identifier *StreamAccessLogsMessage_Identifier + LogEntries isStreamAccessLogsMessage_LogEntries + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamAccessLogsMessage) Descriptor() ([]byte, []int) + func (*StreamAccessLogsMessage) ProtoMessage() + func (*StreamAccessLogsMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (dst *StreamAccessLogsMessage) XXX_Merge(src proto.Message) + 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 (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_Size() int + func (m *StreamAccessLogsMessage) XXX_Unmarshal(b []byte) error + type StreamAccessLogsMessageValidationError struct + Cause error + Field string + Key bool + Reason string + func (e StreamAccessLogsMessageValidationError) Error() string + type StreamAccessLogsMessage_HTTPAccessLogEntries struct + LogEntry []*v2.HTTPAccessLogEntry + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamAccessLogsMessage_HTTPAccessLogEntries) Descriptor() ([]byte, []int) + func (*StreamAccessLogsMessage_HTTPAccessLogEntries) ProtoMessage() + func (dst *StreamAccessLogsMessage_HTTPAccessLogEntries) XXX_Merge(src proto.Message) + 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 (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_Size() int + func (m *StreamAccessLogsMessage_HTTPAccessLogEntries) XXX_Unmarshal(b []byte) error + type StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError struct + Cause error + Field string + Key bool + Reason string + func (e StreamAccessLogsMessage_HTTPAccessLogEntriesValidationError) Error() string + type StreamAccessLogsMessage_HttpLogs struct + HttpLogs *StreamAccessLogsMessage_HTTPAccessLogEntries + func (m *StreamAccessLogsMessage_HttpLogs) MarshalTo(dAtA []byte) (int, error) + func (m *StreamAccessLogsMessage_HttpLogs) Size() (n int) + type StreamAccessLogsMessage_Identifier struct + LogName string + Node *core.Node + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamAccessLogsMessage_Identifier) Descriptor() ([]byte, []int) + func (*StreamAccessLogsMessage_Identifier) ProtoMessage() + func (dst *StreamAccessLogsMessage_Identifier) XXX_Merge(src proto.Message) + 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 (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_Size() int + func (m *StreamAccessLogsMessage_Identifier) XXX_Unmarshal(b []byte) error + type StreamAccessLogsMessage_IdentifierValidationError struct + Cause error + Field string + Key bool + Reason string + func (e StreamAccessLogsMessage_IdentifierValidationError) Error() string + type StreamAccessLogsMessage_TCPAccessLogEntries struct + LogEntry []*v2.TCPAccessLogEntry + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamAccessLogsMessage_TCPAccessLogEntries) Descriptor() ([]byte, []int) + func (*StreamAccessLogsMessage_TCPAccessLogEntries) ProtoMessage() + func (dst *StreamAccessLogsMessage_TCPAccessLogEntries) XXX_Merge(src proto.Message) + 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 (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_Size() int + func (m *StreamAccessLogsMessage_TCPAccessLogEntries) XXX_Unmarshal(b []byte) error + type StreamAccessLogsMessage_TCPAccessLogEntriesValidationError struct + Cause error + Field string + Key bool + Reason string + func (e StreamAccessLogsMessage_TCPAccessLogEntriesValidationError) Error() string + type StreamAccessLogsMessage_TcpLogs struct + TcpLogs *StreamAccessLogsMessage_TCPAccessLogEntries + func (m *StreamAccessLogsMessage_TcpLogs) MarshalTo(dAtA []byte) (int, error) + func (m *StreamAccessLogsMessage_TcpLogs) Size() (n int) + type StreamAccessLogsResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamAccessLogsResponse) Descriptor() ([]byte, []int) + func (*StreamAccessLogsResponse) ProtoMessage() + func (dst *StreamAccessLogsResponse) XXX_Merge(src proto.Message) + func (m *StreamAccessLogsResponse) Marshal() (dAtA []byte, err error) + func (m *StreamAccessLogsResponse) MarshalTo(dAtA []byte) (int, error) + 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_Size() int + func (m *StreamAccessLogsResponse) XXX_Unmarshal(b []byte) error + type StreamAccessLogsResponseValidationError struct + Cause error + Field string + Key bool + Reason string + func (e StreamAccessLogsResponseValidationError) Error() string