logsource

type DockerClient interface {
	io.Closer
	ContainerLogs(context.Context, string, container.LogsOptions) (io.ReadCloser, error)
}

type DockerLogSource struct {
	LogSourceDefaults
	// contains filtered or unexported fields
}

type FileLogSource struct {
	LogSourceDefaults
	// contains filtered or unexported fields
}

type KubernetesLogSource struct {
	LogSourceDefaults
	// contains filtered or unexported fields
}

type LogSource interface {
	// Path returns a representation of the log location.
	Path() string

	// Read returns the next log line. Returns `io.EOF` at the end of
	// the log.
	Read(context.Context) (string, error)

	ConstLabels() prometheus.Labels
	RemoteAddr() string
	// contains filtered or unexported methods
}

type LogSourceCloser interface {
	io.Closer
	LogSource
}

type LogSourceDefaults struct{}

type LogSourceFactory interface {
	// Init adds the factory's struct fields as flags in the
	// application.
	Init(*kingpin.Application)

	// New attempts to create a new log source. This is called after
	// flags have been parsed. Returning `nil, nil`, means the user
	// didn't want this log source.
	New(context.Context) ([]LogSourceCloser, error)

	// Watchdog indicates whether this log source is unhealthy.
	Watchdog(context.Context) bool
	// contains filtered or unexported methods
}

type LogSourceFactoryDefaults struct{}

type SystemdJournal interface {
	io.Closer
	AddMatch(match string) error
	GetEntry() (*sdjournal.JournalEntry, error)
	Next() (uint64, error)
	SeekTail() error
	PreviousSkip(skip uint64) (uint64, error)
	Wait(timeout time.Duration) int
}

type SystemdLogSource struct {
	LogSourceDefaults
	// contains filtered or unexported fields
}