sumoCFFirehose

package
v1.0.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 5, 2024 License: Apache-2.0 Imports: 13 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source
var MaxRetries = 10

MaxRetries is the maximum number of retries before bailing.

Functions

func FormatTimestamp

func FormatTimestamp(event *events.Event, timestamp string)

func IsMaxRetries

func IsMaxRetries(err error) bool

IsMaxRetries checks whether the error is due to hitting the maximum number of retries or not.

func ParseCustomInput

func ParseCustomInput(customInput string) map[string][]string

func Retry

func Retry(fn Func) error

Do keeps trying the function until the second argument returns false, or no error is returned.

func StringBuilder

func StringBuilder(event *events.Event, verboseLogMessages bool, includeOnlyMatchingFilter string, excludeAlwaysMatchingFilter string, customMetadata string) string

func WantedEvent

func WantedEvent(event string, includeOnlyMatchingFilter string, excludeAlwaysMatchingFilter string) bool

Types

type Func

type Func func(attempt int) (retry bool, err error)

Func represents functions that can be retried.

type SumoBuffer

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

type SumoLogicAppender

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

func NewSumoLogicAppender

func NewSumoLogicAppender(urlValue string, connectionTimeoutValue int, nozzleQueue *eventQueue.Queue, eventsBatchSize int, sumoPostMinimumDelay time.Duration, sumoCategory string, sumoName string, sumoHost string, verboseLogMessages bool, customMetadata string, includeOnlyMatchingFilter string, excludeAlwaysMatchingFilter string, nozzleVersion string) *SumoLogicAppender

func (*SumoLogicAppender) AppendLogs

func (s *SumoLogicAppender) AppendLogs(buffer *SumoBuffer)

func (*SumoLogicAppender) SendToSumo

func (s *SumoLogicAppender) SendToSumo(logStringToSend string, url string, isMetric bool)

func (*SumoLogicAppender) Start

func (s *SumoLogicAppender) Start()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL