Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 761 - 770 of 1,039 for take (0.07 seconds)

  1. internal/logger/target/kafka/kafka_scram_client_contrib.go

    	x.Client, err = x.NewClient(userName, password, authzID)
    	if err != nil {
    		return err
    	}
    	x.ClientConversation = x.NewConversation()
    	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
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  2. docs/en/docs/how-to/configure-swagger-ui.md

    `swagger_ui_parameters` receives a dictionary with the configurations passed to Swagger UI directly.
    
    FastAPI converts the configurations to **JSON** to make them compatible with JavaScript, as that's what Swagger UI needs.
    
    ## Disable Syntax Highlighting { #disable-syntax-highlighting }
    
    For example, you could disable syntax highlighting in Swagger UI.
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 20:41:43 GMT 2025
    - 2.9K bytes
    - Click Count (0)
  3. docs/iam/access-manager-plugin.go

    	if err != nil {
    		writeErrorResponse(w, err)
    		return
    	}
    
    	var out bytes.Buffer
    	json.Indent(&out, body, "", "  ")
    	fmt.Printf("Received JSON payload:\n%s\n", out.String())
    
    	reqMap := make(map[string]interface{})
    	err = json.Unmarshal(body, &reqMap)
    	if err != nil {
    		writeErrorResponse(w, err)
    		return
    	}
    
    	m := reqMap["input"].(map[string]interface{})
    	accountValue := m["account"].(string)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Feb 08 17:15:20 GMT 2024
    - 2.7K bytes
    - Click Count (0)
  4. internal/event/target/nats_contrib_test.go

    	}
    	defer con.Close()
    }
    
    func TestNatsConnNKeySeed(t *testing.T) {
    	opts := natsserver.DefaultTestOptions
    	opts.Port = 14223
    	opts.Nkeys = []*server.NkeyUser{
    		{
    			// Not a real NKey
    			// Taken from https://docs.nats.io/running-a-nats-service/configuration/securing_nats/auth_intro/nkey_auth
    			Nkey: "UDXU4RCSJNZOIQHZNWXHXORDPRTGNJAHAHFRGZNEEJCPQTT2M7NLCNF4",
    		},
    	}
    	s := natsserver.RunServer(&opts)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Apr 27 04:30:57 GMT 2025
    - 3K bytes
    - Click Count (0)
  5. internal/bucket/lifecycle/and.go

    		return errXMLNotWellFormed
    	}
    	return nil
    }
    
    // ContainsDuplicateTag - returns true if duplicate keys are present in And
    func (a And) ContainsDuplicateTag() bool {
    	x := make(map[string]struct{}, len(a.Tags))
    
    	for _, t := range a.Tags {
    		if _, has := x[t.Key]; has {
    			return true
    		}
    		x[t.Key] = struct{}{}
    	}
    
    	return false
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 2.9K bytes
    - Click Count (0)
  6. cmd/background-heal-ops.go

    		} else {
    			workers = numHealers
    		}
    	}
    
    	if workers == 0 {
    		workers = 4
    	}
    
    	return &healRoutine{
    		tasks:   make(chan healTask),
    		workers: workers,
    	}
    }
    
    // healDiskFormat - heals format.json, return value indicates if a
    // failure error occurred.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  7. internal/bucket/lifecycle/evaluator.go

    			return true
    		}
    	}
    	return false
    }
    
    // eval will return a lifecycle event for each object in objs for a given time.
    func (e *Evaluator) eval(objs []ObjectOpts, now time.Time) []Event {
    	events := make([]Event, len(objs))
    	var newerNoncurrentVersions int
    loop:
    	for i, obj := range objs {
    		event := e.policy.eval(obj, now, newerNoncurrentVersions)
    		switch event.Action {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Apr 08 15:41:24 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  8. build-logic/jvm/src/main/kotlin/gradlebuild/startscript/tasks/GradleStartScriptGenerator.kt

        fun File.injectAgentOptions(separator: String) {
            if (agentJarNames.isEmpty()) {
                return
            }
            var replacementsCount = 0
            // readLines eats EOLs, so we need to use postfix to make sure the last line ends with EOL too.
            writeBytes(readLines().joinToString(separator = separator, postfix = separator) { line ->
                when {
                    // We assume that the declaration is not empty.
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Tue Apr 08 01:46:59 GMT 2025
    - 6.3K bytes
    - Click Count (0)
  9. docs/en/docs/advanced/openapi-webhooks.md

    With **FastAPI**, using OpenAPI, you can define the names of these webhooks, the types of HTTP operations that your app can send (e.g. `POST`, `PUT`, etc.) and the request **bodies** that your app would send.
    
    This can make it a lot easier for your users to **implement their APIs** to receive your **webhook** requests, they might even be able to autogenerate some of their own API code.
    
    /// info
    
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 20:41:43 GMT 2025
    - 2.9K bytes
    - Click Count (0)
  10. cmd/endpoint-ellipses_test.go

    			false,
    		},
    		{
    			[]string{"data{1...64}"},
    			nil,
    			nil,
    			2,
    			false,
    		},
    	}
    
    	for _, testCase := range testCases {
    		t.Run("", func(t *testing.T) {
    			argPatterns := make([]ellipses.ArgPattern, len(testCase.args))
    			for i, arg := range testCase.args {
    				patterns, err := ellipses.FindEllipsesPatterns(arg)
    				if err != nil {
    					t.Fatalf("Unexpected failure %s", err)
    				}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.1K bytes
    - Click Count (0)
Back to Top