Search Options

Results per page
Sort
Preferred Languages
Advance

Results 201 - 210 of 357 for ENDPOINT (0.13 sec)

  1. internal/logger/targets.go

    )
    
    // Target is the entity that we will receive
    // a single log entry and Send it to the log target
    //
    //	e.g. Send the log to a http server
    type Target interface {
    	String() string
    	Endpoint() string
    	Stats() types.TargetStats
    	Init(ctx context.Context) error
    	IsOnline(ctx context.Context) bool
    	Cancel()
    	Send(ctx context.Context, entry interface{}) error
    	Type() types.TargetType
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 03 15:44:50 UTC 2024
    - 6K bytes
    - Viewed (0)
  2. cmd/xl-storage.go

    }
    
    // Implements stringer compatible interface.
    func (s *xlStorage) String() string {
    	return s.drivePath
    }
    
    func (s *xlStorage) Hostname() string {
    	return s.endpoint.Host
    }
    
    func (s *xlStorage) Endpoint() Endpoint {
    	return s.endpoint
    }
    
    func (s *xlStorage) Close() error {
    	s.immediatePurgeCancel()
    	return nil
    }
    
    func (s *xlStorage) IsOnline() bool {
    	return true
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  3. docs/distributed/distributed-from-config-file.sh

    	exit
    fi
    
    # Compare the difference of the list of disks and their location, with the below expected output
    diff <(./mc admin info minio1 --json | jq -r '.info.servers[].drives[] | "\(.pool_index),\(.set_index),\(.disk_index) \(.endpoint)"' | sort) <(
    	cat <<EOF
    0,0,0 http://localhost:9001/tmp/xl/node9001/mnt/disk1
    0,0,1 http://localhost:9002/tmp/xl/node9002/mnt/disk1
    0,0,2 http://localhost:9001/tmp/xl/node9001/mnt/disk2
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 09:06:49 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  4. cmd/notification.go

    			ctx, cancel := context.WithTimeout(ctx, 10*time.Second)
    			defer cancel()
    			info, err := client.ServerInfo(ctx, metrics)
    			if err != nil {
    				info.Endpoint = client.host.String()
    				info.State = string(madmin.ItemOffline)
    				info.Disks = getOfflineDisks(info.Endpoint, globalEndpoints)
    			}
    			reply[idx] = info
    		}(client, i)
    	}
    	wg.Wait()
    
    	return reply
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  5. cmd/event-notification.go

    	}
    
    	respElements := map[string]string{
    		"x-amz-request-id": args.RespElements["requestId"],
    		"x-amz-id-2":       args.RespElements["nodeId"],
    		"x-minio-origin-endpoint": func() string {
    			if globalMinioEndpoint != "" {
    				return globalMinioEndpoint
    			}
    			return getAPIEndpoints()[0]
    		}(), // MinIO specific custom elements.
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  6. internal/config/identity/openid/jwt_test.go

    	if err != nil {
    		t.Error(err)
    	}
    }
    
    func TestKeycloakProviderInitialization(t *testing.T) {
    	testConfig := providerCfg{
    		DiscoveryDoc: DiscoveryDoc{
    			TokenEndpoint: "http://keycloak.test/token/endpoint",
    		},
    	}
    	testKvs := config.KVS{}
    	testKvs.Set(Vendor, "keycloak")
    	testKvs.Set(KeyCloakRealm, "TestRealm")
    	testKvs.Set(KeyCloakAdminURL, "http://keycloak.test/auth/admin")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  7. istioctl/pkg/writer/ztunnel/configdump/configdump.go

    import (
    	"encoding/json"
    	"fmt"
    	"io"
    	"text/tabwriter"
    
    	"sigs.k8s.io/yaml"
    
    	"istio.io/istio/pkg/maps"
    )
    
    // ConfigWriter is a writer for processing responses from the Ztunnel Admin config_dump endpoint
    type ConfigWriter struct {
    	Stdout      io.Writer
    	ztunnelDump *ZtunnelDump
    	FullDump    []byte
    }
    
    type rawDump struct {
    	Services      json.RawMessage          `json:"services"`
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jun 06 20:18:34 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  8. docs/distributed/decom-encrypted-sse-s3.sh

    ret=$?
    if [ $ret -ne 0 ]; then
    	echo "BUG: expected no missing entries after decommission: $out"
    	exit 1
    fi
    
    ./s3-check-md5 -versions -access-key minioadmin -secret-key minioadmin -endpoint http://127.0.0.1:9001/ -bucket versioned
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon May 27 19:17:46 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  9. cmd/generic-handlers.go

    		if bucket == "" {
    			h.ServeHTTP(w, r)
    			return
    		}
    
    		// MakeBucket requests should be handled at current endpoint
    		if r.Method == http.MethodPut && bucket != "" && object == "" && r.URL.RawQuery == "" {
    			h.ServeHTTP(w, r)
    			return
    		}
    
    		// CopyObject requests should be handled at current endpoint as path style
    		// requests have target bucket and object in URI and source details are in
    		// header fields
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  10. guava/src/com/google/common/graph/EndpointPair.java

       */
      public abstract N target();
    
      /**
       * If this {@link EndpointPair} {@link #isOrdered()} returns the {@link #source()}; otherwise,
       * returns an arbitrary (but consistent) endpoint of the origin edge.
       */
      public final N nodeU() {
        return nodeU;
      }
    
      /**
       * Returns the node {@link #adjacentNode(Object) adjacent} to {@link #nodeU()} along the origin
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 01 17:18:04 UTC 2021
    - 8.1K bytes
    - Viewed (0)
Back to top