adapter

package

v0.154.0 Latest Latest Go to latest Published: Jun 9, 2026 License: Apache-2.0 Imports: 55 Imported by: 35

Documentation ¶

Index ¶

func ConvertEntries(entries []*entry.Entry) plog.Logs
func GetStorageClient(ctx context.Context, host component.Host, storageID *component.ID, ...) (storage.Client, error)
func HashResource(resource map[string]any) uint64
func NewFactory(logReceiverType LogReceiverType, sl component.StabilityLevel, ...) rcvr.Factory
type BaseConfig
type FromPdataConverter
- func NewFromPdataConverter(set component.TelemetrySettings, workerCount int) *FromPdataConverter
type LogReceiverType

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ConvertEntries ¶ added in v0.114.0

func ConvertEntries(entries []*entry.Entry) plog.Logs

func GetStorageClient ¶

func GetStorageClient(ctx context.Context, host component.Host, storageID *component.ID, componentID component.ID) (storage.Client, error)

func HashResource ¶

func HashResource(resource map[string]any) uint64

HashResource will hash an entry.Entry.Resource

func NewFactory ¶

func NewFactory(logReceiverType LogReceiverType, sl component.StabilityLevel, opts ...xrcvr.FactoryOption) rcvr.Factory

NewFactory creates a factory for a Stanza-based receiver

Types ¶

type BaseConfig ¶

type BaseConfig struct {
	Operators      []operator.Config    `mapstructure:"operators"`
	StorageID      *component.ID        `mapstructure:"storage"`
	RetryOnFailure consumerretry.Config `mapstructure:"retry_on_failure"`
	// contains filtered or unexported fields
}

BaseConfig is the common configuration of a stanza-based receiver

type FromPdataConverter ¶

type FromPdataConverter struct {
	// contains filtered or unexported fields
}

FromPdataConverter converts plog.Logs into a set of entry.Entry

The diagram below illustrates the internal communication inside the FromPdataConverter:

          ┌─────────────────────────────────┐
          │ Batch()                         │
┌─────────┤  Ingests plog.Logs, splits up   │
│         │  and places them on workerChan  │
│         └─────────────────────────────────┘
│
│ ┌───────────────────────────────────────────────────┐
├─► workerLoop()                                      │
│ │ ┌─────────────────────────────────────────────────┴─┐
├─┼─► workerLoop()                                      │
│ │ │ ┌─────────────────────────────────────────────────┴─┐
└─┼─┼─► workerLoop()                                      │
  └─┤ │   consumes sent log entries from workerChan,      │
    │ │   translates received logs to entry.Entry,        │
    └─┤   and sends them along entriesChan                │
      └───────────────────────────────────────────────────┘

func NewFromPdataConverter ¶

func NewFromPdataConverter(set component.TelemetrySettings, workerCount int) *FromPdataConverter

func (*FromPdataConverter) Batch ¶

func (c *FromPdataConverter) Batch(pLogs plog.Logs) error

Batch takes in an set of plog.Logs and sends it to an available worker for processing.

func (*FromPdataConverter) OutChannel ¶

func (c *FromPdataConverter) OutChannel() <-chan []*entry.Entry

OutChannel returns the channel on which converted entries will be sent to.

func (*FromPdataConverter) Start ¶

func (c *FromPdataConverter) Start()

func (*FromPdataConverter) Stop ¶

func (c *FromPdataConverter) Stop()

type LogReceiverType ¶

type LogReceiverType interface {
	Type() component.Type
	CreateDefaultConfig() component.Config
	BaseConfig(component.Config) BaseConfig
	InputConfig(component.Config) operator.Config
}

LogReceiverType is the interface used by stanza-based log receivers

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL