logdriver

package

v28.5.2+incompatibleLatest Latest

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

Go to latest Published: Nov 5, 2025 License:Apache-2.0Imports:6Imported by:0

Details

Valid go.mod file

Redistributable license

Tagged version

Stable version

Learn more about best practices

Repository

github.com/moby/moby

Documentation ¶

Index¶

Constants¶

This section is empty.

Variables¶

View Source

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

Functions¶

This section is empty.

Types¶

typeLogEntry ¶

type LogEntry struct {Sourcestring                   `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`TimeNanoint64                    `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"`Partialbool                     `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, errerror)

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

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, deterministicbool) ([]byte,error)

func (*LogEntry)XXX_Merge ¶

func (m *LogEntry) XXX_Merge(srcproto.Message)

func (*LogEntry)XXX_Size ¶

func (m *LogEntry) XXX_Size()int

func (*LogEntry)XXX_Unmarshal ¶

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

typeLogEntryDecoder ¶

type LogEntryDecoder interface {Decode(*LogEntry)error}

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

funcNewLogEntryDecoder ¶

func NewLogEntryDecoder(rio.Reader)LogEntryDecoder

NewLogEntryDecoder creates a new stream decoder for log entries

typeLogEntryEncoder ¶

type LogEntryEncoder interface {Encode(*LogEntry)error}

LogEntryEncoder encodes a LogEntry to a protobuf streamThe 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.

funcNewLogEntryEncoder ¶

func NewLogEntryEncoder(wio.Writer)LogEntryEncoder

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

typePartialLogEntryMetadata ¶

type PartialLogEntryMetadata struct {Lastbool   `protobuf:"varint,1,opt,name=last,proto3" json:"last,omitempty"`Idstring `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`Ordinalint32  `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, errerror)

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

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, deterministicbool) ([]byte,error)

func (*PartialLogEntryMetadata)XXX_Merge ¶

func (m *PartialLogEntryMetadata) XXX_Merge(srcproto.Message)

func (*PartialLogEntryMetadata)XXX_Size ¶

func (m *PartialLogEntryMetadata) XXX_Size()int

func (*PartialLogEntryMetadata)XXX_Unmarshal ¶

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

Source Files¶

View all Source files

?	: This menu
/	: Search site
f orF	: Jump to
y orY	: Canonical URL

Movatterモバイル変換

Details

Repository

Links

Documentation¶

Index¶

Constants¶

Variables¶

Functions¶

Types¶

typeLogEntry¶

func (*LogEntry)Descriptor¶

func (*LogEntry)GetLine¶

func (*LogEntry)GetPartial¶

func (*LogEntry)GetPartialLogMetadata¶

func (*LogEntry)GetSource¶

func (*LogEntry)GetTimeNano¶

func (*LogEntry)Marshal¶

func (*LogEntry)MarshalTo¶

func (*LogEntry)MarshalToSizedBuffer¶

func (*LogEntry)ProtoMessage¶

func (*LogEntry)Reset¶

func (*LogEntry)Size¶

func (*LogEntry)String¶

func (*LogEntry)Unmarshal¶

func (*LogEntry)XXX_DiscardUnknown¶

func (*LogEntry)XXX_Marshal¶

func (*LogEntry)XXX_Merge¶

func (*LogEntry)XXX_Size¶

func (*LogEntry)XXX_Unmarshal¶

typeLogEntryDecoder¶

funcNewLogEntryDecoder¶

typeLogEntryEncoder¶

funcNewLogEntryEncoder¶

typePartialLogEntryMetadata¶

func (*PartialLogEntryMetadata)Descriptor¶

func (*PartialLogEntryMetadata)GetId¶

func (*PartialLogEntryMetadata)GetLast¶

func (*PartialLogEntryMetadata)GetOrdinal¶

func (*PartialLogEntryMetadata)Marshal¶

func (*PartialLogEntryMetadata)MarshalTo¶

func (*PartialLogEntryMetadata)MarshalToSizedBuffer¶

func (*PartialLogEntryMetadata)ProtoMessage¶

func (*PartialLogEntryMetadata)Reset¶

func (*PartialLogEntryMetadata)Size¶

func (*PartialLogEntryMetadata)String¶

func (*PartialLogEntryMetadata)Unmarshal¶

func (*PartialLogEntryMetadata)XXX_DiscardUnknown¶

func (*PartialLogEntryMetadata)XXX_Marshal¶

func (*PartialLogEntryMetadata)XXX_Merge¶

func (*PartialLogEntryMetadata)XXX_Size¶

func (*PartialLogEntryMetadata)XXX_Unmarshal¶