- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 26 for triggered (0.47 sec)
-
internal/event/event.go
ConfigurationID string `json:"configurationId"` Bucket Bucket `json:"bucket"` Object Object `json:"object"` } // Source represents client information who triggered the event. type Source struct { Host string `json:"host"` Port string `json:"port"` UserAgent string `json:"userAgent"` } // Event represents event notification information defined in
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Jun 20 00:53:08 GMT 2023 - 3.4K bytes - Viewed (0) -
internal/bucket/replication/replication.go
switch t { case ObjectReplicationType, HealReplicationType, ExistingObjectReplicationType: return true } return false } // ObjectOpts provides information to deduce whether replication // can be triggered on the resultant object. type ObjectOpts struct { Name string UserTags string VersionID string DeleteMarker bool SSEC bool OpType Type Replica bool
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 8.9K bytes - Viewed (0) -
internal/bucket/lifecycle/lifecycle.go
continue } rules = append(rules, rule) } return rules } // ObjectOpts provides information to deduce the lifecycle actions // which can be triggered on the resultant object. type ObjectOpts struct { Name string UserTags string ModTime time.Time Size int64 VersionID string IsLatest bool
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Mar 09 06:41:22 GMT 2024 - 17K bytes - Viewed (0) -
cni/pkg/install/install.go
if err != nil { return err } defer func() { setNotReady(in.isReady) watcher.Close() }() // Before we process whether any file events have been triggered, we must check that the file is correct // at this moment, and if not, yield. This is to catch other CNIs which might have mutated the file between
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 10.8K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
// wait for an update event mt.Assert(EventTotals.Name(), map[string]string{"type": "update"}, monitortest.AtLeast(2)) // wait for the pod to be annotated // after Pod annotated, another update event will be triggered. assertPodAnnotated(t, client, pod) // Assert expected calls actually made fs.AssertExpectations(t) // unlabelling the namespace should cause only one RemovePodFromMesh to happen
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Feb 08 01:03:24 GMT 2024 - 15.8K bytes - Viewed (0) -
src/cmd/asm/internal/lex/lex_test.go
continue } if !strings.Contains(err.Error(), test.error) { t.Errorf("got error %q expected %q", err.Error(), test.error) } } } // firstError returns the first error value triggered by the input. func firstError(input *Input) (err error) { panicOnError = true defer func() { panicOnError = false switch e := recover(); e := e.(type) { case nil: case error: err = e
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Aug 29 07:48:38 GMT 2023 - 5.8K bytes - Viewed (0) -
internal/lock/lock_windows_test.go
for _, test := range []struct{ in, want string }{ // Short; unchanged: {`C:\short.txt`, `C:\short.txt`}, {`C:\`, `C:\`}, {`C:`, `C:`}, // The "long" substring is replaced by a looooooong // string which triggers the rewriting. Except in the // cases below where it doesn't. {`C:\long\foo.txt`, `\\?\C:\long\foo.txt`}, {`C:/long/foo.txt`, `\\?\C:\long\foo.txt`}, {`C:\long\foo\\bar\.\baz\\`, `\\?\C:\long\foo\bar\baz`},
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Oct 18 18:08:15 GMT 2023 - 2.2K bytes - Viewed (0) -
cmd/erasure-decode.go
p.orgReaders[bufIdx] = nil p.readers[i] = nil // Since ReadAt returned error, trigger another read. readTriggerCh <- true return } newBufLK.Lock() newBuf[bufIdx] = p.buf[bufIdx][:n] newBufLK.Unlock() // Since ReadAt returned success, there is no need to trigger another read. readTriggerCh <- false }(readerIndex) readerIndex++ } wg.Wait()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 9.4K bytes - Viewed (0) -
src/bufio/scan_test.go
if *c > 0 { *c-- return 1, data[:1], nil } return 0, nil, nil } // Check that the looping-at-EOF check doesn't trigger for merely empty tokens. func TestEmptyLinesOK(t *testing.T) { c := countdown(10000) s := NewScanner(strings.NewReader(strings.Repeat("\n", 10000))) s.Split(c.split) for s.Scan() { } if s.Err() != nil {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Sep 22 16:22:42 GMT 2023 - 14.3K bytes - Viewed (0) -
src/archive/tar/reader.go
// Do this because Seek is often lazy about reporting errors; this will mask // the fact that the stream may be truncated. We can rely on the // io.CopyN done shortly afterwards to trigger any IO errors. var seekSkipped int64 // Number of bytes skipped via Seek if sr, ok := r.(io.Seeker); ok && n > 1 { // Not all io.Seeker can actually Seek. For example, os.Stdin implements
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Mar 08 01:59:14 GMT 2024 - 26.8K bytes - Viewed (0)