Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 122 for notifiers (4.46 sec)

  1. docs/en/docs/help-fastapi.md

    If you select "Watching" instead of "Releases only" you will receive notifications when someone creates a new issue or question. You can also specify that you only want to be notified about new issues, or discussions, or PRs, etc.
    
    Then you can try and help them solve those questions.
    
    ## Ask Questions
    
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Thu Apr 18 19:53:19 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt

      /** The close reason from the peer, or null if this web socket has not yet read a close frame. */
      private var receivedCloseReason: String? = null
    
      /** True if this web socket failed and the listener has been notified. */
      private var failed = false
    
      /** Total number of pings sent by this web socket. */
      private var sentPingCount = 0
    
      /** Total number of pings received by this web socket. */
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Apr 01 14:21:25 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/interfaces.go

    	// * not be delivered at all. It's recommended to poll request progress periodically.
    	//
    	// Note: Only watches with matching context grpc metadata will be notified.
    	// https://github.com/kubernetes/kubernetes/blob/9325a57125e8502941d1b0c7379c4bb80a678d5c/vendor/go.etcd.io/etcd/client/v3/watch.go#L1037-L1042
    	//
    	// TODO: Remove when storage.Interface will be separate from etc3.store.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 07:53:48 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  4. src/vendor/golang.org/x/text/unicode/norm/composition.go

    // It flushes the buffer on each new segment start.
    func (rb *reorderBuffer) insertDecomposed(dcomp []byte) insertErr {
    	rb.tmpBytes.setBytes(dcomp)
    	// As the streamSafe accounting already handles the counting for modifiers,
    	// we don't have to call next. However, we do need to keep the accounting
    	// intact when flushing the buffer.
    	for i := 0; i < len(dcomp); {
    		info := rb.f.info(rb.tmpBytes, i)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 26 19:27:51 UTC 2019
    - 14.1K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

      private val writerQueue = taskRunner.newQueue()
    
      /** Ensures push promise callbacks events are sent in order per stream. */
      private val pushQueue = taskRunner.newQueue()
    
      /** Notifies the listener of settings changes. */
      private val settingsListenerQueue = taskRunner.newQueue()
    
      /** User code to run in response to push promise events. */
      private val pushObserver: PushObserver = builder.pushObserver
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  6. pkg/controller/serviceaccount/tokens_controller.go

    		// Retry for any error other than a NotFound
    		return !apierrors.IsNotFound(err), err
    	}
    	if liveSecret.ResourceVersion != cachedSecret.ResourceVersion {
    		// our view of the secret is not up to date
    		// we'll get notified of an update event later and get to try again
    		logger.V(2).Info("Secret is not up to date, skipping token population", "secret", klog.KRef(liveSecret.Namespace, liveSecret.Name))
    		return false, nil
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  7. samples/security/spire/spire-quickstart.yaml

                }
              }
            }
          }
    
          KeyManager "disk" {
            plugin_data {
              keys_path = "/run/spire/server/data/keys.json"
            }
          }
    
          Notifier "k8sbundle" {
            plugin_data {
              namespace = "spire"
            }
          }
        }
    
        health_checks {
          listener_enabled = true
          bind_address = "0.0.0.0"
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Oct 12 16:12:42 UTC 2023
    - 32.2K bytes
    - Viewed (0)
  8. pkg/kube/krt/collection.go

    	// Stores a map of I -> secondary dependencies (added via Fetch)
    	objectDependencies map[Key[I]][]*dependency
    
    	// eventHandlers is a list of event handlers registered for the collection. On any changes, each will be notified.
    	eventHandlers *handlers[O]
    
    	transformation TransformationMulti[I, O]
    
    	// augmentation allows transforming an object into another for usage throughout the library. See WithObjectAugmentation.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 10 23:33:56 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  9. platforms/jvm/testing-jvm-infrastructure/src/test/groovy/org/gradle/api/internal/tasks/testing/junit/JUnitTestClassProcessorTest.groovy

            1 * processor.started({ it.id == 2 && it.name == "ok" && it.className == ATestClass.name }, { it.parentId == 1 })
            1 * processor.completed(2, { it.resultType == null }) //wondering why result type is null? Failures are notified via failure() method
            1 * processor.completed(1, { it.resultType == null })
            0 * processor._
        }
    
        def "executes a JUnit 4 test class with ignored test"() {
            when:
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Sep 18 20:52:40 UTC 2023
    - 24.8K bytes
    - Viewed (0)
  10. architecture/networking/pilot.md

    #### Ingress
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Feb 07 17:53:24 UTC 2024
    - 19.1K bytes
    - Viewed (0)
Back to top