Back to

Package logdriver

v17.12.1-ce-rc2+incompatible (ce-rc2)
Latest Go to latest
Published: Mar 23, 2020 | License: Apache-2.0 | Module:


Package logdriver is a generated protocol buffer package.

It is generated from these files:


It has these top-level messages:



Package Files


var (
	ErrInvalidLengthEntry = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEntry   = fmt.Errorf("proto: integer overflow")

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"`

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

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.

Documentation was rendered with GOOS=linux and GOARCH=amd64.

Jump to identifier

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to identifier