Golint fixes

mapr · Jan 16, 2023 · 74a6eeb · 74a6eeb
1 parent cd144c2
commit 74a6eeb
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/kafka/mockcluster.go b/kafka/mockcluster.go
@@ -83,9 +83,9 @@ func (mc *MockCluster) BootstrapServers() string {
 }
 
 // SetRoundtripDuration sets the broker round-trip-time delay for the given broker.
-func (mc *MockCluster) SetRoundtripDuration(brokerId int, duration time.Duration) error {
+func (mc *MockCluster) SetRoundtripDuration(brokerID int, duration time.Duration) error {
 	durationInMillis := C.int(duration.Milliseconds())
-	cError := C.rd_kafka_mock_broker_set_rtt(mc.mcluster, C.int(brokerId), durationInMillis)
+	cError := C.rd_kafka_mock_broker_set_rtt(mc.mcluster, C.int(brokerID), durationInMillis)
 	if cError != C.RD_KAFKA_RESP_ERR_NO_ERROR {
 		return newError(cError)
 	}

diff --git a/schemaregistry/serde/avro/avro_generic_test.go b/schemaregistry/serde/avro/avro_generic_test.go
@@ -27,7 +27,7 @@ import (
 
 func testMessageFactoryGeneric(subject string, name string) (interface{}, error) {
 	if subject != "topic1-value" {
-		return nil, errors.New("Message factory only handles topic1.")
+		return nil, errors.New("message factory only handles topic1")
 	}
 
 	switch name {
@@ -39,7 +39,7 @@ func testMessageFactoryGeneric(subject string, name string) (interface{}, error)
 		return &GenericNestedTestRecord{}, nil
 	}
 
-	return nil, errors.New("Schema not found.")
+	return nil, errors.New("schema not found")
 }
 
 func TestGenericAvroSerdeWithSimple(t *testing.T) {

diff --git a/schemaregistry/serde/avro/avro_specific_test.go b/schemaregistry/serde/avro/avro_specific_test.go
@@ -27,7 +27,7 @@ import (
 
 func testMessageFactorySpecific(subject string, name string) (interface{}, error) {
 	if subject != "topic1-value" {
-		return nil, errors.New("Message factory only handles topic1.")
+		return nil, errors.New("message factory only handles topic1")
 	}
 
 	switch name {
@@ -39,7 +39,7 @@ func testMessageFactorySpecific(subject string, name string) (interface{}, error
 		return &test.RecursiveUnionTestRecord{}, nil
 	}
 
-	return nil, errors.New("Schema not found.")
+	return nil, errors.New("schema not found")
 }
 
 func TestSpecificAvroSerdeWithSimple(t *testing.T) {