- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 41 for del (0.17 sec)
-
cni/test/install_cni.go
t.Logf("PASS: File %v was added to %v", f, tempCNIBinDir) return nil } else if op == "del" { return fmt.Errorf("FAIL: File %v was not removed from %v", f, tempCNIBinDir) } } else { if op == "add" { return fmt.Errorf("FAIL: File %v was not added to %v", f, tempCNIBinDir) } else if op == "del" { t.Logf("PASS: File %v was removed from %v", f, tempCNIBinDir) return nil } } }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
case <-ctx.Done(): return nil } } } func (z *ztunnelServer) PodDeleted(ctx context.Context, uid string) error { r := &zdsapi.WorkloadRequest{ Payload: &zdsapi.WorkloadRequest_Del{ Del: &zdsapi.DelWorkload{ Uid: uid, }, }, } data, err := proto.Marshal(r) if err != nil { return err } log.Debugf("sending delete pod to ztunnel: %s %v", uid, r)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
internal/store/queuestore.go
} if err = json.Unmarshal(eventData, &item); err != nil { return item, err } return item, nil } // Del - Deletes an entry from the store. func (store *QueueStore[_]) Del(key string) error { store.Lock() defer store.Unlock() return store.del(key) } // DelList - Deletes a list of entries from the store. // Returns an error even if one key fails to be deleted.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 7.1K bytes - Viewed (0) -
internal/crypto/header.go
// It has the same semantics as RemoveSensitiveEntries. func RemoveSensitiveHeaders(h http.Header) { h.Del(xhttp.AmzServerSideEncryptionCustomerKey) h.Del(xhttp.AmzServerSideEncryptionCopyCustomerKey) h.Del(xhttp.AmzMetaUnencryptedContentLength) h.Del(xhttp.AmzMetaUnencryptedContentMD5) } // SSECopy represents AWS SSE-C for copy requests. It provides // functionality to handle SSE-C copy requests.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 2.9K bytes - Viewed (0) -
internal/event/target/mqtt.go
if os.IsNotExist(err) { return nil } return err } if err = target.send(eventData); err != nil { return err } // Delete the event from store. return target.store.Del(key.Name) } // Save - saves the events to the store if queuestore is configured, which will // be replayed when the mqtt connection is active. func (target *MQTTTarget) Save(eventData event.Event) error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 8.2K bytes - Viewed (0) -
cmd/os-reliable_test.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Sep 13 15:14:36 GMT 2023 - 3.1K bytes - Viewed (0) -
internal/store/queuestore_test.go
if err != nil { t.Fatal(err) } // Remove all the items. if len(itemKeys) == 20 { for _, key := range itemKeys { err := store.Del(strings.TrimSuffix(key, testItemExt)) if err != nil { t.Fatal("queue store Del failed with ", err) } } } else { t.Fatalf("List() Expected: 20, got %d", len(itemKeys)) } names, err := store.List() if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 04 17:52:24 GMT 2023 - 5.9K bytes - Viewed (0) -
cmd/bucket-policy.go
if lc != "" { args["LocationConstraint"] = []string{lc} } cloneHeader := r.Header.Clone() if v := cloneHeader.Get("x-amz-signature-age"); v != "" { args["signatureAge"] = []string{v} cloneHeader.Del("x-amz-signature-age") } if userTags := cloneHeader.Get(xhttp.AmzObjectTagging); userTags != "" { tag, _ := tags.ParseObjectTags(userTags) if tag != nil { tagMap := tag.ToMap()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 8K 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/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)