Method run

output/dyndb.go:148–157

()

}

func (dp *dynamoProcess) run() {
	for req := range dp.in {
		if err := dp.doRequest(req); err != nil {
			log.WithError(err).Error("error writing to DynamoDB")
			dp.out <- false
		} else {
			dp.out <- true
		}
	}
}

func (dp *dynamoProcess) BeginWriting(req *dynamodb.BatchWriteItemInput) {
	dp.in <- req