config

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

type HTTPConnectivity bool

type InfoProvider interface {
	InfoKey() string
	Info() []string
}

type LogSource struct {
	// Put expvar Int first because it's modified with sync/atomic, so it needs to
	// be 64-bit aligned on 32-bit systems. See https://golang.org/pkg/sync/atomic/#pkg-note-BUG
	BytesRead expvar.Int

	Name   string
	Config *LogsConfig
	Status *LogStatus

	Messages *Messages

	// In the case that the source is overridden, keep a reference to the parent for bubbling up information about the child
	ParentSource *LogSource
	// LatencyStats tracks internal stats on the time spent by messages from this source in a processing pipeline, i.e.
	// the duration between when a message is decoded by the tailer/listener/decoder and when the message is handled by a sender
	LatencyStats *util.StatsTracker
	// contains filtered or unexported fields
}

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

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

type LogsConfig struct {
	Type          string   `yaml:"type"`
	Port          int      `yaml:"port"`          // Network
	Path          string   `yaml:"path"`          // File, Journald
	Encoding      string   `yaml:"encoding"`      // File
	ExcludePaths  []string `yaml:"excludePaths"`  // File
	TailingMode   string   `yaml:"startPosition"` // File
	IncludeUnits  []string `yaml:"includeUnits"`  // Journald
	ExcludeUnits  []string `yaml:"excludeUnits"`  // Journald
	ContainerMode bool     `yaml:"containerMode"` // Journald
	Image         string   `yaml:"image"`         // Docker
	Label         string   `yaml:"label"`         // Docker
	Name          string   `yaml:"name"`          // Docker Name contains the container name
	Identifier    string   `yaml:"identifier"`    // Docker Identifier contains the container ID
	ChannelPath   string   `yaml:"channelPath"`   // Windows Event
	Query         string   `yaml:"query"`         // Windows Event

	// used as input only by the Channel tailer.
	// could have been unidirectional but the tailer could not close it in this case.
	// TODO(remy): strongly typed to an AWS Lambda LogMessage, we should probably use
	// a more generic type here.
	Channel chan aws.LogMessage `yaml:"channel"`

	Service         string            `yaml:"service"`
	Source          string            `yaml:"source"`
	SourceCategory  string            `yaml:"sourceCategory"`
	Tags            []string          `yaml:"tags"`
	ProcessingRules []*ProcessingRule `yaml:"logProcessingRules"`
}

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

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

type SourceType string

type TailingMode uint8