Clean up linting warnings

client/matching/client.go

@@ -307,15 +307,3 @@ func (c *clientImpl) getClientForTaskList(key string) (Client, error) {
 	}
 	return client.(Client), nil
 }
-
-func (c *clientImpl) getTaskListsByDomain(
-	cl Client,
-	ctx context.Context,
-	request *types.GetTaskListsByDomainRequest,
-	opts ...yarpc.CallOption,
-) (*types.GetTaskListsByDomainResponse, error) {
-	ctx, cancel := c.createContext(ctx)
-	defer cancel()
-
-	return cl.GetTaskListsByDomain(ctx, request, opts...)
-}

common/metrics/context.go

@@ -22,7 +22,9 @@ package metrics
 
 import "context"
 
-const contextTagsKey = "metrics.Tags"
+type contextTag string
+
+const contextTagsKey = contextTag("metrics.Tags")
 
 func TagContext(ctx context.Context, tag Tag) context.Context {
 	tags, ok := ctx.Value(contextTagsKey).([]Tag)

common/persistence/nosql/nosqlTaskStore.go

@@ -121,7 +121,7 @@ func (t *nosqlTaskStore) LeaseTaskList(
 		}
 
 		// Update the rangeID as this is an ownership change
-		currTL.RangeID += 1
+		currTL.RangeID++
 
 		err = t.db.UpdateTaskList(ctx, &nosqlplugin.TaskListRow{
 			DomainID:        request.DomainID,

common/persistence/sql/sqlExecutionStoreUtil.go

@@ -188,18 +188,15 @@ func applyWorkflowMutationTx(
 		}
 	}
 
-	if err := updateBufferedEvents(
+	return updateBufferedEvents(
 		ctx,
 		tx,
 		workflowMutation.NewBufferedEvents,
 		shardID,
 		domainID,
 		workflowID,
 		runID,
-	); err != nil {
-		return err
-	}
-	return nil
+	)
 }
 
 func applyWorkflowSnapshotTxAsReset(
@@ -395,16 +392,13 @@ func applyWorkflowSnapshotTxAsReset(
 		return err
 	}
 
-	if err := deleteBufferedEvents(
+	return deleteBufferedEvents(
 		ctx,
 		tx,
 		shardID,
 		domainID,
 		workflowID,
-		runID); err != nil {
-		return err
-	}
-	return nil
+		runID)
 }
 
 func (m *sqlExecutionStore) applyWorkflowSnapshotTxAsNew(
@@ -516,19 +510,15 @@ func (m *sqlExecutionStore) applyWorkflowSnapshotTxAsNew(
 		return err
 	}
 
-	if err := updateSignalsRequested(
+	return updateSignalsRequested(
 		ctx,
 		tx,
 		workflowSnapshot.SignalRequestedIDs,
 		nil,
 		shardID,
 		domainID,
 		workflowID,
-		runID); err != nil {
-		return err
-	}
-
-	return nil
+		runID)
 }
 
 func applyTasks(

common/persistence/sql/sqlplugin/postgres/db.go

@@ -62,21 +62,21 @@ func (pdb *db) IsDupEntryError(err error) bool {
 	return ok && sqlErr.Code == ErrDupEntry
 }
 
-func (mdb *db) IsNotFoundError(err error) bool {
+func (pdb *db) IsNotFoundError(err error) bool {
 	if err == sql.ErrNoRows {
 		return true
 	}
 	return false
 }
 
-func (mdb *db) IsTimeoutError(err error) bool {
+func (pdb *db) IsTimeoutError(err error) bool {
 	if err == context.DeadlineExceeded {
 		return true
 	}
 	return false
 }
 
-func (mdb *db) IsThrottlingError(err error) bool {
+func (pdb *db) IsThrottlingError(err error) bool {
 	sqlErr, ok := err.(*pq.Error)
 	if ok {
 		if sqlErr.Code == ErrTooManyConnections ||

common/persistence/visibilitySamplingClient.go

@@ -318,10 +318,9 @@ func (p *visibilitySamplingClient) tryConsumeListToken(domain string) error {
 	if ok {
 		p.logger.Debug("List API request consumed QPS token", tag.WorkflowDomainName(domain), tag.Name(callerFuncName(2)))
 		return nil
-	} else {
-		p.logger.Debug("List API request is being sampled", tag.WorkflowDomainName(domain), tag.Name(callerFuncName(2)))
-		return errPersistenceLimitExceededForList
 	}
+	p.logger.Debug("List API request is being sampled", tag.WorkflowDomainName(domain), tag.Name(callerFuncName(2)))
+	return errPersistenceLimitExceededForList
 }
 
 func callerFuncName(skip int) string {

common/util.go

@@ -900,3 +900,13 @@ func MicrosecondsToDuration(d int64) time.Duration {
 func NanosecondsToDuration(d int64) time.Duration {
 	return time.Duration(d) * time.Nanosecond
 }
+
+// SleepWithMinDuration sleeps for the minimum of desired and available duration
+// returns the remaining available time duration
+func SleepWithMinDuration(desired time.Duration, available time.Duration) time.Duration {
+	d := MinDuration(desired, available)
+	if d > 0 {
+		time.Sleep(d)
+	}
+	return available - d
+}