Search Options

Results per page
Sort
Preferred Languages
Advance

Results 2061 - 2070 of 2,360 for created (0.12 sec)

  1. cmd/erasure-server-pool-decom.go

    	if err != nil {
    		if errors.Is(err, errConfigNotFound) || isErrObjectNotFound(err) {
    			return nil
    		}
    		return err
    	}
    	if len(data) == 0 {
    		// Seems to be empty create a new poolMeta object.
    		return nil
    	}
    	if len(data) <= 4 {
    		return fmt.Errorf("poolMeta: no data")
    	}
    	// Read header
    	switch binary.LittleEndian.Uint16(data[0:2]) {
    	case poolMetaFormat:
    	default:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  2. ci/official/utilities/extract_resultstore_links.py

          elem.tail = indent_str
    
    
    def create_xml_file(result_store_dict: ResultDictType,
                        output_path: str,
                        verbose: bool = False):
      """Creates a JUnit-based XML file, with each invocation as a testcase."""
      os.makedirs(os.path.dirname(output_path), exist_ok=True)
      failure_count = 0
      error_count = 0
    
      date_time = datetime.datetime
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Nov 08 17:50:27 UTC 2023
    - 10.9K bytes
    - Viewed (0)
  3. internal/event/target/amqp.go

    			target.loggerOnce(context.Background(), err, target.ID().String())
    		}
    		return err
    	}
    	target.conn = conn
    
    	return nil
    }
    
    // NewAMQPTarget - creates new AMQP target.
    func NewAMQPTarget(id string, args AMQPArgs, loggerOnce logger.LogOnce) (*AMQPTarget, error) {
    	var queueStore store.Store[event.Event]
    	if args.QueueDir != "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  4. internal/event/targetlist.go

    // Init initialize target send workers.
    func (list *TargetList) Init(workers int) *TargetList {
    	startOnce.Do(func() {
    		go list.startSendWorkers(workers)
    	})
    	return list
    }
    
    // NewTargetList - creates TargetList.
    func NewTargetList(ctx context.Context) *TargetList {
    	list := &TargetList{
    		targets:     make(map[TargetID]Target),
    		queue:       make(chan asyncEvent, maxConcurrentAsyncSend),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  5. guava/src/com/google/common/collect/SparseImmutableTable.java

          // requireNonNull is safe because the cell exists in the table.
          cellColumnIndices[i++] = requireNonNull(columnKeyToIndex.get(cell.getColumnKey()));
        }
        return SerializedForm.create(this, cellRowIndices, cellColumnIndices);
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Nov 30 21:54:06 UTC 2023
    - 5.6K bytes
    - Viewed (0)
  6. guava/src/com/google/common/cache/LongAdder.java

      private static final long serialVersionUID = 7249069246863182397L;
    
      /** Version of plus for use in retryUpdate */
      @Override
      final long fn(long v, long x) {
        return v + x;
      }
    
      /** Creates a new adder with initial sum of zero. */
      public LongAdder() {}
    
      /**
       * Adds the given value.
       *
       * @param x the value to add
       */
      @Override
      public void add(long x) {
        Cell[] as;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jun 15 18:00:07 UTC 2021
    - 5.5K bytes
    - Viewed (0)
  7. cmd/bucket-policy.go

    	}
    
    	// As policy is not available for given bucket name, returns IsOwner i.e.
    	// operation is allowed only for owner.
    	return args.IsOwner
    }
    
    // NewPolicySys - creates new policy system.
    func NewPolicySys() *PolicySys {
    	return &PolicySys{}
    }
    
    func getSTSConditionValues(r *http.Request, lc string, cred auth.Credentials) map[string][]string {
    	m := make(map[string][]string)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8K bytes
    - Viewed (0)
  8. internal/event/target/webhook.go

    	yes, err := target.isActive()
    	if err != nil {
    		return err
    	}
    	if !yes {
    		return store.ErrNotConnected
    	}
    
    	return nil
    }
    
    // NewWebhookTarget - creates new Webhook target.
    func NewWebhookTarget(ctx context.Context, id string, args WebhookArgs, loggerOnce logger.LogOnce, transport *http.Transport) (*WebhookTarget, error) {
    	ctx, cancel := context.WithCancel(ctx)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  9. src/main/webapp/js/clipboard.min.js

    Symbol&&Symbol.toStringTag&&Object.defineProperty(t,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(t,"__esModule",{value:!0})},r.t=function(e,t){if(1&t&&(e=r(e)),8&t)return e;if(4&t&&"object"==typeof e&&e&&e.__esModule)return e;var n=Object.create(null);if(r.r(n),Object.defineProperty(n,"default",{enumerable:!0,value:e}),2&t&&"string"!=typeof e)for(var o in e)r.d(n,o,function(t){return e[t]}.bind(null,o));return n},r.n=function(t){var e=t&&t.__esModule?function(){return t.default}:function(){return...
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat May 28 04:16:16 UTC 2022
    - 10.5K bytes
    - Viewed (0)
  10. cmd/iam-etcd-store.go

    						isDeleteEvent := event.Type == etcd.EventTypeDelete
    
    						switch {
    						case isCreateEvent:
    							ch <- iamWatchEvent{
    								isCreated: true,
    								keyPath:   string(event.Kv.Key),
    							}
    						case isDeleteEvent:
    							ch <- iamWatchEvent{
    								isCreated: false,
    								keyPath:   string(event.Kv.Key),
    							}
    						}
    
    					}
    				}
    			}
    		}
    	}()
    	return ch
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 14K bytes
    - Viewed (0)
Back to top