Versions in this module Expand all Collapse all v1 v1.0.0 Mar 10, 2021 Changes in this version + func NewFactory() component.ReceiverFactory + type AckResponse struct + Ack string + func (z AckResponse) EncodeMsg(en *msgp.Writer) error + type Collector struct + func (c *Collector) Start(ctx context.Context) + type Config struct + ListenAddress string + type Event interface + Chunk func() string + Compressed func() string + DecodeMsg func(dc *msgp.Reader) error + LogRecords func() pdata.LogSlice + type EventMode int + const ForwardMode + const MessageMode + const PackedForwardMode + const UnknownMode + func DetermineNextEventMode(peeker Peeker) (EventMode, error) + func (em EventMode) String() string + type EventTimeExt time.Time + func (*EventTimeExt) ExtensionType() int8 + func (e *EventTimeExt) Len() int + func (e *EventTimeExt) MarshalBinaryTo(b []byte) error + func (e *EventTimeExt) UnmarshalBinary(b []byte) error + type ForwardEventLogRecords struct + func (fe *ForwardEventLogRecords) DecodeMsg(dc *msgp.Reader) (err error) + func (fe *ForwardEventLogRecords) LogRecords() pdata.LogSlice + type MessageEventLogRecord struct + func (melr *MessageEventLogRecord) DecodeMsg(dc *msgp.Reader) error + func (melr *MessageEventLogRecord) LogRecords() pdata.LogSlice + type OptionsMap map[string]interface + func (om OptionsMap) Chunk() string + func (om OptionsMap) Compressed() string + type PackedForwardEventLogRecords struct + func (pfe *PackedForwardEventLogRecords) DecodeMsg(dc *msgp.Reader) error + func (pfe *PackedForwardEventLogRecords) LogRecords() pdata.LogSlice + type Peeker interface + Peek func(n int) ([]byte, error)