- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 132 for startup (0.22 sec)
-
internal/event/target/elasticsearch.go
} if v, ok := m["version"].(map[string]interface{}); ok { if ver, ok := v["number"].(string); ok { status, err := getESVersionSupportStatus(ver) return status, ver, err } } return ESSUnknown, "", fmt.Errorf("Unable to get ES Server Version - got INFO response: %v", m) } func (c *esClientV7) isAtleastV7() bool { return true }
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/grid/connection.go
} // TODO: This causes allocations, but escape analysis doesn't really show the cause. // If another faithful engineer wants to take a stab, feel free. go func(m message) { var start time.Time if m.DeadlineMS > 0 { start = time.Now() } var b []byte var err *RemoteErr func() { defer func() { if rec := recover(); rec != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
internal/dsync/dsync_test.go
func TestThreeSimultaneousLocksForSameResource(t *testing.T) { dm1st := NewDRWMutex(ds, "aap") dm2nd := NewDRWMutex(ds, "aap") dm3rd := NewDRWMutex(ds, "aap") dm1st.Lock(id, source) started := time.Now() var expect time.Duration // Release lock after 10 seconds go func() { // TOTAL time.Sleep(2 * testDrwMutexAcquireTimeout) // fmt.Println("Unlocking dm1")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 11K bytes - Viewed (0) -
chainable_api.go
// // func AmountGreaterThan1000(db *gorm.DB) *gorm.DB { // return db.Where("amount > ?", 1000) // } // // func OrderStatus(status []string) func (db *gorm.DB) *gorm.DB { // return func (db *gorm.DB) *gorm.DB { // return db.Scopes(AmountGreaterThan1000).Where("status in (?)", status) // } // } // // db.Scopes(AmountGreaterThan1000, OrderStatus([]string{"paid", "shipped"})).Find(&orders)
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Wed Apr 17 03:38:55 GMT 2024 - 14.3K bytes - Viewed (1) -
src/archive/zip/reader.go
d.dirDiskNbr = b.uint32() // number of the disk with the start of the central directory d.dirRecordsThisDisk = b.uint64() // total number of entries in the central directory on this disk d.directoryRecords = b.uint64() // total number of entries in the central directory d.directorySize = b.uint64() // size of the central directory d.directoryOffset = b.uint64() // offset of start of central directory with respect to the starting disk number
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 27.7K bytes - Viewed (0) -
operator/cmd/mesh/manifest_shared_test.go
log.Infof("Recreating kubebuilder test environment\n") if testenv != nil { testenv.Stop() } var err error testenv = &envtest.Environment{} testRestConfig, err := testenv.Start() if err != nil { return err } _, err = kubernetes.NewForConfig(testRestConfig) testRestConfig.QPS = 50 testRestConfig.Burst = 100 if err != nil { return err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 20 22:39:28 GMT 2024 - 11.7K bytes - Viewed (1) -
cni/pkg/plugin/sidecar_redirect.go
kubevirtInterfacesKey = annotation.SidecarTrafficKubevirtInterfaces.Name annotationRegistry = map[string]*annotationParam{ "inject": {injectAnnotationKey, "", alwaysValidFunc}, "status": {sidecarStatusKey, "", alwaysValidFunc}, "redirectMode": {sidecarInterceptModeKey, defaultRedirectMode, validateInterceptionMode}, "ports": {sidecarPortListKey, "", validatePortList},
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.6K bytes - Viewed (0) -
src/archive/zip/struct.go
// See the [ZIP specification] for details. // // [ZIP specification]: https://support.pkware.com/pkzip/appnote type FileHeader struct { // Name is the name of the file. // // It must be a relative path, not start with a drive letter (such as "C:"), // and must use forward slashes instead of back slashes. A trailing slash // indicates that this file is a directory and should have no data. Name string
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 12.1K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
currentPodSnapshot: podNsMap, podNs: podNs, iptablesConfigurator: iptablesConfigurator, netnsRunner: NetnsDo, hostsideProbeIPSet: probeSet, } } func (s *NetServer) Start(ctx context.Context) { log.Debug("starting ztunnel server") go s.ztunnelServer.Run(ctx) } func (s *NetServer) Stop() { log.Debug("removing host iptables rules") s.iptablesConfigurator.DeleteHostRules()
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/signature-v4-utils_test.go
if err != nil { t.Fatalf("unable create credential, %s", err) } _, err = globalIAMSys.CreateUser(ctx, ucreds.AccessKey, madmin.AddOrUpdateUserReq{ SecretKey: ucreds.SecretKey, Status: madmin.AccountEnabled, }) if err != nil { t.Fatalf("unable create credential, %s", err) } _, owner, s3Err = checkKeyValid(req, ucreds.AccessKey) if s3Err != ErrNone {
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)