journal

Documentation

Index

• type Arguments
  • func (r *Arguments) SetToDefault()
• type Component
  • func New(o component.Options, args Arguments) (*Component, error)
  • func (c *Component) Run(ctx context.Context) error
  • func (c *Component) Update(args component.Arguments) error

Types

type Arguments

type Arguments struct {
	FormatAsJson bool                `river:"format_as_json,attr,optional"`
	MaxAge       time.Duration       `river:"max_age,attr,optional"`
	Path         string              `river:"path,attr,optional"`
	RelabelRules flow_relabel.Rules  `river:"relabel_rules,attr,optional"`
	Matches      string              `river:"matches,attr,optional"`
	Receivers    []loki.LogsReceiver `river:"forward_to,attr"`
	Labels       map[string]string   `river:"labels,attr,optional"`
}

Arguments are the arguments for the component.

func (*Arguments) SetToDefault

func (r *Arguments) SetToDefault()

SetToDefault implements river.Defaulter.

type Component

type Component struct {
}

Component represents reading from a journal

func New

func New(o component.Options, args Arguments) (*Component, error)

New creates a new component.

func (*Component) Run

func (c *Component) Run(ctx context.Context) error

Run starts the component.

func (*Component) Update

func (c *Component) Update(args component.Arguments) error

Update updates the fields of the component.