cwlogs

Documentation

Index

• type Dispatcher
  • func NewDispatcher(config *config.SyslogConfig) (*Dispatcher, error)
  • func (d *Dispatcher) Dispatch(entries []*batching.LogEntry)
  • func (d *Dispatcher) SetupCloudwatch() error

Types

type Dispatcher

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

Dispatcher dispatches logs to cloudwatch

func NewDispatcher

func NewDispatcher(config *config.SyslogConfig) (*Dispatcher, error)

NewDispatcher create a new dispatcher

func (*Dispatcher) Dispatch

func (d *Dispatcher) Dispatch(entries []*batching.LogEntry)

Dispatch handle entries and send them to cloudwatch

func (*Dispatcher) SetupCloudwatch

func (d *Dispatcher) SetupCloudwatch() error

SetupCloudwatch create cloudwatch group and stream