Discover Packages
github.com/jsirianni/operator-devel
operator
flusher
package
Version:
v0.13.13-0...-98661b4
Opens a new window with list of versions in this module.
Published: Feb 10, 2021
License: Apache-2.0
Opens a new window with license information.
Imports: 7
Opens a new window with list of imports.
Imported by: 0
Opens a new window with list of known importers.
Documentation
Documentation
¶
type Config struct {
MaxConcurrent int `json:"max_concurrent" yaml:"max_concurrent"`
}
Config holds the configuration to build a new flusher
NewConfig creates a new default flusher config
Build uses a Config to build a new Flusher
FlushFunc is any function that flushes
Flusher is used to flush entries from a buffer concurrently. It handles max concurrency,
retry behavior, and cancellation.
Do executes the flusher function in a goroutine
Stop cancels all the in-progress flushers and waits until they have returned
Source Files
¶
Click to show internal directories.
Click to hide internal directories.