Documentation ¶
Index ¶
- Constants
- func CalculateRunningAverage(period float64, totalPeriods float64, average float64, measurement float64) float64
- func CalculateSpeed(duration time.Duration, average float64, measurement float64, ...) float64
- type Event
- type EventDescriptor
- type ExpBackoff
- type IPipelineConfigReceiver
- type IPipelineSegment
- type Pipeline
- type PipelineConfigReceiver
- type PipelineSegment
- type Snapshot
- func (s *Snapshot) AddEntry(name string, value interface{})
- func (s *Snapshot) AddSub(sub *Snapshot)
- func (s *Snapshot) Description() string
- func (s *Snapshot) Entry(i int) (string, interface{})
- func (s *Snapshot) EntryByName(name string) (interface{}, bool)
- func (s *Snapshot) NumEntries() int
- func (s *Snapshot) NumSubs() int
- func (s *Snapshot) Sort()
- func (s *Snapshot) Sub(i int) *Snapshot
- type Stream
Constants ¶
const DefaultDelay = 1 * time.Second
DefaultDelay is the default delay for an ExpBackoff structure when it is not specified, or when it is zero (in which case this becomes the delay after the first immediate retry)
const LogCourierVersion string = "2.0.6"
LogCourierVersion is the library version number
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Event ¶
type Event map[string]interface{}
Event holds a key-value map that represents a single log event
type EventDescriptor ¶
EventDescriptor describes an Event, such as it's source and offset, which can be used in order to resume log files
type ExpBackoff ¶
type ExpBackoff struct {
// contains filtered or unexported fields
}
ExpBackoff implements an exponential backoff helper The default delay is 1 second
func NewExpBackoff ¶
NewExpBackoff creates a new ExpBackoff structure with the given default delay
func (*ExpBackoff) Reset ¶
func (e *ExpBackoff) Reset()
Reset resets the exponential backoff to default values
func (*ExpBackoff) Trigger ¶
func (e *ExpBackoff) Trigger() time.Duration
Trigger informs the ExpBackoff that backoff needs to happen and returns the next delay to use
type IPipelineConfigReceiver ¶
type IPipelineConfigReceiver interface {
// contains filtered or unexported methods
}
type IPipelineSegment ¶
type IPipelineSegment interface { Run() // contains filtered or unexported methods }
type Pipeline ¶
type Pipeline struct {
// contains filtered or unexported fields
}
func NewPipeline ¶
func NewPipeline() *Pipeline
func (*Pipeline) Register ¶
func (p *Pipeline) Register(ipipe IPipelineSegment)
func (*Pipeline) SendConfig ¶
type PipelineConfigReceiver ¶
type PipelineConfigReceiver struct {
// contains filtered or unexported fields
}
func (*PipelineConfigReceiver) OnConfig ¶
func (s *PipelineConfigReceiver) OnConfig() <-chan *config.Config
type PipelineSegment ¶
type PipelineSegment struct {
// contains filtered or unexported fields
}
func (*PipelineSegment) Done ¶
func (s *PipelineSegment) Done()
func (*PipelineSegment) OnShutdown ¶
func (s *PipelineSegment) OnShutdown() <-chan interface{}
func (*PipelineSegment) Run ¶
func (s *PipelineSegment) Run()
type Snapshot ¶
type Snapshot struct { Desc string Entries map[string]interface{} Keys []string Subs map[string]*Snapshot SubKeys []string }