From 6039f69d8679bccc641cc286170cd2e15cf6bcb6 Mon Sep 17 00:00:00 2001 From: Nathan Leiby Date: Thu, 10 Aug 2017 14:28:13 -0700 Subject: [PATCH] (lint) go vet fixes --- batchconsumer/writer.go | 2 +- cmd/consumer/main.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/batchconsumer/writer.go b/batchconsumer/writer.go index c8341d2..4b68c74 100644 --- a/batchconsumer/writer.go +++ b/batchconsumer/writer.go @@ -81,7 +81,7 @@ func (b *batchedWriter) ProcessRecords(records []kcl.Record) error { 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 prevPair = pair } diff --git a/cmd/consumer/main.go b/cmd/consumer/main.go index 6f2f51a..647b472 100644 --- a/cmd/consumer/main.go +++ b/cmd/consumer/main.go @@ -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) continue } - pair := kcl.SequencePair{seqNumber, record.SubSequenceNumber} + pair := kcl.SequencePair{Sequence: seqNumber, SubSequence: record.SubSequenceNumber} if srp.shouldUpdateSequence(pair) { srp.largestPair = pair }