*: U1000

Author: mreiferson

apps/nsq_to_file/nsq_to_file.go

@@ -18,16 +18,6 @@ import (
 	"github.com/nsqio/nsq/internal/version"
 )
 
-func hasArg(s string) bool {
-	argExist := false
-	flag.Visit(func(f *flag.Flag) {
-		if f.Name == s {
-			argExist = true
-		}
-	})
-	return argExist
-}
-
 func flagSet() *flag.FlagSet {
 	fs := flag.NewFlagSet("nsqd", flag.ExitOnError)
 

apps/nsq_to_http/nsq_to_http.go

@@ -155,16 +155,6 @@ func (p *GetPublisher) Publish(addr string, msg []byte) error {
 	return nil
 }
 
-func hasArg(s string) bool {
-	argExist := false
-	flag.Visit(func(f *flag.Flag) {
-		if f.Name == s {
-			argExist = true
-		}
-	})
-	return argExist
-}
-
 func main() {
 	var publisher Publisher
 	var addresses app.StringArray

apps/nsq_to_nsq/nsq_to_nsq.go

@@ -254,16 +254,6 @@ func (ph *PublishHandler) HandleMessage(m *nsq.Message, destinationTopic string)
 	return nil
 }
 
-func hasArg(s string) bool {
-	argExist := false
-	flag.Visit(func(f *flag.Flag) {
-		if f.Name == s {
-			argExist = true
-		}
-	})
-	return argExist
-}
-
 func main() {
 	var selectedMode int
 

internal/http_api/api_response.go

@@ -24,14 +24,6 @@ func (e Err) Error() string {
 	return e.Text
 }
 
-func acceptVersion(req *http.Request) int {
-	if req.Header.Get("accept") == "application/vnd.nsq; version=1.0" {
-		return 1
-	}
-
-	return 0
-}
-
 func PlainText(f APIHandler) APIHandler {
 	return func(w http.ResponseWriter, req *http.Request, ps httprouter.Params) (interface{}, error) {
 		code := 200

nsqd/protocol_v2.go

@@ -17,8 +17,6 @@ import (
 	"github.com/nsqio/nsq/internal/version"
 )
 
-const maxTimeout = time.Hour
-
 const (
 	frameTypeResponse int32 = 0
 	frameTypeError    int32 = 1