awscloudwatchlogevents

Documentation

Index

• type Processor
  • func NewProcessor(service string, client datadog.Client) *Processor
  • func (p *Processor) Errors() []error
  • func (p *Processor) Process(ctx context.Context, request events.CloudwatchLogsEvent)
  • func (p *Processor) WithNoOfWorkers(noOfWorkers int) *Processor
  • func (p *Processor) Withtags(tags tags.Tags) *Processor

Types

type Processor

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

func NewProcessor

func NewProcessor(service string, client datadog.Client) *Processor

func (*Processor) Errors

func (p *Processor) Errors() []error

func (*Processor) Process

func (p *Processor) Process(ctx context.Context, request events.CloudwatchLogsEvent)

Process will parse and push AWS Cloudwatch Log Events as Datadog logs to Datadog

func (*Processor) WithNoOfWorkers

func (p *Processor) WithNoOfWorkers(noOfWorkers int) *Processor

func (*Processor) Withtags

func (p *Processor) Withtags(tags tags.Tags) *Processor