Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 270 for save3_ (0.06 sec)

  1. internal/logger/target/kafka/kafka.go

    	return atomic.LoadInt32(&h.status) == statusOnline
    }
    
    // Send log message 'e' to kafka target.
    func (h *Target) Send(ctx context.Context, entry interface{}) error {
    	if h.store != nil {
    		// save the entry to the queue store which will be replayed to the target.
    		_, err := h.store.Put(entry)
    		return err
    	}
    	h.logChMu.RLock()
    	defer h.logChMu.RUnlock()
    	if h.logCh == nil {
    		// We are closing...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  2. cmd/bucket-replication-metrics.go

    	rx.sma.addSample(rx.Curr)
    	rx.Avg = rx.sma.simpleMovingAvg()
    	if rx.Curr > rx.Peak {
    		rx.Peak = rx.Curr
    	}
    	rx.N++
    }
    
    // ReplicationMRFStats holds stats of MRF backlog saved to disk in the last 5 minutes
    // and number of entries that failed replication after 3 retries
    type ReplicationMRFStats struct {
    	LastFailedCount uint64 `json:"failedCount_last5min"`
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/collect/ObjectArrays.java

        for (int i = 0; i < length; i++) {
          checkElementNotNull(array[i], i);
        }
        return array;
      }
    
      // We do this instead of Preconditions.checkNotNull to save boxing and array
      // creation cost.
      @CanIgnoreReturnValue
      static Object checkElementNotNull(@CheckForNull Object element, int index) {
        if (element == null) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 9K bytes
    - Viewed (0)
  4. docs/em/docs/advanced/generate-clients.md

    ### ๐Ÿ— ๐Ÿ“• ๐Ÿ‘ฉโ€๐Ÿ’ป
    
    ๐Ÿ”œ ๐Ÿ‘ˆ ๐Ÿ‘ฅ โœ”๏ธ ๐Ÿ“ฑ โฎ๏ธ ๐Ÿท, ๐Ÿ‘ฅ ๐Ÿ’ช ๐Ÿ— ๐Ÿ‘ฉโ€๐Ÿ’ป ๐Ÿ“Ÿ ๐Ÿ•ธ.
    
    #### โŽ `openapi-ts`
    
    ๐Ÿ‘† ๐Ÿ’ช โŽ `openapi-ts` ๐Ÿ‘† ๐Ÿ•ธ ๐Ÿ“Ÿ โฎ๏ธ:
    
    <div class="termy">
    
    ```console
    $ npm install @hey-api/openapi-ts --save-dev
    
    ---> 100%
    ```
    
    </div>
    
    #### ๐Ÿ— ๐Ÿ‘ฉโ€๐Ÿ’ป ๐Ÿ“Ÿ
    
    ๐Ÿ— ๐Ÿ‘ฉโ€๐Ÿ’ป ๐Ÿ“Ÿ ๐Ÿ‘† ๐Ÿ’ช โš™๏ธ ๐Ÿ“‹ โธ ๐Ÿˆธ `openapi-ts` ๐Ÿ‘ˆ ๐Ÿ”œ ๐Ÿ”œ โŽ.
    
    โ†ฉ๏ธ โšซ๏ธ โŽ ๐Ÿ‡ง๐Ÿ‡ฟ ๐Ÿ—, ๐Ÿ‘† ๐ŸŽฒ ๐Ÿšซ๐Ÿ”œ ๐Ÿ’ช ๐Ÿค™ ๐Ÿ‘ˆ ๐Ÿ“‹ ๐Ÿ”—, โœ‹๏ธ ๐Ÿ‘† ๐Ÿ”œ ๐Ÿšฎ โšซ๏ธ ๐Ÿ”› ๐Ÿ‘† `package.json` ๐Ÿ“.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  5. cmd/test-utils_test.go

    	query.Set("AWSAccessKeyId", accessKeyID)
    	// Fill in Expires for presigned query.
    	query.Set("Expires", strconv.FormatInt(epochExpires, 10))
    
    	// Encode query and save.
    	req.URL.RawQuery = query.Encode()
    
    	// Save signature finally.
    	req.URL.RawQuery += "&Signature=" + url.QueryEscape(signature)
    	return nil
    }
    
    // Sign given request using Signature V2.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  6. docs/bucket/replication/DESIGN.md

    previously replicated need to be re-synced, the `mc replicate resync start` command with optional flag of `--older-than` needs to be used to trigger re-syncing of previously replicated objects. This command generates a ResetID which is a unique UUID saved to the remote target config along with the applicable date(defaults to time of initiating the reset). All objects created prior to this date are eligible for re-replication if existing object replication is enabled for the replication rule the object...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 14.7K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt

     * from this file as necessary.
     *
     * This class also keeps a small buffer of bytes recently read from upstream. This is intended to
     * save a small amount of file I/O and data copying.
     */
    class Relay private constructor(
      /**
       * Read/write persistence of the upstream source and its metadata. Its layout is as follows:
       *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  8. tests/migrate_test.go

    		t.Errorf("AutoMigrate err:%v", err)
    	}
    	err = DB.Table("events").AutoMigrate(&Event2{})
    	if err != nil {
    		t.Errorf("AutoMigrate err:%v", err)
    	}
    
    	DB.Table("events").Save(&Event2{})
    	DB.Table("events").Save(&Event2{})
    	DB.Table("events").Save(&Event2{})
    
    	events := make([]*Event, 0)
    	DB.Table("events").Find(&events)
    
    	AssertEqual(t, 3, len(events))
    	for _, v := range events {
    		AssertEqual(t, v.ID, v.UID)
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Mar 18 11:24:16 UTC 2024
    - 56.2K bytes
    - Viewed (0)
  9. docs/bigdata/README.md

    ### **4.2 WordCount**
    
    WordCount is a simple program that counts how often a word occurs in a text file. The code builds a dataset of (String, Int) pairs called counts, and saves the dataset to a file.
    
    The following example submits WordCount code to the Scala shell. Select an input file for the Spark WordCount example. We can use any text file as input.
    
    - Login as user **โ€˜sparkโ€™**.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 14.7K bytes
    - Viewed (0)
  10. finisher_api.go

    		tx.RowsAffected = rowsAffected
    	default:
    		tx = db.getInstance()
    		tx.Statement.Dest = value
    		tx = tx.callbacks.Create().Execute(tx)
    	}
    	return
    }
    
    // Save updates value in database. If value doesn't contain a matching primary key, value is inserted.
    func (db *DB) Save(value interface{}) (tx *DB) {
    	tx = db.getInstance()
    	tx.Statement.Dest = value
    
    	reflectValue := reflect.Indirect(reflect.ValueOf(value))
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sat Sep 14 12:58:29 UTC 2024
    - 22.8K bytes
    - Viewed (0)
Back to top