logdriver

Documentation

Index

• Variables
• type LogEntry
  • func (*LogEntry) Descriptor() ([]byte, []int)
  • func (m *LogEntry) GetLine() []byte
  • func (m *LogEntry) GetPartial() bool
  • func (m *LogEntry) GetPartialLogMetadata() *PartialLogEntryMetadata
  • func (m *LogEntry) GetSource() string
  • func (m *LogEntry) GetTimeNano() int64
  • func (m *LogEntry) Marshal() (dAtA []byte, err error)
  • func (m *LogEntry) MarshalTo(dAtA []byte) (int, error)
  • func (m *LogEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*LogEntry) ProtoMessage()
  • func (m *LogEntry) Reset()
  • func (m *LogEntry) Size() (n int)
  • func (m *LogEntry) String() string
  • func (m *LogEntry) Unmarshal(dAtA []byte) error
  • func (m *LogEntry) XXX_DiscardUnknown()
  • func (m *LogEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *LogEntry) XXX_Merge(src proto.Message)
  • func (m *LogEntry) XXX_Size() int
  • func (m *LogEntry) XXX_Unmarshal(b []byte) error
• type LogEntryDecoder
  • func NewLogEntryDecoder(r io.Reader) LogEntryDecoder
• type LogEntryEncoder
  • func NewLogEntryEncoder(w io.Writer) LogEntryEncoder
• type PartialLogEntryMetadata
  • func (*PartialLogEntryMetadata) Descriptor() ([]byte, []int)
  • func (m *PartialLogEntryMetadata) GetId() string
  • func (m *PartialLogEntryMetadata) GetLast() bool
  • func (m *PartialLogEntryMetadata) GetOrdinal() int32
  • func (m *PartialLogEntryMetadata) Marshal() (dAtA []byte, err error)
  • func (m *PartialLogEntryMetadata) MarshalTo(dAtA []byte) (int, error)
  • func (m *PartialLogEntryMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*PartialLogEntryMetadata) ProtoMessage()
  • func (m *PartialLogEntryMetadata) Reset()
  • func (m *PartialLogEntryMetadata) Size() (n int)
  • func (m *PartialLogEntryMetadata) String() string
  • func (m *PartialLogEntryMetadata) Unmarshal(dAtA []byte) error
  • func (m *PartialLogEntryMetadata) XXX_DiscardUnknown()
  • func (m *PartialLogEntryMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PartialLogEntryMetadata) XXX_Merge(src proto.Message)
  • func (m *PartialLogEntryMetadata) XXX_Size() int
  • func (m *PartialLogEntryMetadata) XXX_Unmarshal(b []byte) error

Variables

var (
	ErrInvalidLengthEntry        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEntry          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEntry = fmt.Errorf("proto: unexpected end of group")
)

Types

type LogEntry

type LogEntry struct {
	Source             string                   `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	TimeNano           int64                    `protobuf:"varint,2,opt,name=time_nano,json=timeNano,proto3" json:"time_nano,omitempty"`
	Line               []byte                   `protobuf:"bytes,3,opt,name=line,proto3" json:"line,omitempty"`
	Partial            bool                     `protobuf:"varint,4,opt,name=partial,proto3" json:"partial,omitempty"`
	PartialLogMetadata *PartialLogEntryMetadata `protobuf:"bytes,5,opt,name=partial_log_metadata,json=partialLogMetadata,proto3" json:"partial_log_metadata,omitempty"`
}

func (*LogEntry) Descriptor

func (*LogEntry) Descriptor() ([]byte, []int)

func (*LogEntry) GetLine

func (m *LogEntry) GetLine() []byte

func (*LogEntry) GetPartial

func (m *LogEntry) GetPartial() bool

func (*LogEntry) GetPartialLogMetadata

func (m *LogEntry) GetPartialLogMetadata() *PartialLogEntryMetadata

func (*LogEntry) GetSource

func (m *LogEntry) GetSource() string

func (*LogEntry) GetTimeNano

func (m *LogEntry) GetTimeNano() int64

func (*LogEntry) Marshal

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

func (*LogEntry) MarshalTo

func (m *LogEntry) MarshalTo(dAtA []byte) (int, error)

func (*LogEntry) MarshalToSizedBuffer

func (m *LogEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LogEntry) ProtoMessage

func (*LogEntry) ProtoMessage()

func (*LogEntry) Reset

func (m *LogEntry) Reset()

func (*LogEntry) Size

func (m *LogEntry) Size() (n int)

func (*LogEntry) String

func (m *LogEntry) String() string

func (*LogEntry) Unmarshal

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

func (*LogEntry) XXX_DiscardUnknown

func (m *LogEntry) XXX_DiscardUnknown()

func (*LogEntry) XXX_Marshal

func (m *LogEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogEntry) XXX_Merge

func (m *LogEntry) XXX_Merge(src proto.Message)

func (*LogEntry) XXX_Size

func (m *LogEntry) XXX_Size() int

func (*LogEntry) XXX_Unmarshal

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

type LogEntryDecoder

type LogEntryDecoder interface {
	Decode(*LogEntry) error
}

LogEntryDecoder decodes log entries from a stream It is expected that the wire format is as defined by LogEntryEncoder.

func NewLogEntryDecoder

func NewLogEntryDecoder(r io.Reader) LogEntryDecoder

NewLogEntryDecoder creates a new stream decoder for log entries

type LogEntryEncoder

type LogEntryEncoder interface {
	Encode(*LogEntry) error
}

LogEntryEncoder encodes a LogEntry to a protobuf stream The stream should look like:

[uint32 binary encoded message size][protobuf message]

To decode an entry, read the first 4 bytes to get the size of the entry, then read `size` bytes from the stream.

func NewLogEntryEncoder

func NewLogEntryEncoder(w io.Writer) LogEntryEncoder

NewLogEntryEncoder creates a protobuf stream encoder for log entries. This is used to write out log entries to a stream.

type PartialLogEntryMetadata

type PartialLogEntryMetadata struct {
	Last    bool   `protobuf:"varint,1,opt,name=last,proto3" json:"last,omitempty"`
	Id      string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Ordinal int32  `protobuf:"varint,3,opt,name=ordinal,proto3" json:"ordinal,omitempty"`
}

func (*PartialLogEntryMetadata) Descriptor

func (*PartialLogEntryMetadata) Descriptor() ([]byte, []int)

func (*PartialLogEntryMetadata) GetId

func (m *PartialLogEntryMetadata) GetId() string

func (*PartialLogEntryMetadata) GetLast

func (m *PartialLogEntryMetadata) GetLast() bool

func (*PartialLogEntryMetadata) GetOrdinal

func (m *PartialLogEntryMetadata) GetOrdinal() int32

func (*PartialLogEntryMetadata) Marshal

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

func (*PartialLogEntryMetadata) MarshalTo

func (m *PartialLogEntryMetadata) MarshalTo(dAtA []byte) (int, error)

func (*PartialLogEntryMetadata) MarshalToSizedBuffer

func (m *PartialLogEntryMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PartialLogEntryMetadata) ProtoMessage

func (*PartialLogEntryMetadata) ProtoMessage()

func (*PartialLogEntryMetadata) Reset

func (m *PartialLogEntryMetadata) Reset()

func (*PartialLogEntryMetadata) Size

func (m *PartialLogEntryMetadata) Size() (n int)

func (*PartialLogEntryMetadata) String

func (m *PartialLogEntryMetadata) String() string

func (*PartialLogEntryMetadata) Unmarshal

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

func (*PartialLogEntryMetadata) XXX_DiscardUnknown

func (m *PartialLogEntryMetadata) XXX_DiscardUnknown()

func (*PartialLogEntryMetadata) XXX_Marshal

func (m *PartialLogEntryMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PartialLogEntryMetadata) XXX_Merge

func (m *PartialLogEntryMetadata) XXX_Merge(src proto.Message)

func (*PartialLogEntryMetadata) XXX_Size

func (m *PartialLogEntryMetadata) XXX_Size() int

func (*PartialLogEntryMetadata) XXX_Unmarshal

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