sumoCFFirehose

Documentation

Index

• Variables
• func FormatTimestamp(event *events.Event, timestamp string)
• func IsMaxRetries(err error) bool
• func ParseCustomInput(customInput string) map[string][]string
• func Retry(fn Func) error
• func StringBuilder(event *events.Event, verboseLogMessages bool, includeOnlyMatchingFilter string, ...) string
• func WantedEvent(event string, includeOnlyMatchingFilter string, ...) bool
• type Func
• type SumoBuffer
• type SumoLogicAppender
  • func NewSumoLogicAppender(urlValue string, connectionTimeoutValue int, nozzleQueue *eventQueue.Queue, ...) *SumoLogicAppender
  • func (s *SumoLogicAppender) AppendLogs(buffer *SumoBuffer)
  • func (s *SumoLogicAppender) SendToSumo(logStringToSend string, url string, isMetric bool)
  • func (s *SumoLogicAppender) Start()

Variables

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()