Versions in this module Expand all Collapse all v0 v0.1.1 Oct 13, 2015 v0.1.0 Sep 27, 2015 Changes in this version + func NewAdapter(route *router.Route) (router.LogAdapter, error) + type Adapter struct + func (a *Adapter) Stream(logstream chan *router.Message) + type Batcher struct + func NewBatcher(in <-chan Log, out chan<- []Log, capacity Capacity) *Batcher + func (b *Batcher) Length() int + func (b *Batcher) Start() + type Capacity struct + Duration time.Duration + Length int + Size int + type FakeLog struct + func (l *FakeLog) Body() string + func (l *FakeLog) Size() int + func (l *FakeLog) Timestamp() int64 + type Log interface + Body func() string + Size func() int + Timestamp func() int64 + type LogMessage struct + func (l *LogMessage) Body() string + func (l *LogMessage) Size() int + func (l *LogMessage) Timestamp() int64 + type LogStream struct + func NewLogStream(group, stream string) (*LogStream, error) + func (s *LogStream) Init() error + func (s *LogStream) Log(logs []*cloudwatchlogs.InputLogEvent)
Go to main page