journal

Documentation

Index

• type JournalTarget
  • func NewJournalTarget(logger log.Logger, handler api.EntryHandler, positions positions.Positions, ...) (*JournalTarget, error)
  • func (t *JournalTarget) Details() interface{}
  • func (t *JournalTarget) DiscoveredLabels() model.LabelSet
  • func (t *JournalTarget) Labels() model.LabelSet
  • func (t *JournalTarget) Ready() bool
  • func (t *JournalTarget) Stop() error
  • func (t *JournalTarget) Type() target.TargetType
• type JournalTargetManager
  • func NewJournalTargetManager(logger log.Logger, positions positions.Positions, client api.EntryHandler, ...) (*JournalTargetManager, error)
  • func (tm *JournalTargetManager) ActiveTargets() map[string][]target.Target
  • func (tm *JournalTargetManager) AllTargets() map[string][]target.Target
  • func (tm *JournalTargetManager) Ready() bool
  • func (tm *JournalTargetManager) Stop()

Types

type JournalTarget

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

JournalTarget tails systemd journal entries.

func NewJournalTarget

func NewJournalTarget(
	logger log.Logger,
	handler api.EntryHandler,
	positions positions.Positions,
	jobName string,
	relabelConfig []*relabel.Config,
	targetConfig *scrapeconfig.JournalTargetConfig,
) (*JournalTarget, error)

NewJournalTarget configures a new JournalTarget.

func (*JournalTarget) Details

func (t *JournalTarget) Details() interface{}

Details returns target-specific details.

func (*JournalTarget) DiscoveredLabels

func (t *JournalTarget) DiscoveredLabels() model.LabelSet

DiscoveredLabels returns the set of labels discovered by the JournalTarget, which is always nil. Implements Target.

func (*JournalTarget) Labels

func (t *JournalTarget) Labels() model.LabelSet

Labels returns the set of labels that statically apply to all log entries produced by the JournalTarget.

func (*JournalTarget) Ready

func (t *JournalTarget) Ready() bool

Ready indicates whether or not the journal is ready to be read from.

func (*JournalTarget) Stop

func (t *JournalTarget) Stop() error

Stop shuts down the JournalTarget.

func (*JournalTarget) Type

func (t *JournalTarget) Type() target.TargetType

Type returns JournalTargetType.

type JournalTargetManager

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

JournalTargetManager manages a series of JournalTargets.

func NewJournalTargetManager

func NewJournalTargetManager(
	logger log.Logger,
	positions positions.Positions,
	client api.EntryHandler,
	scrapeConfigs []scrapeconfig.Config,
) (*JournalTargetManager, error)

NewJournalTargetManager creates a new JournalTargetManager.

func (*JournalTargetManager) ActiveTargets

func (tm *JournalTargetManager) ActiveTargets() map[string][]target.Target

ActiveTargets returns the list of JournalTargets where journal data is being read. ActiveTargets is an alias to AllTargets as JournalTargets cannot be deactivated, only stopped.

func (*JournalTargetManager) AllTargets

func (tm *JournalTargetManager) AllTargets() map[string][]target.Target

AllTargets returns the list of all targets where journal data is currently being read.

func (*JournalTargetManager) Ready

func (tm *JournalTargetManager) Ready() bool

Ready returns true if at least one JournalTarget is also ready.

func (*JournalTargetManager) Stop

func (tm *JournalTargetManager) Stop()

Stop stops the JournalTargetManager and all of its JournalTargets.