- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 32 for Adel (0.22 sec)
-
cmd/xl-storage-format-v2_test.go
}, { name: "del-on-one", input: [][]xlMetaV2ShallowVersion{ 0: {vDelMarker, vObj}, // disk 0 1: {vObj}, // disk 1 2: {vObj}, // disk 2 }, quorum: 2, reqVersions: 0, want: []xlMetaV2ShallowVersion{vObj}, }, { name: "del-on-two", input: [][]xlMetaV2ShallowVersion{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 17:50:48 GMT 2024 - 36.4K bytes - Viewed (0) -
internal/event/target/elasticsearch.go
if err := target.send(eventData); err != nil { if xnet.IsNetworkOrHostDown(err, false) { return store.ErrNotConnected } return err } // Delete the event from store. return target.store.Del(key.Name) } // Close - does nothing and available for interface compatibility. func (target *ElasticsearchTarget) Close() error { close(target.quitCh) if target.client != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 15K bytes - Viewed (0) -
internal/event/target/amqp.go
return nil } return eErr } if err := target.send(eventData, ch, confirms); err != nil { return err } // Delete the event from store. return target.store.Del(key.Name) } // Close - does nothing and available for interface compatibility. func (target *AMQPTarget) Close() error { close(target.quitCh) if target.conn != nil { return target.conn.Close() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 10K bytes - Viewed (0) -
internal/event/target/kafka.go
} if err := target.send(eventData); err != nil { if isKafkaConnErr(err) { return store.ErrNotConnected } return err } // Delete the event from store. return target.store.Del(key.Name) } func (target *KafkaTarget) addToBatch(key store.Key) error { if target.batch.IsFull() { if err := target.commitBatch(); err != nil { return err } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 20 08:16:35 GMT 2024 - 13K bytes - Viewed (0) -
internal/event/target/nats.go
if os.IsNotExist(eErr) { return nil } return eErr } if err := target.send(eventData); err != nil { return err } return target.store.Del(key.Name) } // Close - closes underneath connections to NATS server. func (target *NATSTarget) Close() (err error) { close(target.quitCh) if target.stanConn != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 27 18:11:55 GMT 2024 - 12.8K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
return err } atomic.AddInt64(&h.totalMessages, 1) err = h.send(auditEntry) if err != nil { atomic.AddInt64(&h.failedMessages, 1) return } // Delete the event from store. return h.store.Del(key.Name) } // Cancel - cancels the target func (h *Target) Cancel() { // If queuestore is configured, cancel it's context to // stop the replay go-routine. if h.store != nil { h.storeCtxCancel()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1) -
cmd/admin-handlers-users_test.go
if err != nil { c.Fatalf("user could not be deleted: %v", err) } err = s.adm.RemoveCannedPolicy(ctx, policy1) if err != nil { c.Fatalf("policy del err: %v", err) } err = s.adm.RemoveCannedPolicy(ctx, policy2) if err != nil { c.Fatalf("policy del err: %v", err) } } func (s *TestSuiteIAM) TestPolicyCreate(c *check) { ctx, cancel := context.WithTimeout(context.Background(), testDefaultTimeout)
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/signature-v2.go
if !compareSignatureV2(gotSignature, expectedSignature) { return ErrSignatureDoesNotMatch } r.Form.Del(xhttp.Expires) return ErrNone } func getReqAccessKeyV2(r *http.Request) (auth.Credentials, bool, APIErrorCode) { if accessKey := r.Form.Get(xhttp.AmzAccessKeyID); accessKey != "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 12.2K bytes - Viewed (0) -
internal/event/target/postgresql.go
} if err := target.send(eventData); err != nil { if IsConnErr(err) { return store.ErrNotConnected } return err } // Delete the event from store. return target.store.Del(key.Name) } // Close - closes underneath connections to PostgreSQL database. func (target *PostgreSQLTarget) Close() error { close(target.quitCh) if target.updateStmt != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 17:51:07 GMT 2024 - 13.3K bytes - Viewed (0) -
cmd/signature-v4-utils_test.go
if errCode != ErrUnsignedHeaders { t.Fatalf("Expected the APIErrorCode to be %d, but got %d", ErrUnsignedHeaders, errCode) } // Delete extra metadata from header to don't affect other test inputHeader.Del("X-Amz-Meta-Clone") // calling the function being tested. errCode = checkMetaHeaders(signedHeadersMap, r) if errCode != ErrNone { t.Fatalf("Expected the APIErrorCode to be %d, but got %d", ErrNone, errCode) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 05 21:26:41 GMT 2024 - 14.3K bytes - Viewed (0)