logs

type ChannelMessage struct {
	Content []byte
	// Optional. Must be UTC. If not provided, time.Now().UTC() will be used
	// Used in the Serverless Agent
	Timestamp time.Time
	// Optional.
	// Used in the Serverless Agent
	Lambda *Lambda
}

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

type EPIntakeVersion uint8

type Endpoint struct {
	APIKey                  string `mapstructure:"api_key" json:"api_key"`
	Addr                    string
	Topic                   string
	Host                    string
	Port                    int
	UseSSL                  bool
	UseCompression          bool `mapstructure:"use_compression" json:"use_compression"`
	CompressionLevel        int  `mapstructure:"compression_level" json:"compression_level"`
	ProxyAddress            string
	ConnectionResetInterval time.Duration

	BackoffFactor    float64
	BackoffBase      float64
	BackoffMax       float64
	RecoveryInterval int
	RecoveryReset    bool

	Version   EPIntakeVersion
	TrackType IntakeTrackType
	Protocol  IntakeProtocol
	Origin    IntakeOrigin
}

type Endpoints struct {
	Main                   Endpoint
	Additionals            []Endpoint
	UseProto               bool
	Type                   string
	BatchWait              time.Duration
	BatchMaxConcurrentSend int
	BatchMaxSize           int
	BatchMaxContentSize    int
}

type HTTPConnectivity bool

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

type IntakeOrigin string

type IntakeProtocol string

type IntakeTrackType string

type Lambda struct {
	ARN          string
	RequestID    string
	FunctionName 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 *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

	Port        int    // Network
	IdleTimeout string `mapstructure:"idle_timeout" json:"idle_timeout" toml:"idle_timeout"` // Network
	Path        string // File, Journald
	Topic       string `mapstructure:"topic" json:"topic" toml:"topic"`

	Encoding     string   `mapstructure:"encoding" json:"encoding" toml:"encoding"`                   // File
	ExcludePaths []string `mapstructure:"exclude_paths" json:"exclude_paths" toml:"exclude_paths"`    // File
	TailingMode  string   `mapstructure:"start_position" json:"start_position" toml:"start_position"` // File

	IncludeUnits  []string `mapstructure:"include_units" json:"include_units" toml:"include_units"`    // Journald
	ExcludeUnits  []string `mapstructure:"exclude_units" json:"exclude_units" toml:"exclude_units"`    // Journald
	ContainerMode bool     `mapstructure:"container_mode" json:"container_mode" toml:"container_mode"` // Journald

	Image string // Docker
	Label string // Docker
	// Name contains the container name
	Name string // Docker
	// Identifier contains the container ID
	Identifier string // Docker

	ChannelPath string `mapstructure:"channel_path" json:"channel_path" toml:"channel_path"` // Windows Event
	Query       string // Windows Event

	// used as input only by the Channel tailer.
	// could have been unidirectional but the tailer could not close it in this case.
	Channel chan *ChannelMessage `json:"-"`

	Service         string
	Source          string
	SourceCategory  string
	Tags            []string
	ProcessingRules []*ProcessingRule `mapstructure:"log_processing_rules" json:"log_processing_rules" toml:"log_processing_rules"`

	AutoMultiLine               bool    `mapstructure:"auto_multi_line_detection" json:"auto_multi_line_detection" toml:"auto_multi_line_detectio"`
	AutoMultiLineSampleSize     int     `mapstructure:"auto_multi_line_sample_size" json:"auto_multi_line_sample_size" toml:"auto_multi_line_sample_size"`
	AutoMultiLineMatchThreshold float64 `mapstructure:"auto_multi_line_match_threshold" json:"auto_multi_line_match_threshold" toml:"auto_multi_line_match_threshold"`
}

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

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

type ProcessingRule struct {
	Type               string `mapstructure:"type" json:"type" toml:"type"`
	Name               string `mapstructure:"name" json:"name" toml:"name"`
	ReplacePlaceholder string `mapstructure:"replace_placeholder" json:"replace_placeholder" toml:"replace_placeholder"`
	Pattern            string `mapstructure:"pattern" json:"pattern" toml:"pattern"`
	// TODO: should be moved out
	Regex       *regexp.Regexp
	Placeholder []byte
}

type SourceType string

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

type TailingMode uint8