dockerlog

Documentation

Overview

Package dockerlog provides Docker container log parser.

Index

• func ParseLog(f io.ReadCloser, resource otelstorage.Attrs) logqlengine.EntryIterator
• type InputNode
  • func (n *InputNode) EvalPipeline(ctx context.Context, params logqlengine.EvalParams) (_ logqlengine.EntryIterator, rerr error)
  • func (n *InputNode) Traverse(cb logqlengine.NodeVisitor) error
• type Querier
  • func NewQuerier(c client.APIClient) (*Querier, error)
  • func (q *Querier) Capabilities() (caps logqlengine.QuerierCapabilities)
  • func (q *Querier) Query(ctx context.Context, labels []logql.LabelMatcher) (logqlengine.PipelineNode, error)

Functions

func ParseLog

func ParseLog(f io.ReadCloser, resource otelstorage.Attrs) logqlengine.EntryIterator

ParseLog parses log stream from Docker daemon.

Types

type InputNode

type InputNode struct {
	Lables []logql.LabelMatcher
	// contains filtered or unexported fields
}

InputNode is an input for LogQL pipeline using Docker API.

func (*InputNode) EvalPipeline

func (n *InputNode) EvalPipeline(ctx context.Context, params logqlengine.EvalParams) (_ logqlengine.EntryIterator, rerr error)

EvalPipeline implements logqlengine.PipelineNode.

func (*InputNode) Traverse

func (n *InputNode) Traverse(cb logqlengine.NodeVisitor) error

Traverse implements logqlengine.Node.

type Querier

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

Querier implements LogQL querier.

func NewQuerier

func NewQuerier(c client.APIClient) (*Querier, error)

NewQuerier creates new Querier.

func (*Querier) Capabilities

func (q *Querier) Capabilities() (caps logqlengine.QuerierCapabilities)

Capabilities returns Querier capabilities. NOTE: engine would call once and then save value.

Capabilities should not change over time.

func (*Querier) Query

func (q *Querier) Query(ctx context.Context, labels []logql.LabelMatcher) (logqlengine.PipelineNode, error)

Query creates new InputNode.