Documentation
¶
Index ¶
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"
)
Variables ¶
This section is empty.
Functions ¶
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.
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.
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.
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.
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
Source Files