Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for activeConnection (0.16 sec)

  1. pkg/envoy/agent.go

    		if err != nil {
    			log.Warnf("failed parsing Envoy stat %s (error: %s) line: %s", parts[0], err.Error(), line)
    			continue
    		}
    		activeConnections += int(val)
    	}
    	if activeConnections > 0 {
    		log.Debugf("Active connections stats: %s", stats.String())
    	}
    	return activeConnections, nil
    }
    
    // runWait runs the start-up command as a go routine and waits for it to finish
    func (a *Agent) runWait(abortCh <-chan error) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 24 16:04:22 UTC 2024
    - 9K bytes
    - Viewed (0)
  2. pkg/proxy/ipvs/util/ipvs_linux.go

    		return nil, errors.New("ipvs destination should not be empty")
    	}
    	return &RealServer{
    		Address:      dst.Address,
    		Port:         dst.Port,
    		Weight:       dst.Weight,
    		ActiveConn:   dst.ActiveConnections,
    		InactiveConn: dst.InactiveConnections,
    	}, nil
    }
    
    // toIPVSService converts a VirtualServer to the equivalent IPVS Service structure.
    func toIPVSService(vs *VirtualServer) (*libipvs.Service, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 9K bytes
    - Viewed (0)
Back to top