Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 421 for SENT (0.02 sec)

  1. istioctl/pkg/writer/pilot/status.go

    func formatStatus(s *xdsstatus.ClientConfig_GenericXdsConfig) string {
    	switch s.GetConfigStatus() {
    	case xdsstatus.ConfigStatus_UNKNOWN:
    		return ignoredStatus
    	case xdsstatus.ConfigStatus_NOT_SENT:
    		return "NOT SENT"
    	default:
    		status := s.GetConfigStatus().String()
    		if s.LastUpdated != nil {
    			status += " (" + duration.HumanDuration(time.Since(s.LastUpdated.AsTime())) + ")"
    		}
    		return status
    	}
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 21 22:47:20 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  2. internal/event/target/nats.go

    	if err != nil {
    		return err
    	}
    
    	eventData, eErr := target.store.Get(key)
    	if eErr != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and wouldve been already been sent successfully.
    		if os.IsNotExist(eErr) {
    			return nil
    		}
    		return eErr
    	}
    
    	if err := target.send(eventData); err != nil {
    		return err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  3. common-protos/k8s.io/api/admissionregistration/v1alpha1/generated.proto

      // ObjectSelector decides whether to run the validation based on if the
      // object has matching labels. objectSelector is evaluated against both
      // the oldObject and newObject that would be sent to the cel validation, and
      // is considered to match if either object matches the selector. A null
      // object (oldObject in the case of create, or newObject in the case of
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 25.7K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt

         */
        fun goAway(
          lastGoodStreamId: Int,
          errorCode: ErrorCode,
          debugData: ByteString,
        )
    
        /**
         * Notifies that an additional `windowSizeIncrement` bytes can be sent on `streamId`, or the
         * connection if `streamId` is zero.
         */
        fun windowUpdate(
          streamId: Int,
          windowSizeIncrement: Long,
        )
    
        /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt

          assertThat(queueSize).isBetween(0L, messageCount * message.size)
          // Expect to fail before enqueueing 32 MiB.
          assertThat(messageCount).isLessThan(32L)
        }
    
        // Confirm all sent messages were received, followed by a client-initiated close.
        val server = serverListener.assertOpen()
        for (i in 0 until messageCount) {
          serverListener.assertBinaryMessage(message)
        }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 35.2K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2.kt

       *
       * ```
       * direction streamID length type flags
       * ```
       *
       * Where direction is `<<` for inbound and `>>` for outbound.
       *
       * For example, the following would indicate a HEAD request sent from the client.
       * ```
       * `<< 0x0000000f    12 HEADERS       END_HEADERS|END_STREAM
       * ```
       */
      fun frameLog(
        inbound: Boolean,
        streamId: Int,
        length: Int,
        type: Int,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  7. cmd/data-usage.go

    	backgroundHealInfoPath = bucketMetaPrefix + SlashSeparator + ".background-heal.json"
    
    	dataUsageCacheName = ".usage-cache.bin"
    )
    
    // storeDataUsageInBackend will store all objects sent on the dui channel until closed.
    func storeDataUsageInBackend(ctx context.Context, objAPI ObjectLayer, dui <-chan DataUsageInfo) {
    	attempts := 1
    	for dataUsageInfo := range dui {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  8. cmd/handler-utils.go

    	cred, _, _ = getReqAccessKeyV4(r, region, serviceS3)
    	if cred.AccessKey == "" {
    		cred, _, _ = getReqAccessKeyV2(r)
    	}
    	return cred
    }
    
    // Extract request params to be sent with event notification.
    func extractReqParams(r *http.Request) map[string]string {
    	if r == nil {
    		return nil
    	}
    
    	region := globalSite.Region()
    	cred := getReqAccessCred(r, region)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  9. internal/event/target/elasticsearch.go

    	if err != nil {
    		return err
    	}
    
    	eventData, eErr := target.store.Get(key)
    	if eErr != nil {
    		// The last event key in a successful batch will be sent in the channel atmost once by the replayEvents()
    		// Such events will not exist and wouldve been already been sent successfully.
    		if os.IsNotExist(eErr) {
    			return nil
    		}
    		return eErr
    	}
    
    	if err := target.send(eventData); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  10. docs/hotfixes.md

        which was incorrectly matching prefix based on resource
        prefixes instead of exact match.
    ```
    
    - There is always a possibility of a fix that is new, it is advised that the developer must make sure that the fix is sent upstream, reviewed and merged to the master branch.
    
    ## Creating a hotfix branch
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Feb 14 21:36:02 UTC 2024
    - 5K bytes
    - Viewed (0)
Back to top