- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 833 for Fill (0.12 sec)
-
internal/event/target/elasticsearch.go
if err != nil { return err } eventData, eErr := target.store.Get(key.Name) if eErr != nil { // The last event key in a successful batch will be sent in the channel atmost once by the replayEvents() // Such events will not exist and wouldve been already been sent successfully. if os.IsNotExist(eErr) { return nil } return eErr } if err := target.send(eventData); err != 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) -
istioctl/pkg/checkinject/checkinject.go
Use: "check-inject [<type>/]<name>[.<namespace>]", Short: "Check the injection status or inject-ability of a given resource, explains why it is (or will be) injected or not", Long: ` Checks associated resources of the given resource, and running webhooks to examine whether the pod can be or will be injected or not.`, Example: ` # Check the injection status of a pod istioctl experimental check-inject details-v1-fcff6c49c-kqnfk.test
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 9.3K bytes - Viewed (0) -
internal/config/storageclass/storage-class.go
// the Free Software Foundation, either version 3 of the License, or // (at your option) any later version. // // This program is distributed in the hope that it will be useful // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU Affero General Public License for more details. //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 11.8K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
log.Errorf("error scanning proc: error was %s", err) return nil, err } // try again. we can still get here if the pod is in the process of being created. // in this case the CNI will be invoked soon and provide us with the netns. openNetns = s.currentPodSnapshot.Get(string(pod.UID)) if openNetns == nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
cmd/copy-part-range.go
// the Free Software Foundation, either version 3 of the License, or // (at your option) any later version. // // This program is distributed in the hope that it will be useful // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU Affero General Public License for more details. //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Jun 18 03:27:04 GMT 2021 - 2.5K bytes - Viewed (0) -
cmd/object-api-utils.go
return false } if !utf8.ValidString(object) { return false } if strings.Contains(object, `//`) { return false } // This is valid for AWS S3 but it will never // work with file systems, we will reject here // to return object name invalid rather than // a cryptic error from the file system. return !strings.ContainsRune(object, 0) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 11 11:55:34 GMT 2024 - 35.6K bytes - Viewed (1) -
cni/pkg/log/uds_test.go
) func TestUDSLog(t *testing.T) { // Start UDS log server udsSockDir := t.TempDir() udsSock := filepath.Join(udsSockDir, "cni.sock") logger := NewUDSLogger() pluginLog.SetOutputLevel(log.DebugLevel) // this will be configured by global.logging.level stop := make(chan struct{}) defer close(stop) assert.NoError(t, logger.StartUDSLogServer(udsSock, stop)) // Configure log to tee to UDS server stdout := os.Stdout
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Mar 16 00:20:01 GMT 2024 - 2.5K bytes - Viewed (0) -
internal/bucket/bandwidth/reader.go
// the Free Software Foundation, either version 3 of the License, or // (at your option) any later version. // // This program is distributed in the hope that it will be useful // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU Affero General Public License for more details. //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Sep 06 03:21:59 GMT 2023 - 3.1K bytes - Viewed (0) -
cmd/warm-backend-minio.go
// the Free Software Foundation, either version 3 of the License, or // (at your option) any later version. // // This program is distributed in the hope that it will be useful // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU Affero General Public License for more details. //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 3.8K bytes - Viewed (0) -
operator/cmd/mesh/profile-dump_test.go
outPath := filepath.Join(testDataDir, "output", tt.desc+".yaml") got, err := runProfileDump(inPath, tt.configPath, snapshotCharts, "") if err != nil { t.Fatal(err) } // installPackagePath may change, we will remove it for consistent output got = installPackagePathRegex.ReplaceAllString(got, "") if refreshGoldenFiles() { t.Logf("Refreshing golden file for %s", outPath)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jan 20 11:44:25 GMT 2022 - 3.7K bytes - Viewed (0)