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 ( MaxSleepInterval = 10 * time.Second ErrMaxTries = errors.New("max tries") )
Functions ¶
This section is empty.
Types ¶
type Logger ¶
type Logger struct { // Service exposed for direct actions Service *cloudwatchlogs.CloudWatchLogs Debug bool // 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
Click to show internal directories.
Click to hide internal directories.