- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 76 for conker (0.75 sec)
-
internal/event/target/nats.go
return false, store.ErrNotConnected } } if connErr != nil { if connErr.Error() == nats.ErrNoServers.Error() { return false, store.ErrNotConnected } return false, connErr } if target.natsConn != nil && target.args.JetStream.Enable { target.jstream, connErr = target.natsConn.JetStream() if connErr != nil { if connErr.Error() == nats.ErrNoServers.Error() {
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) -
utils/tests/utils.go
} } if reflect.ValueOf(got).Type().ConvertibleTo(reflect.ValueOf(expect).Type()) { got = reflect.ValueOf(got).Convert(reflect.ValueOf(expect).Type()).Interface() isEqual() } else if reflect.ValueOf(expect).Type().ConvertibleTo(reflect.ValueOf(got).Type()) { expect = reflect.ValueOf(got).Convert(reflect.ValueOf(got).Type()).Interface() isEqual() } else {
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Fri Mar 10 09:21:56 GMT 2023 - 3.9K bytes - Viewed (0) -
internal/s3select/sql/value.go
a.setInt(iA) } else if fA, ok := a.bytesToFloat(); ok { a.setFloat(fA) } else { return fmt.Errorf("Could not convert %s to a number", a.String()) } case bool: if bA, ok := a.bytesToBool(); ok { a.setBool(bA) } else { return fmt.Errorf("Could not convert %s to a boolean", a.String()) } default: return errCmpMismatchedTypes } return nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 25 20:31:19 GMT 2022 - 20.2K bytes - Viewed (0) -
cni/pkg/install/kubeconfig.go
Cluster: clusterName, }, }, CurrentContext: contextName, } lcfg, err := latest.Scheme.ConvertToVersion(kcfg, latest.ExternalVersion) if err != nil { return kubeconfig{}, err } // Convert to v1 schema which has proper encoding fullYaml, err := yaml.Marshal(lcfg) if err != nil { return kubeconfig{}, err } // Log with redaction if err := api.RedactSecrets(kcfg); err != nil {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Aug 11 01:19:03 GMT 2023 - 4.9K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
mergeCh := make(chan []byte, globalAPIConfig.getRequestsPoolCapacity()*len(globalEndpoints.Hostnames())) localCh := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity()) // Convert local messages to JSON and send to mergeCh go func() { buf := bytes.NewBuffer(grid.GetByteBuffer()[:0]) enc := json.NewEncoder(buf) tmpEvt := struct{ Records []event.Event }{[]event.Event{{}}} for {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
internal/s3select/simdj/record.go
case simdjson.TypeInt: v, err := iter.Int() if err != nil { return nil, err } return sql.FromInt(v), nil case simdjson.TypeUint: v, err := iter.Int() if err != nil { // Can't fit into int, convert to float. v, err := iter.Float() return sql.FromFloat(v), err } return sql.FromInt(v), nil case simdjson.TypeBool: v, err := iter.Bool() if err != nil { return nil, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 5.4K bytes - Viewed (0) -
operator/cmd/mesh/test-util_test.go
t.Helper() got := mustGetPath(t, obj, path) conv, ok := got.(map[string]any) if !ok { t.Fatalf("could not convert %v", got) } ret := map[string]string{} for k, v := range conv { sv, ok := v.(string) if !ok { t.Fatalf("could not convert to string %v", v) } ret[k] = sv } return ret } func mustGetPath(t test.Failer, obj object.K8sObject, path string) any {
Go - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Tue Oct 31 14:48:28 GMT 2023 - 15.3K bytes - Viewed (0) -
istioctl/pkg/multicluster/remote_secret.go
remoteSecret, warn, err := createRemoteSecret(opt, client) if err != nil { return "", warn, err } // convert any binary data to the string equivalent for easier review. The // kube-apiserver will convert this to binary before it persists it to storage. remoteSecret.StringData = make(map[string]string, len(remoteSecret.Data)) for k, v := range remoteSecret.Data {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Oct 11 01:43:17 GMT 2023 - 24K bytes - Viewed (0) -
callbacks/create.go
if i, ok := value.(AfterSaveInterface); ok { called = true db.AddError(i.AfterSave(tx)) } } return called }) } } // ConvertToCreateValues convert to create values func ConvertToCreateValues(stmt *gorm.Statement) (values clause.Values) { curTime := stmt.DB.NowFunc() switch value := stmt.Dest.(type) { case map[string]interface{}:
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Mon Apr 08 03:29:55 GMT 2024 - 12.5K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns.go
// - /docker/8d461fa5765781bcf5f7eb192f101bc3103d4b932e26236f43feecfa20664f96/kubepods/besteffort/poddaa5c7ee-3484-4533-af39-3591564fd03e/aff34703e5e1f89443e9a1bffcc80f43f74d4808a2dd22c8f88c08547b323934 // - /kubepods.slice/kubepods-burstable.slice/kubepods-burstable-pod2c48913c-b29f-11e7-9350-020968147796.slice/docker-9bca8d63d5fa610783847915bcff0ecac1273e5b4bed3f6fa1b07350e0135961.scope
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 11K bytes - Viewed (0)