forwarder

type Config struct {
	// Source taps workload logs. Required.
	Source LogSource

	// Ingester is the batch sink. Required.
	Ingester Ingester

	// Outbox is the agent's system-event buffer. Optional; when nil the
	// event tap is disabled and only workload logs are forwarded.
	Outbox *outbox.Outbox

	// NodeID is stamped on every record. Required.
	NodeID string

	// Spool is the durable buffer for at-least-once delivery. When nil an
	// in-memory spool is used (records are lost on crash, but never block the
	// taps). Provide a disk-backed spool for production durability.
	Spool Spool

	// FlushInterval, BatchSize, PollInterval, OutboxDrain override the
	// package defaults when > 0.
	FlushInterval time.Duration
	BatchSize     int
	PollInterval  time.Duration
	OutboxDrain   int

	// Logger; defaults to the global logger with component "agent.forwarder".
	Logger log.Logger
}

type DiskSpool struct {
	*MemSpool
	// contains filtered or unexported fields
}

type Ingester interface {
	Ingest(ctx context.Context, records []observe.LogRecord) error
}

type LogSource interface {
	ListRunningInstances(ctx context.Context, namespace string) ([]*types.Instance, error)
	GetInstanceLogs(ctx context.Context, namespace, instanceID string, opts types.LogOptions) (io.ReadCloser, error)
}

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

type Spool interface {
	// Push enqueues a record. Must be non-blocking.
	Push(r observe.LogRecord)
	// Pop removes and returns up to max records (oldest first). Empty => nil.
	Pop(max int) []observe.LogRecord
	// Requeue returns a previously-popped batch to the front of the spool
	// (used after an ingest failure so records aren't dropped).
	Requeue(batch []observe.LogRecord)
	// Len reports the current depth.
	Len() int
}

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