fabiocicerchia/go-proxy-cache

File metrics.go has 533 lines of code (exceeds 500 allowed). Consider refactoring.

Open

package metrics

import (
    "fmt"
    "net/http"

Function IncWholeResponse has 8 arguments (exceeds 4 allowed). Consider refactoring.

Open

func IncWholeResponse(reqID string, req http.Request, statusCode int, size int, duration int64, scheme string, cached bool, stale bool) {

Method TelemetryContext.RegisterWholeResponse has 8 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (tc TelemetryContext) RegisterWholeResponse(reqID string, req http.Request, statusCode int, contentLength int, requestStartTime time.Time, scheme string, cached bool, stale bool) {

Function StoreMetadata has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

func StoreMetadata(ctx context.Context, domainID string, method string, url url.URL, meta []string, expiration time.Duration) (bool, error) {

Method TelemetryContext.RegisterLegitRequest has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (tc TelemetryContext) RegisterLegitRequest(hostMatch bool, legitPort bool, hostname string, listeningPort string, confHostname string, confPort string) {

Avoid deeply nested control flow statements.

Open

    } else if code < 600 {
        request5xx.With(labels).Inc()
    }

Method Object.RetrieveFullPage has 6 return statements (exceeds 4 allowed).

Open

func (c *Object) RetrieveFullPage() error {
    obj := &URIObj{}

    meta, err := FetchMetadata(c.DomainID, c.CurrentURIObject.Method, c.CurrentURIObject.URL)
    if err != nil {

Method Object.StoreFullPage has 6 return statements (exceeds 4 allowed).

Open

func (c Object) StoreFullPage(ctx context.Context, expiration time.Duration) (bool, error) {
    if !c.IsStatusAllowed() || !c.IsMethodAllowed() || expiration < 1 {
        logger.GetGlobal().WithFields(log.Fields{
            "ReqID": c.ReqID,
        }).Debugf(

Method TelemetryContext.RegisterRequestCall has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (tc TelemetryContext) RegisterRequestCall(reqID string, req http.Request, reqURL url.URL, scheme string, webSocket bool) {

Function LogRequest has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func LogRequest(req http.Request, statusCode int, lenContent int, reqID string, cacheLabel int) {

Similar blocks of code found in 4 locations. Consider refactoring.

Open

func InitIpHash(name string, config config.Upstream, enableHealthchecks bool) {
    initLB()
    items := convertEndpoints(config.Endpoints)

    lb[name] = NewIpHashBalancer(name, items)

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

func InitRandom(name string, config config.Upstream, enableHealthchecks bool) {
    initLB()
    items := convertEndpoints(config.Endpoints)

    lb[name] = NewRandomBalancer(name, items)

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

func InitRoundRobin(name string, config config.Upstream, enableHealthchecks bool) {
    initLB()
    items := convertEndpoints(config.Endpoints)

    lb[name] = NewRoundRobinBalancer(name, items)

• Read up
  Read up

Similar blocks of code found in 4 locations. Consider refactoring.

Open

func InitLeastConnection(name string, config config.Upstream, enableHealthchecks bool) {
    initLB()
    items := convertEndpoints(config.Endpoints)

    lb[name] = NewLeastConnectionsBalancer(name, items)

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func SetUpstreamServerHealthChecksHealthy(server string, upstream string) {
    hostname, _ := os.Hostname()
    labels := prometheus.Labels{
        "hostname": hostname,
        "env":      os.Getenv("TRACING_ENV"),

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func SetUpstreamServerHealthChecksUnhealthy(server string, upstream string) {
    hostname, _ := os.Hostname()
    labels := prometheus.Labels{
        "hostname": hostname,
        "env":      os.Getenv("TRACING_ENV"),

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    if err := rdb.getMutex(key).Lock(); err != nil {
        escapedKey := strings.Replace(key, "\n", "", -1)
        escapedKey = strings.Replace(escapedKey, "\r", "", -1)
        rdb.logger.Errorf("Lock Error on %s: %s", escapedKey, err)
        telemetry.From(ctx).RegisterEventWithData("Lock Error", map[string]string{

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    if ok, err := rdb.getMutex(key).Unlock(); !ok || err != nil {
        escapedKey := strings.Replace(key, "\n", "", -1)
        escapedKey = strings.Replace(escapedKey, "\r", "", -1)
        rdb.logger.Errorf("Unlock Error on %s: %s", escapedKey, err)
        telemetry.From(ctx).RegisterEventWithData("Lock Error", map[string]string{

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

func IncUpstreamServerSent(server string, upstream string, val float64) {
    hostname, _ := os.Hostname()
    labels := prometheus.Labels{
        "hostname": hostname,
        "env":      os.Getenv("TRACING_ENV"),

• Read up
  Read up

Similar blocks of code found in 3 locations. Consider refactoring.

Open

func IncUpstreamServerReceived(server string, upstream string, val float64) {
    hostname, _ := os.Hostname()
    labels := prometheus.Labels{
        "hostname": hostname,
        "env":      os.Getenv("TRACING_ENV"),

• Read up
  Read up