Connector has 26 methods (exceeds 20 allowed). Consider refactoring.

Open

type Connector struct {
    // struct alignment! These fields must be up-front.
    updateMetricCount uint64
    ipfsPinCount      int64

File methods.go has 535 lines of code (exceeds 500 allowed). Consider refactoring.

Open

package client

import (
    "bytes"
    "context"

defaultClient has 25 methods (exceeds 20 allowed). Consider refactoring.

Open

func (c *defaultClient) ID(ctx context.Context) (api.ID, error) {
    ctx, span := trace.StartSpan(ctx, "client/ID")
    defer span.End()

    var id api.ID

File raft.go has 525 lines of code (exceeds 500 allowed). Consider refactoring.

Open

package raft

import (
    "context"
    "errors"

API has 23 methods (exceeds 20 allowed). Consider refactoring.

Open

type API struct {
    ctx    context.Context
    cancel func()

    config *Config

Function runCmd has a Cognitive Complexity of 27 (exceeds 15 allowed). Consider refactoring.

Open

func runCmd(c *cli.Context) error {
    clusterName := c.String(clusterNameFlag)

    if cfgURL := c.String("init"); cfgURL != "" {
        err := initCluster(c, true, cfgURL)

• Read up
  Read up

Method Cluster.Shutdown has a Cognitive Complexity of 27 (exceeds 15 allowed). Consider refactoring.

Open

func (c *Cluster) Shutdown(ctx context.Context) error {
    ctx, span := trace.StartSpan(ctx, "cluster/Shutdown")
    defer span.End()

    c.shutdownLock.Lock()

• Read up
  Read up

Method Monitor.logFromPubsub has a Cognitive Complexity of 27 (exceeds 15 allowed). Consider refactoring.

Open

func (mon *Monitor) logFromPubsub() {
    ctx, span := trace.StartSpan(mon.ctx, "monitor/pubsub/logFromPubsub")
    defer span.End()

    decodeWarningPrinted := false

• Read up
  Read up

Function main has 111 lines of code (exceeds 80 allowed). Consider refactoring.

Open

func main() {
    app := cli.NewApp()
    app.Name = programName
    app.Usage = "IPFS Cluster Follower"
    app.UsageText = fmt.Sprintf("%s [global options] <clusterName> [subcommand]...", programName)

Method Server.pinLsHandler has a Cognitive Complexity of 26 (exceeds 15 allowed). Consider refactoring.

Open

func (proxy *Server) pinLsHandler(w http.ResponseWriter, r *http.Request) {
    proxy.setHeaders(w.Header(), r)

    arg := r.URL.Query().Get("arg")

• Read up
  Read up

Method Tracker.StatusAll has a Cognitive Complexity of 26 (exceeds 15 allowed). Consider refactoring.

Open

func (spt *Tracker) StatusAll(ctx context.Context, filter api.TrackerStatus, out chan<- api.PinInfo) error {
    ctx, span := trace.StartSpan(ctx, "tracker/stateless/StatusAll")
    defer span.End()

    ipfsid := spt.getIPFSID(ctx)

• Read up
  Read up

Method Cluster.globalPinInfoStream has a Cognitive Complexity of 25 (exceeds 15 allowed). Consider refactoring.

Open

func (c *Cluster) globalPinInfoStream(ctx context.Context, comp, method string, inChan interface{}, out chan<- api.GlobalPinInfo) error {
    defer close(out)

    ctx, span := trace.StartSpan(ctx, "cluster/globalPinInfoStream")
    defer span.End()

• Read up
  Read up

Method Connector.Pin has a Cognitive Complexity of 24 (exceeds 15 allowed). Consider refactoring.

Open

func (ipfs *Connector) Pin(ctx context.Context, pin api.Pin) error {
    ctx, span := trace.StartSpan(ctx, "ipfsconn/ipfshttp/Pin")
    defer span.End()

    hash := pin.Cid

• Read up
  Read up

Function main has 25 return statements (exceeds 10 allowed).

Open

func main() {
    ctx := context.Background()

    app := cli.NewApp()
    app.Name = programName

Method Server.pinLsHandler has 98 lines of code (exceeds 80 allowed). Consider refactoring.

Open

func (proxy *Server) pinLsHandler(w http.ResponseWriter, r *http.Request) {
    proxy.setHeaders(w.Header(), r)

    arg := r.URL.Query().Get("arg")

Method Tracker.StatusAll has 97 lines of code (exceeds 80 allowed). Consider refactoring.

Open

func (spt *Tracker) StatusAll(ctx context.Context, filter api.TrackerStatus, out chan<- api.PinInfo) error {
    ctx, span := trace.StartSpan(ctx, "tracker/stateless/StatusAll")
    defer span.End()

    ipfsid := spt.getIPFSID(ctx)

Method Cluster.globalPinInfoCid has 96 lines of code (exceeds 80 allowed). Consider refactoring.

Open

func (c *Cluster) globalPinInfoCid(ctx context.Context, comp, method string, h api.Cid) (api.GlobalPinInfo, error) {
    ctx, span := trace.StartSpan(ctx, "cluster/globalPinInfoCid")
    defer span.End()

    // The object we will return

Method Cluster.globalPinInfoStream has 95 lines of code (exceeds 80 allowed). Consider refactoring.

Open

func (c *Cluster) globalPinInfoStream(ctx context.Context, comp, method string, inChan interface{}, out chan<- api.GlobalPinInfo) error {
    defer close(out)

    ctx, span := trace.StartSpan(ctx, "cluster/globalPinInfoStream")
    defer span.End()

Method ListOptions.FromQuery has a Cognitive Complexity of 23 (exceeds 15 allowed). Consider refactoring.

Open

func (lo *ListOptions) FromQuery(q url.Values) error {
    cidq := q.Get("cid")
    if len(cidq) > 0 {
        for _, cstr := range strings.Split(cidq, ",") {
            c, err := types.DecodeCid(cstr)

• Read up
  Read up

Function createCluster has 93 lines of code (exceeds 80 allowed). Consider refactoring.

Open

func createCluster(
    ctx context.Context,
    c *cli.Context,
    cfgHelper *cmdutils.ConfigHelper,
    host host.Host,