Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for rubbish (0.13 sec)

  1. docs/bucket/notifications/README.md

    notify_webhook        publish bucket notifications to webhook endpoints
    notify_amqp           publish bucket notifications to AMQP endpoints
    notify_kafka          publish bucket notifications to Kafka endpoints
    notify_mqtt           publish bucket notifications to MQTT endpoints
    notify_nats           publish bucket notifications to NATS endpoints
    notify_nsq            publish bucket notifications to NSQ endpoints
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 84K bytes
    - Viewed (0)
  2. .teamcity/test-buckets.json

    					"name":"TestDistribution"
    				},
    				"subprojects":[
    					"composite-builds",
    					"internal-integ-testing",
    					"jvm-services",
    					"flow-services",
    					"persistent-cache",
    					"publish",
    					"base-services",
    					"process-memory-services",
    					"problems-api",
    					"plugins-java-base",
    					"build-cache"
    				]
    			},
    			{
    				"parallelizationMethod":{
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Tue Oct 08 11:14:16 UTC 2024
    - 87.8K bytes
    - Viewed (0)
  3. cmd/peer-rest-server.go

    	// Trace Publisher uses nonblocking publish and hence does not wait for slow subscribers.
    	// Use buffered channel to take care of burst sends or slow w.Write()
    	err = globalTrace.SubscribeJSON(traceOpts.TraceTypes(), out, ctx.Done(), func(entry madmin.TraceInfo) bool {
    		return shouldTrace(entry, traceOpts)
    	}, &wg)
    	if err != nil {
    		return grid.NewRemoteErr(err)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  4. cmd/batch-handlers.go

    		if globalTrace.NumSubscribers(madmin.TraceBatch) > 0 {
    			globalTrace.Publish(batchJobTrace(d, job, startTime, duration, info, attempts, err))
    			return
    		}
    		switch d {
    		case batchJobMetricReplication:
    			if globalTrace.NumSubscribers(madmin.TraceBatchReplication) > 0 {
    				globalTrace.Publish(batchJobTrace(d, job, startTime, duration, info, attempts, err))
    			}
    		case batchJobMetricKeyRotation:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/Futures.java

      // propagate to the input. Cancellation propagation is fundamentally racy so this is fine.
      //
      // Future versions of the JMM may revise safe construction semantics in such a way that we can
      // safely publish these objects and we won't need this whole discussion.
      // TODO(user,lukes): consider adding volatile to all these fields since in current known JVMs
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/Futures.java

      // propagate to the input. Cancellation propagation is fundamentally racy so this is fine.
      //
      // Future versions of the JMM may revise safe construction semantics in such a way that we can
      // safely publish these objects and we won't need this whole discussion.
      // TODO(user,lukes): consider adding volatile to all these fields since in current known JVMs
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.4K bytes
    - Viewed (0)
  7. src/cmd/cgo/gcc.go

    				tagGen++
    				anonymousStructTag[dt] = tag
    			}
    		} else if t.C.Empty() {
    			t.C.Set(dt.Kind + " " + tag)
    		}
    		name := c.Ident("_Ctype_" + dt.Kind + "_" + tag)
    		t.Go = name // publish before recursive calls
    		goIdent[name.Name] = name
    		if dt.ByteSize < 0 {
    			// Don't override old type
    			if _, ok := typedef[name.Name]; ok {
    				break
    			}
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Sep 18 15:07:34 UTC 2024
    - 97.1K bytes
    - Viewed (0)
Back to top