cloudwatch

Documentation

Index

• type BatchWriter
  • func NewBatchWriter(groupName, streamName string, cfg *aws.Config) (*BatchWriter, error)
  • func NewBatchWriterWithDuration(groupName, streamName string, cfg *aws.Config, batchFrequency time.Duration) (*BatchWriter, error)
  • func (w *BatchWriter) Flush() error
  • func (w *BatchWriter) Write(p []byte) (n int, err error)
• type LogrusHook
  • func NewLogrusHook(w io.Writer) *LogrusHook
  • func (h *LogrusHook) Fire(entry *logrus.Entry) error
  • func (h *LogrusHook) Flush() error
  • func (h *LogrusHook) Levels() []logrus.Level
  • func (h *LogrusHook) Sync() error

Types

type BatchWriter

type BatchWriter struct {
	// contains filtered or unexported fields
}

BatchWriter is an io.Writer that batch writes log events to the AWS CloudWatch logs API.

func NewBatchWriter

func NewBatchWriter(groupName, streamName string, cfg *aws.Config) (*BatchWriter, error)

NewBatchWriter creates an unbuffered BatchWriter with the given group and stream.

func NewBatchWriterWithDuration

func NewBatchWriterWithDuration(groupName, streamName string, cfg *aws.Config, batchFrequency time.Duration) (*BatchWriter, error)

NewBatchWriterWithDuration creates a BatchWriter with the given group and stream. To create an unbuffered writer, set batchFrequency to 0.

func (*BatchWriter) Flush

func (w *BatchWriter) Flush() error

Force flushing of currently stored messages

func (*BatchWriter) Write

func (w *BatchWriter) Write(p []byte) (n int, err error)

type LogrusHook

type LogrusHook struct {
	// contains filtered or unexported fields
}

LogrusHook implements the logrus.LogrusHook interface, writing lines to its writer.

func NewLogrusHook

func NewLogrusHook(w io.Writer) *LogrusHook

func (*LogrusHook) Fire

func (h *LogrusHook) Fire(entry *logrus.Entry) error

func (*LogrusHook) Flush

func (h *LogrusHook) Flush() error

Force flushing of currently stored messages

func (*LogrusHook) Levels

func (h *LogrusHook) Levels() []logrus.Level

func (*LogrusHook) Sync

func (h *LogrusHook) Sync() error

Function alias for compatibility with zap logging