README
¶
This is a Go library to treat CloudWatch Log streams as io.Writers and io.Readers.
Usage
group := NewGroup("group", cloudwatchlogs.New(defaults.DefaultConfig))
w, err := group.Create("stream")
io.WriteString(w, "Hello World")
r, err := group.Open("stream")
io.Copy(os.Stdout, r)
Dependencies
This library depends on aws-sdk-go.
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Group ¶
type Group struct {
// contains filtered or unexported fields
}
Group wraps a log stream group and provides factory methods for creating readers and writers for streams.
func NewGroup ¶
func NewGroup(group string, client *cloudwatchlogs.CloudWatchLogs) *Group
NewGroup returns a new Group instance.
type Reader ¶
type Reader struct {
// contains filtered or unexported fields
}
Reader is an io.Reader implementation that streams log lines from cloudwatch logs.
func NewReader ¶
func NewReader(group, stream string, client *cloudwatchlogs.CloudWatchLogs) *Reader
type RejectedLogEventsInfoError ¶
type RejectedLogEventsInfoError struct {
Info *cloudwatchlogs.RejectedLogEventsInfo
}
func (*RejectedLogEventsInfoError) Error ¶
func (e *RejectedLogEventsInfoError) Error() string
type Writer ¶
type Writer struct {
sync.Mutex // This protects calls to flush.
// contains filtered or unexported fields
}
Writer is an io.Writer implementation that writes lines to a cloudwatch logs stream.
func NewWriter ¶
func NewWriter(group, stream string, client *cloudwatchlogs.CloudWatchLogs) *Writer
NewWriterWithToken returns a new Writer to a new Log Stream
func NewWriterWithToken ¶
func NewWriterWithToken(group, stream string, sequenceToken *string, client *cloudwatchlogs.CloudWatchLogs) *Writer
NewWriterWithToken returns a new Writer that accepts a sequence token from an existing AWS Log Stream
func (*Writer) Close ¶
Closes the writer. Any subsequent calls to Write will return io.ErrClosedPipe.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.