Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 27 for steps (0.15 sec)

  1. operator/cmd/mesh/shared.go

    type applyOptions struct {
    	// Path to the kubeconfig file.
    	Kubeconfig string
    	// ComponentName of the kubeconfig context to use.
    	Context string
    	// DryRun performs all steps except actually applying the manifests or creating output dirs/files.
    	DryRun bool
    	// Maximum amount of time to wait for resources to be ready after install when Wait=true.
    	WaitTimeout time.Duration
    }
    
    Go
    - Registered: Wed Mar 20 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 01:18:49 GMT 2024
    - 5.3K bytes
    - Viewed (0)
  2. src/bufio/bufio_test.go

    // A scriptedReader is an io.Reader that executes its steps sequentially.
    type scriptedReader []func(p []byte) (n int, err error)
    
    func (sr *scriptedReader) Read(p []byte) (n int, err error) {
    	if len(*sr) == 0 {
    		panic("too many Read calls on scripted Reader. No steps remain.")
    	}
    	step := (*sr)[0]
    	*sr = (*sr)[1:]
    	return step(p)
    }
    
    func newScriptedReader(steps ...func(p []byte) (n int, err error)) io.Reader {
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Feb 10 18:56:01 GMT 2023
    - 51.5K bytes
    - Viewed (0)
  3. operator/cmd/mesh/root.go

    	VerifyCRInstallHelpStr    = "Verify the Istio control plane after installation/in-place upgrade"
    )
    
    type RootArgs struct {
    	// DryRun performs all steps except actually applying the manifests or creating output dirs/files.
    	DryRun bool
    }
    
    func addFlags(cmd *cobra.Command, rootArgs *RootArgs) {
    	cmd.PersistentFlags().BoolVarP(&rootArgs.DryRun, "dry-run", "",
    Go
    - Registered: Wed Mar 20 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 01:18:49 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  4. cmd/iam-store.go

    		cache.iamGroupPolicyMap.Delete(group)
    
    		cache.updatedAt = time.Now()
    		return nil
    	}
    
    	gi := cache.iamGroupsMap[group]
    
    	// Updating the group memberships cache happens in two steps:
    	//
    	// 1. Remove the group from each user's list of memberships.
    	// 2. Add the group to each member's list of memberships.
    	//
    	// This ensures that regardless of members being added or
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  5. cmd/routers.go

    }
    
    // configureServer handler returns final handler for the http server.
    func configureServerHandler(endpointServerPools EndpointServerPools) (http.Handler, error) {
    	// Initialize router. `SkipClean(true)` stops minio/mux from
    	// normalizing URL path minio/minio#3256
    	router := mux.NewRouter().SkipClean(true).UseEncodedPath()
    
    	// Initialize distributed NS lock.
    	if globalIsDistErasure {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Mar 08 19:08:18 GMT 2024
    - 3.6K bytes
    - Viewed (1)
  6. src/cmd/api/main_test.go

    		log.Fatal(err)
    	}
    	s := string(bs)
    
    	// Diagnose common mistakes people make,
    	// since there is no apifmt to format these files.
    	// The missing final newline is important for the
    	// final release step of cat next/*.txt >go1.X.txt.
    	// If the files don't end in full lines, the concatenation goes awry.
    	if strings.Contains(s, "\r") {
    		log.Printf("%s: contains CRLFs", filename)
    		exitCode = 1
    	}
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Tue Apr 09 20:48:51 GMT 2024
    - 31.4K bytes
    - Viewed (0)
  7. cmd/admin-handlers.go

    }
    
    // ServiceHandler - POST /minio/admin/v3/service?action={action}
    // ----------
    // Supports following actions:
    // - restart (restarts all the MinIO instances in a setup)
    // - stop (stops all the MinIO instances in a setup)
    // - freeze (freezes all incoming S3 API calls)
    // - unfreeze (unfreezes previously frozen S3 API calls)
    func (a adminAPIHandlers) ServiceHandler(w http.ResponseWriter, r *http.Request) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 97.3K bytes
    - Viewed (2)
  8. cmd/service.go

    )
    
    // Type of service signals currently supported.
    type serviceSignal int
    
    const (
    	serviceRestart       serviceSignal = iota // Restarts the server.
    	serviceStop                               // Stops the server.
    	serviceReloadDynamic                      // Reload dynamic config values.
    	serviceFreeze                             // Freeze all S3 API calls.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Feb 28 07:02:14 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  9. internal/event/target/kafka_scram_client_contrib.go

    	return nil
    }
    
    // Step takes a string provided from a server (or just an empty string for the
    // very first conversation step) and attempts to move the authentication
    // conversation forward.  It returns a string to be sent to the server or an
    // error if the server message is invalid.  Calling Step after a conversation
    // completes is also an error.
    func (x *XDGSCRAMClient) Step(challenge string) (response string, err error) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Nov 09 04:04:01 GMT 2023
    - 3.2K bytes
    - Viewed (0)
  10. src/cmd/cgo/doc.go

    present to create such a binary.
    
    Most builds both compile source code and invoke the linker to create a
    binary. When cgo is involved, the compile step already requires gcc, so
    it is not problematic for the link step to require gcc too.
    
    An important exception is builds using a pre-compiled copy of the
    standard library. In particular, package net uses cgo on most systems,
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Sun Mar 31 09:02:45 GMT 2024
    - 42.1K bytes
    - Viewed (0)
Back to top