Documentation ¶
Index ¶
Constants ¶
View Source
const (
MaxMessageLength = 32 << 10
)
Variables ¶
View Source
var ( // this is how long a batch will continue to be retried, in the event CloudWatch is // not available. At which point the batch is dumped to stderr MaxRetryTime = time.Hour // the buffer length of the log event channel EventLogBufferLength = 64 << 10 // this occurs when the buffered channel receiving log writes blocks ErrStreamBackedUp = errors.New("stream backed up") )
View Source
var ( ExceededBufferSizeLimitError = fmt.Errorf("exceeded buffer size limit") WriterClosedError = fmt.Errorf("cannot write to closed writer") )
View Source
var ( MaxSleepInterval = 10 * time.Second ErrMaxTries = errors.New("max tries") )
Functions ¶
This section is empty.
Types ¶
type LogMessage ¶
type Logger ¶
type Logger struct { // Service exposed for direct actions Service *cloudwatchlogs.CloudWatchLogs // contains filtered or unexported fields }
func (*Logger) WriteError ¶
type RateLimiter ¶
type RateLimiter struct {
// contains filtered or unexported fields
}
func NewRateLimiter ¶
func NewRateLimiter(n int, d time.Duration) *RateLimiter
func (*RateLimiter) Close ¶
func (r *RateLimiter) Close()
func (*RateLimiter) Ready ¶
func (r *RateLimiter) Ready() bool
type ScannerWriter ¶
type ScannerWriter struct {
// contains filtered or unexported fields
}
func NewScannerWriter ¶
func (*ScannerWriter) Close ¶
func (sc *ScannerWriter) Close() error
func (*ScannerWriter) Flush ¶
func (sc *ScannerWriter) Flush() error
Click to show internal directories.
Click to hide internal directories.