func()

in cfn/logging/cloudwatchlogs.go [87:115]

• 22 lines of code
• 3 McCabe index (conditional complexity)

func (p *cloudWatchLogsProvider) Write(b []byte) (int, error) {
	p.logger.Printf("Need to write: %v", string(b))

	input := &cloudwatchlogs.PutLogEventsInput{
		LogGroupName:  aws.String(p.logGroupName),
		LogStreamName: aws.String(p.logStreamName),

		LogEvents: []*cloudwatchlogs.InputLogEvent{
			&cloudwatchlogs.InputLogEvent{
				Message:   aws.String(string(b)),
				Timestamp: aws.Int64(time.Now().UnixNano() / int64(time.Millisecond)),
			},
		},
	}

	if len(p.sequence) != 0 {
		input.SetSequenceToken(p.sequence)
	}

	resp, err := p.client.PutLogEvents(input)

	if err != nil {
		return 0, err
	}

	p.sequence = *resp.NextSequenceToken

	return len(b), nil
}