Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 125 for TCP (0.16 sec)

  1. internal/rest/rpc-stats.go

    	tcpDialErrs     uint64
    	tcpDialCount    uint64
    	tcpDialTotalDur uint64
    }{}
    
    // RPCStats holds information about the DHCP/TCP metrics and errors
    type RPCStats struct {
    	Errs uint64
    
    	DialAvgDuration uint64
    	DialErrs        uint64
    }
    
    // GetRPCStats returns RPC stats, include calls errors and dhcp/tcp metrics
    func GetRPCStats() RPCStats {
    	s := RPCStats{
    		Errs:     atomic.LoadUint64(&globalStats.errs),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Sep 29 16:27:58 GMT 2022
    - 2.3K bytes
    - Viewed (0)
  2. helm/minio/templates/ciliumnetworkpolicy.yaml

          app: {{ template "minio.name" . }}
          release: {{ .Release.Name }}
      ingress:
      - toPorts:
        - ports:
          - port: "{{ .Values.minioAPIPort }}"
            protocol: TCP
          - port: "{{ .Values.minioConsolePort }}"
            protocol: TCP
        {{- if not .Values.networkPolicy.allowExternal }}
        fromEndpoints:
        - matchLabels:
            {{ template "minio.name" . }}-client: "true"
        {{- end }}
      egress:
    Others
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 07:50:24 GMT 2024
    - 936 bytes
    - Viewed (0)
  3. .github/workflows/go-lint.yml

          - name: Build on ${{ matrix.os }}
            if: matrix.os == 'windows-latest'
            env:
              CGO_ENABLED: 0
              GO111MODULE: on
            run: |
              netsh int ipv4 set dynamicport tcp start=60000 num=61000
              go build --ldflags="-s -w" -o %GOPATH%\bin\minio.exe
              go test -v --timeout 50m ./...
          - name: Build on ${{ matrix.os }}
            if: matrix.os == 'ubuntu-latest'
            env:
    Others
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 23:44:49 GMT 2024
    - 1.3K bytes
    - Viewed (0)
  4. internal/http/server.go

    type Server struct {
    	http.Server
    	Addrs           []string      // addresses on which the server listens for new connection.
    	TCPOptions      TCPOptions    // all the configurable TCP conn specific configurable options.
    	ShutdownTimeout time.Duration // timeout used for graceful server shutdown.
    	listenerMutex   sync.Mutex    // to guard 'listener' field.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 09 21:25:16 GMT 2024
    - 7.7K bytes
    - Viewed (0)
  5. helm/minio/templates/statefulset.yaml

        heritage: {{ .Release.Service }}
    spec:
      publishNotReadyAddresses: true
      clusterIP: None
      ports:
        - name: {{ $scheme }}
          port: {{ .Values.service.port }}
          protocol: TCP
          targetPort: {{ .Values.minioAPIPort }}
      selector:
        app: {{ template "minio.name" . }}
        release: {{ .Release.Name }}
    ---
    apiVersion: {{ template "minio.statefulset.apiVersion" . }}
    kind: StatefulSet
    Others
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 07:50:24 GMT 2024
    - 10.7K bytes
    - Viewed (0)
  6. internal/http/listener.go

    type httpListener struct {
    	opts        TCPOptions
    	listeners   []net.Listener    // underlying TCP listeners.
    	acceptCh    chan acceptResult // channel where all TCP listeners write accepted connection.
    	ctx         context.Context
    	ctxCanceler context.CancelFunc
    }
    
    // start - starts separate goroutine for each TCP listener.  A valid new connection is passed to httpListener.acceptCh.
    func (listener *httpListener) start() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  7. internal/http/check_port_test.go

    	if runtime.GOOS != "linux" {
    		t.Skip()
    	}
    
    	l, err := net.Listen("tcp", "localhost:0") // ask kernel for a free port.
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer l.Close()
    
    	port := l.Addr().(*net.TCPAddr).Port
    
    	testCases := []struct {
    		host        string
    		port        int
    		expectedErr error
    	}{
    		{"", port, fmt.Errorf("listen tcp :%v: bind: address already in use", port)},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 03 21:12:25 GMT 2023
    - 1.9K bytes
    - Viewed (0)
  8. internal/event/target/webhook.go

    // Store returns any underlying store if set.
    func (target *WebhookTarget) Store() event.TargetStore {
    	return target.store
    }
    
    func (target *WebhookTarget) isActive() (bool, error) {
    	conn, err := net.DialTimeout("tcp", target.addr, 5*time.Second)
    	if err != nil {
    		if xnet.IsNetworkOrHostDown(err, false) {
    			return false, store.ErrNotConnected
    		}
    		return false, err
    	}
    	defer conn.Close()
    	return true, nil
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Nov 20 22:40:07 GMT 2023
    - 8.5K bytes
    - Viewed (0)
  9. helm-releases/minio-2.0.0.tgz

    type: {{ .Values.consoleService.type }} loadBalancerIP: {{ default "" .Values.consoleService.loadBalancerIP }} {{- else }} type: {{ .Values.consoleService.type }} {{- end }} ports: - name: {{ $scheme }} port: {{ .Values.consoleService.port }} protocol: TCP {{- if (and (eq .Values.consoleService.type "NodePort") ( .Values.consoleService.nodePort)) }} nodePort: {{ .Values.consoleService.nodePort }} {{- else }} targetPort: {{ .Values.consoleService.port }} {{- end}} {{- if .Values.consoleService.externalIPs...
    Others
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Aug 26 07:36:46 GMT 2021
    - 13.6K bytes
    - Viewed (0)
  10. helm-releases/minio-1.0.3.tgz

    type: {{ .Values.consoleService.type }} loadBalancerIP: {{ default "" .Values.consoleService.loadBalancerIP }} {{- else }} type: {{ .Values.consoleService.type }} {{- end }} ports: - name: {{ $scheme }} port: {{ .Values.consoleService.port }} protocol: TCP {{- if (and (eq .Values.consoleService.type "NodePort") ( .Values.consoleService.nodePort)) }} nodePort: {{ .Values.consoleService.nodePort }} {{- else }} targetPort: {{ .Values.consoleService.port }} {{- end}} {{- if .Values.consoleService.externalIPs...
    Others
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Aug 24 19:04:07 GMT 2021
    - 13.6K bytes
    - Viewed (0)
Back to top