Search Options

Results per page
Sort
Preferred Languages
Advance

Results 2311 - 2320 of 2,475 for created (0.08 sec)

  1. cmd/bucket-stats.go

    	}
    }
    
    // Empty returns true if there are no target stats
    func (brs *BucketReplicationStats) Empty() bool {
    	return len(brs.Stats) == 0 && brs.ReplicaSize == 0
    }
    
    // Clone creates a new BucketReplicationStats copy
    func (brs BucketReplicationStats) Clone() (c BucketReplicationStats) {
    	// This is called only by replicationStats cache and already holds a
    	// read lock before calling Clone()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 11:39:51 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

          routes = routes,
          attempt = 0,
          tunnelRequest = tunnelRequest,
          connectionSpecIndex = -1,
          isTlsFallback = false,
        )
      }
    
      /**
       * Returns a request that creates a TLS tunnel via an HTTP proxy. Everything in the tunnel request
       * is sent unencrypted to the proxy server, so tunnels include only the minimum set of headers.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 12K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/collect/Multiset.java

     *
     * <p>In addition to these required methods, implementations of {@code Multiset} are expected to
     * provide two {@code static} creation methods: {@code create()}, returning an empty multiset, and
     * {@code create(Iterable<? extends E>)}, returning a multiset containing the given initial
     * elements. This is simply a refinement of {@code Collection}'s constructor recommendations,
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Jun 17 14:40:53 UTC 2023
    - 19.7K bytes
    - Viewed (0)
  4. internal/logger/target/kafka/kafka.go

    	logCh := h.logCh
    	if logCh != nil {
    		// We are not allowed to add when logCh is nil
    		h.wg.Add(1)
    		defer h.wg.Done()
    
    	}
    	h.logChMu.RUnlock()
    
    	if logCh == nil {
    		return
    	}
    
    	// Create a routine which sends json logs received
    	// from an internal channel.
    	for entry := range logCh {
    		h.logEntry(entry)
    	}
    }
    
    func (h *Target) logEntry(entry interface{}) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/ws/WebSocketRecorder.kt

      private val name: String,
    ) : WebSocketListener() {
      private val events = LinkedBlockingQueue<Any>()
      private var delegate: WebSocketListener? = null
    
      /** Sets a delegate for handling the next callback to this listener. Cleared after invoked.  */
      fun setNextEventDelegate(delegate: WebSocketListener?) {
        this.delegate = delegate
      }
    
      override fun onOpen(
        webSocket: WebSocket,
        response: Response,
      ) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  6. istioctl/pkg/validate/validate.go

    			_, _ = fmt.Fprintf(writer, "%q has warnings: %v\n", fname, warningToString(w))
    		} else {
    			_, _ = fmt.Fprintf(writer, "%q is valid\n", fname)
    		}
    	}
    
    	return nil
    }
    
    // NewValidateCommand creates a new command for validating Istio k8s resources.
    func NewValidateCommand(ctx cli.Context) *cobra.Command {
    	var filenames []string
    	var referential bool
    
    	c := &cobra.Command{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 22:27:47 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  7. schema/field.go

    		} else {
    			field.Readable = true
    		}
    	}
    
    	if v, ok := field.TagSettings["<-"]; ok {
    		field.Creatable = true
    		field.Updatable = true
    
    		if v != "<-" {
    			if !strings.Contains(v, "create") {
    				field.Creatable = false
    			}
    
    			if !strings.Contains(v, "update") {
    				field.Updatable = false
    			}
    		}
    	}
    
    	// Normal anonymous field or having `EMBEDDED` tag
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Apr 15 03:20:20 UTC 2024
    - 32K bytes
    - Viewed (0)
  8. cmd/common-main.go

    	dirAbs, err := filepath.Abs(dir)
    	if err != nil {
    		return nil, err
    	}
    	err = mkdirAllIgnorePerm(dirAbs)
    	if err != nil {
    		return nil, fmt.Errorf("unable to create the directory `%s`: %w", dirAbs, err)
    	}
    
    	return &ConfigDir{path: dirAbs}, nil
    }
    
    func buildServerCtxt(ctx *cli.Context, ctxt *serverCtxt) (err error) {
    	// Get "json" flag from command line argument and
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 31.7K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/CollectCollectors.java

          Function<? super T, ? extends E> elementFunction, ToIntFunction<? super T> countFunction) {
        checkNotNull(elementFunction);
        checkNotNull(countFunction);
        return Collector.of(
            LinkedHashMultiset::create,
            (multiset, t) ->
                multiset.add(checkNotNull(elementFunction.apply(t)), countFunction.applyAsInt(t)),
            (multiset1, multiset2) -> {
              multiset1.addAll(multiset2);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  10. istioctl/pkg/admin/istiodconfig.go

    			}
    			return nil
    		},
    		RunE: func(logCmd *cobra.Command, args []string) error {
    			client, err := ctx.CLIClientWithRevision(opts.Revision)
    			if err != nil {
    				return fmt.Errorf("failed to create k8s client: %v", err)
    			}
    
    			var podName, ns string
    			if len(args) == 0 {
    				if opts.Revision == "" {
    					opts.Revision = "default"
    				}
    				if len(istiodLabelSelector) > 0 {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Apr 13 05:23:38 UTC 2024
    - 13.5K bytes
    - Viewed (0)
Back to top