Versions in this module Expand all Collapse all v0 v0.6.3 Nov 12, 2018 v0.6.2 Nov 6, 2018 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