- Sort Score
- Result 10 results
- Languages All
Results 171 - 180 of 270 for save3_ (0.12 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)