Versions in this module Expand all Collapse all v0 v0.9.0 Oct 20, 2021retracted Changes in this version + const SnmpTraps + const SnmpTrapsType + const StringChannelType + const UTF16BE + const UTF16LE + func AggregationTimeout() time.Duration + func ExpectedTagsDuration() time.Duration + func IsExpectedTagsSet() bool + type ChannelMessage struct + Content []byte + Lambda *Lambda + Timestamp time.Time + func NewChannelMessageFromLambda(content []byte, utcTime time.Time, ARN, reqID string) *ChannelMessage + type CountInfo struct + func NewCountInfo(key string) *CountInfo + func (c *CountInfo) Add(v int32) + func (c *CountInfo) Info() []string + func (c *CountInfo) InfoKey() string + type EPIntakeVersion uint8 + const EPIntakeVersion1 + const EPIntakeVersion2 type Endpoint + BackoffBase float64 + BackoffFactor float64 + BackoffMax float64 + Origin IntakeOrigin + Protocol IntakeProtocol + RecoveryInterval int + RecoveryReset bool + TrackType IntakeTrackType + Version EPIntakeVersion type Endpoints + BatchMaxConcurrentSend int + BatchMaxContentSize int + BatchMaxSize int + func BuildEndpointsWithConfig(logsConfig *LogsConfigKeys, endpointPrefix string, ...) (*Endpoints, error) + func BuildHTTPEndpointsWithConfig(logsConfig *LogsConfigKeys, endpointPrefix string, ...) (*Endpoints, error) + func BuildServerlessEndpoints(intakeTrackType IntakeTrackType, intakeProtocol IntakeProtocol) (*Endpoints, error) + func NewEndpointsWithBatchSettings(main Endpoint, additionals []Endpoint, useProto bool, useHTTP bool, ...) *Endpoints + type InfoProvider interface + Info func() []string + InfoKey func() string + type IntakeOrigin string + const DefaultIntakeOrigin + const ServerlessIntakeOrigin + type IntakeProtocol string + const DefaultIntakeProtocol + type IntakeTrackType string + type Lambda struct + ARN string + FunctionName string + RequestID string type LogSource + BytesRead expvar.Int + LatencyStats *util.StatsTracker + ParentSource *LogSource + func ContainerCollectAllSource() *LogSource + func SNMPTrapsSource() *LogSource + func (s *LogSource) GetInfo(key string) InfoProvider + func (s *LogSource) GetInfoStatus() map[string][]string + func (s *LogSource) HideFromStatus() + func (s *LogSource) IsHiddenFromStatus() bool + func (s *LogSource) RegisterInfo(i InfoProvider) type LogsConfig + AutoMultiLine bool + AutoMultiLineMatchThreshold float64 + AutoMultiLineSampleSize int + Channel chan *ChannelMessage + Encoding string + IdleTimeout string + type LogsConfigKeys struct + func NewLogsConfigKeys(configPrefix string, config coreConfig.Config) *LogsConfigKeys + type MappedInfo struct + func NewMappedInfo(key string) *MappedInfo + func (m *MappedInfo) Info() []string + func (m *MappedInfo) InfoKey() string + func (m *MappedInfo) RemoveMessage(key string) + func (m *MappedInfo) SetMessage(key string, message string) v0.8.0 Jul 23, 2020retracted Changes in this version + const Beginning + const ChanSize + const ContainerCollectAll + const DateFormat + const DockerType + const End + const ExcludeAtMatch + const FileType + const ForceBeginning + const ForceEnd + const IncludeAtMatch + const JournaldType + const MaskSequences + const MultiLine + const NumberOfPipelines + const TCPType + const UDPType + const WindowsEventType + func CompileProcessingRules(rules []*ProcessingRule) error + func ContainsWildcard(path string) bool + func TaggerWarmupDuration() time.Duration + func ValidateProcessingRules(rules []*ProcessingRule) error + type Endpoint struct + APIKey string + CompressionLevel int + ConnectionResetInterval time.Duration + Host string + Port int + ProxyAddress string + UseCompression bool + UseSSL bool + type Endpoints struct + Additionals []Endpoint + BatchWait time.Duration + Main Endpoint + UseHTTP bool + UseProto bool + func BuildEndpoints(httpConnectivity HTTPConnectivity) (*Endpoints, error) + func BuildHTTPEndpoints() (*Endpoints, error) + func NewEndpoints(main Endpoint, additionals []Endpoint, useProto bool, useHTTP bool, ...) *Endpoints + type HTTPConnectivity bool + var HTTPConnectivityFailure HTTPConnectivity = false + var HTTPConnectivitySuccess HTTPConnectivity = true + type LogSource struct + Config *LogsConfig + Messages *Messages + Name string + Status *LogStatus + func DefaultSources() []*LogSource + func NewLogSource(name string, config *LogsConfig) *LogSource + func (s *LogSource) AddInput(input string) + func (s *LogSource) GetInputs() []string + func (s *LogSource) GetSourceType() SourceType + func (s *LogSource) RemoveInput(input string) + func (s *LogSource) SetSourceType(sourceType SourceType) + type LogSources struct + func CreateSources(sourcesArray []*LogSource) *LogSources + func NewLogSources() *LogSources + func (s *LogSources) AddSource(source *LogSource) + func (s *LogSources) GetAddedForType(sourceType string) chan *LogSource + func (s *LogSources) GetRemovedForType(sourceType string) chan *LogSource + func (s *LogSources) GetSources() []*LogSource + func (s *LogSources) RemoveSource(source *LogSource) + type LogStatus struct + func NewLogStatus() *LogStatus + func (s *LogStatus) Error(err error) + func (s *LogStatus) GetError() string + func (s *LogStatus) IsError() bool + func (s *LogStatus) IsPending() bool + func (s *LogStatus) IsSuccess() bool + func (s *LogStatus) Success() + type LogsConfig struct + ChannelPath string + ContainerMode bool + ExcludePaths []string + ExcludeUnits []string + Identifier string + Image string + IncludeUnits []string + Label string + Name string + Path string + Port int + ProcessingRules []*ProcessingRule + Query string + Service string + Source string + SourceCategory string + Tags []string + TailingMode string + Type string + func ParseJSON(data []byte) ([]*LogsConfig, error) + func ParseYAML(data []byte) ([]*LogsConfig, error) + func (c *LogsConfig) Validate() error + type Messages struct + func NewMessages() *Messages + func (m *Messages) AddMessage(key string, message string) + func (m *Messages) GetMessages() []string + func (m *Messages) RemoveMessage(key string) + type ProcessingRule struct + Name string + Pattern string + Placeholder []byte + Regex *regexp.Regexp + ReplacePlaceholder string + Type string + func GlobalProcessingRules() ([]*ProcessingRule, error) + type SourceType string + const DockerSourceType + const KubernetesSourceType + type TailingMode uint8 + func TailingModeFromString(mode string) (TailingMode, bool) + func (mode TailingMode) String() string
Go to main page