luciano/amazon-kinesis-client-go
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

(lint) go vet fixes

Browse source
This commit is contained in:
Nathan Leiby 2017-08-10 14:28:13 -07:00
parent 5b8a86212d
commit 6039f69d86
2 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
batchconsumer/writer.go
View file

@ -81,7 +81,7 @@ func (b *batchedWriter) ProcessRecords(records []kcl.Record) error {
return fmt.Errorf("could not parse sequence number '%s'", record.SequenceNumber) return fmt.Errorf("could not parse sequence number '%s'", record.SequenceNumber)
} }
pair = kcl.SequencePair{seq, record.SubSequenceNumber} pair = kcl.SequencePair{Sequence: seq, SubSequence: record.SubSequenceNumber}
if prevPair.IsNil() { // Handles on-start edge case where b.lastProcessSeq is empty if prevPair.IsNil() { // Handles on-start edge case where b.lastProcessSeq is empty
prevPair = pair prevPair = pair
} }

2
cmd/consumer/main.go
View file

@ -39,7 +39,7 @@ func (srp *sampleRecordProcessor) ProcessRecords(records []kcl.Record) error {
fmt.Fprintf(os.Stderr, "could not parse sequence number '%s'\n", record.SequenceNumber) fmt.Fprintf(os.Stderr, "could not parse sequence number '%s'\n", record.SequenceNumber)
continue continue
} }
pair := kcl.SequencePair{seqNumber, record.SubSequenceNumber} pair := kcl.SequencePair{Sequence: seqNumber, SubSequence: record.SubSequenceNumber}
if srp.shouldUpdateSequence(pair) { if srp.shouldUpdateSequence(pair) {
srp.largestPair = pair srp.largestPair = pair
} }