- Sort Score
- Result 10 results
- Languages All
Results 21 - 28 of 28 for execute (1.79 sec)
-
internal/dsync/drwmutex.go
case <-refreshTimer.C: noQuorum, err := refreshLock(ctx, dm.clnt, id, source, quorum) if err == nil && noQuorum { // Clean the lock locally and in remote nodes forceUnlock(ctx, dm.clnt, id) // Execute the caller lock loss callback if lockLossCallback != nil { lockLossCallback() } return } refreshTimer.Reset(dm.refreshInterval) } } }() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
docs/bucket/notifications/README.md
print(" [x] %r" % body) channel.basic_consume(callback, queue=queue_name, no_ack=False) channel.start_consuming() ``` Execute this example python program to watch for RabbitMQ events on the console. ```py python rabbit.py ``` Open another terminal and upload a JPEG image into `images` bucket. ```
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 84K bytes - Viewed (2) -
cmd/admin-handlers-users_test.go
sum := sha256.Sum256(buf) req.Header.Set("X-Amz-Content-Sha256", hex.EncodeToString(sum[:])) req.Body = io.NopCloser(bytes.NewReader(buf)) req = signer.SignV4(*req, accessKey, secretKey, "", "") // 3.1 Execute the request. resp, err := s.TestSuiteCommon.client.Do(req) if err != nil { c.Fatalf("unexpected request err: %v", err) } if resp.StatusCode != 200 { c.Fatalf("got unexpected response: %#v\n", resp) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 12 16:36:16 GMT 2024 - 45.7K bytes - Viewed (0) -
cmd/xl-storage_test.go
t.Fatalf("Unable to create file, %s", err.Error()) } // Parent directory must have write permissions, this is read + execute. if err = os.Chmod(pathJoin(path, "no-permissions"), 0o555); err != nil { t.Fatalf("Unable to chmod directory, %s", err.Error()) } t.Cleanup(func() { os.Chmod(pathJoin(path, "no-permissions"), 0o775) })
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 17:45:28 GMT 2024 - 66.7K bytes - Viewed (0) -
internal/bucket/replication/replication.go
} if rule.ExistingObjectReplication.Status == Enabled { return true, true } } } return hasARN, false } // FilterActionableRules returns the rules actions that need to be executed // after evaluating prefix/tag filtering func (c Config) FilterActionableRules(obj ObjectOpts) []Rule { if obj.Name == "" && !(obj.OpType == ResyncReplicationType || obj.OpType == AllReplicationType) { return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 8.9K bytes - Viewed (0) -
CREDITS
be required to provide such information under section 6 of the GNU GPL, and only to the extent that such information is necessary to install and execute a modified version of the Combined Work produced by recombining or relinking the Application with a modified version of the Linked Version. (If you use option 4d0, the Installation Information must accompany
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:31:35 GMT 2024 - 1.6M bytes - Viewed (0) -
cmd/veeam-sos-api.go
// Vendors might change the settings based on the configuration and scale out of the solution (more storage nodes => // higher task limit). // // <S3ConcurrentTaskLimit> // // - Defines how many S3 operations are executed parallel within one Repository Task Slot (and within one backup object // that gets offloaded). The same registry key setting overwrites the storage-defined setting. // Optional value, default 64, range: 1-unlimited //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 18:43:58 GMT 2024 - 8.2K bytes - Viewed (2) -
internal/event/target/mysql.go
// FIXME: log returned error. ignore time being. _ = target.insertStmt.Close() } if target.db != nil { return target.db.Close() } return nil } // Executes the table creation statements. func (target *MySQLTarget) executeStmts() error { _, err := target.db.Exec(fmt.Sprintf(mysqlTableExists, target.args.Table)) if err != nil { createStmt := mysqlCreateNamespaceTable
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 11.5K bytes - Viewed (0)