targets

Documentation

Index

• Constants
• func IsDropped(t Target) bool
• type Config
  • func (cfg *Config) RegisterFlags(flags *flag.FlagSet)
• type FileTarget
  • func NewFileTarget(logger log.Logger, handler api.EntryHandler, positions *positions.Positions, ...) (*FileTarget, error)
  • func (t *FileTarget) Details() interface{}
  • func (t *FileTarget) Ready() bool
  • func (t *FileTarget) Stop()
  • func (t *FileTarget) Type() TargetType
• type FileTargetManager
  • func NewFileTargetManager(logger log.Logger, positions *positions.Positions, client api.EntryHandler, ...) (*FileTargetManager, error)
  • func (tm *FileTargetManager) ActiveTargets() map[string][]Target
  • func (tm *FileTargetManager) AllTargets() map[string][]Target
  • func (tm *FileTargetManager) Ready() bool
  • func (tm *FileTargetManager) Stop()
• type JournalTarget
  • func NewJournalTarget(logger log.Logger, handler api.EntryHandler, positions *positions.Positions, ...) (*JournalTarget, error)
  • func (t *JournalTarget) Details() interface{}
  • func (t *JournalTarget) Ready() bool
  • func (t *JournalTarget) Stop() error
  • func (t *JournalTarget) Type() TargetType
• type JournalTargetManager
  • func NewJournalTargetManager(logger log.Logger, positions *positions.Positions, client api.EntryHandler, ...) (*JournalTargetManager, error)
  • func (tm *JournalTargetManager) ActiveTargets() map[string][]Target
  • func (tm *JournalTargetManager) AllTargets() map[string][]Target
  • func (tm *JournalTargetManager) Ready() bool
  • func (tm *JournalTargetManager) Stop()
• type Target
• type TargetManagers
  • func NewTargetManagers(logger log.Logger, positions *positions.Positions, client api.EntryHandler, ...) (*TargetManagers, error)
  • func (tm *TargetManagers) ActiveTargets() map[string][]Target
  • func (tm *TargetManagers) AllTargets() map[string][]Target
  • func (tm *TargetManagers) Ready() bool
  • func (tm *TargetManagers) Stop()
• type TargetType

Constants

const (
	// FileTargetType is a file target
	FileTargetType = TargetType("File")

	// JournalTargetType is a journalctl target
	JournalTargetType = TargetType("Journal")

	// DroppedTargetType is a target that's been dropped.
	DroppedTargetType = TargetType("dropped")
)

const (
	FilenameLabel = "filename"
)

Functions

func IsDropped

func IsDropped(t Target) bool

IsDropped tells if a target has been dropped

Types

type Config

type Config struct {
	SyncPeriod time.Duration `yaml:"sync_period"`
}

Config describes behavior for Target

func (*Config) RegisterFlags

func (cfg *Config) RegisterFlags(flags *flag.FlagSet)

RegisterFlags register flags.

type FileTarget

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

FileTarget describes a particular set of logs.

func NewFileTarget

func NewFileTarget(logger log.Logger, handler api.EntryHandler, positions *positions.Positions, path string, labels model.LabelSet, discoveredLabels model.LabelSet, targetConfig *Config) (*FileTarget, error)

NewFileTarget create a new FileTarget.

func (*FileTarget) Details

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

Details implements a Target

func (*FileTarget) Ready

func (t *FileTarget) Ready() bool

Ready if at least one file is being tailed

func (*FileTarget) Stop

func (t *FileTarget) Stop()

Stop the target.

func (*FileTarget) Type

func (t *FileTarget) Type() TargetType

Type implements a Target

type FileTargetManager

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

FileTargetManager manages a set of targets.

func NewFileTargetManager

func NewFileTargetManager(
	logger log.Logger,
	positions *positions.Positions,
	client api.EntryHandler,
	scrapeConfigs []scrape.Config,
	targetConfig *Config,
) (*FileTargetManager, error)

NewFileTargetManager creates a new TargetManager.

func (*FileTargetManager) ActiveTargets

func (tm *FileTargetManager) ActiveTargets() map[string][]Target

ActiveTargets returns the active targets currently being scraped.

func (*FileTargetManager) AllTargets

func (tm *FileTargetManager) AllTargets() map[string][]Target

AllTargets returns all targets, active and dropped.

func (*FileTargetManager) Ready

func (tm *FileTargetManager) Ready() bool

Ready if there's at least one file target

func (*FileTargetManager) Stop

func (tm *FileTargetManager) Stop()

Stop the TargetManager.

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 *scrape.JournalTargetConfig,
) (*JournalTarget, error)

NewJournalTarget configures a new JournalTarget.

func (*JournalTarget) Details

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

Details returns target-specific details (currently nil).

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() 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 []scrape.Config,
) (*JournalTargetManager, error)

NewJournalTargetManager creates a new JournalTargetManager.

func (*JournalTargetManager) ActiveTargets

func (tm *JournalTargetManager) ActiveTargets() map[string][]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

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.

type Target

type Target interface {
	// Type of the target
	Type() TargetType
	// Ready tells if the targets is ready
	Ready() bool
	// Details is additional information about this target specific to its type
	Details() interface{}
}

Target is a promtail scrape target

type TargetManagers

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

TargetManagers manages a list of target managers.

func NewTargetManagers

func NewTargetManagers(
	logger log.Logger,
	positions *positions.Positions,
	client api.EntryHandler,
	scrapeConfigs []scrape.Config,
	targetConfig *Config,
) (*TargetManagers, error)

NewTargetManagers makes a new TargetManagers

func (*TargetManagers) ActiveTargets

func (tm *TargetManagers) ActiveTargets() map[string][]Target

ActiveTargets returns active targets per jobs

func (*TargetManagers) AllTargets

func (tm *TargetManagers) AllTargets() map[string][]Target

AllTargets returns all targets per jobs

func (*TargetManagers) Ready

func (tm *TargetManagers) Ready() bool

Ready if there's at least one ready target manager.

func (*TargetManagers) Stop

func (tm *TargetManagers) Stop()

Stop the TargetManagers.

type TargetType

type TargetType string

TargetType is the type of target