- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for Id (0.02 sec)
-
cmd/logging.go
logger.LogIf(ctx, "replication", err, errKind...) } func replLogOnceIf(ctx context.Context, err error, id string, errKind ...interface{}) { logger.LogOnceIf(ctx, "replication", err, id, errKind...) } func iamLogOnceIf(ctx context.Context, err error, id string, errKind ...interface{}) { logger.LogOnceIf(ctx, "iam", err, id, errKind...) } func iamLogIf(ctx context.Context, err error, errKind ...interface{}) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 7.2K bytes - Viewed (0) -
internal/grid/muxserver.go
func (m *muxServer) disconnect(msg string, locked bool) { if debugPrint { fmt.Println("Mux", m.ID, "disconnecting. Reason:", msg) } if msg != "" { m.send(message{Op: OpMuxServerMsg, MuxID: m.ID, Flags: FlagPayloadIsErr | FlagEOF, Payload: []byte(msg)}) } else { m.send(message{Op: OpDisconnectClientMux, MuxID: m.ID}) } // Unlock, since we are calling deleteMux, which will call close - which will lock recvMu.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0) -
cmd/storage-rest-common.go
storageRESTBitrotHash = "bitrot-hash" storageRESTDiskID = "disk-id" storageRESTForceDelete = "force-delete" storageRESTGlob = "glob" storageRESTMetrics = "metrics" storageRESTDriveQuorum = "drive-quorum" storageRESTOrigVolume = "orig-volume" ) type nsScannerOptions struct { DiskID string `msg:"id"` ScanMode int `msg:"m"` Cache *dataUsageCache `msg:"c"` }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 2.9K bytes - Viewed (0) -
pkg/test/framework/components/environment/kube/kube.go
out := make(map[string][]cluster.Cluster) for _, c := range e.Clusters() { out[c.NetworkName()] = append(out[c.NetworkName()], c) } return out } // ID implements resource.Instance func (e *Environment) ID() resource.ID { return e.id } func (e *Environment) Settings() *Settings { return e.s.clone() } func buildClusters(configs []cluster.Config) (cluster.Clusters, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 5.1K bytes - Viewed (0) -
tests/associations_has_one_test.go
if err := DB.Create(&user).Error; err != nil { t.Fatalf("errors happened when create: %v", err) } CheckUser(t, user, user) // Find var user2 User DB.Find(&user2, "id = ?", user.ID) DB.Model(&user2).Association("Account").Find(&user2.Account) CheckUser(t, user2, user) // Count AssertAssociationCount(t, user, "Account", 1, "") // Append
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Wed Jun 12 10:49:45 UTC 2024 - 7.1K bytes - Viewed (0) -
pkg/test/framework/components/namespace/kube.go
type kubeNamespace struct { ctx resource.Context id resource.ID name string prefix string cleanupMutex sync.Mutex cleanupFuncs []func() error skipDump bool } func (n *kubeNamespace) Dump(ctx resource.Context) { if n.skipDump { scopes.Framework.Debugf("=== Skip dumping Namespace %s State for %v...", n.name, ctx.ID()) return }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 9K bytes - Viewed (0) -
pilot/pkg/xds/deltatest.go
log.Errorf("%s: TEST for node:%s unexpected resources: %v %v", v3.GetShortType(w.TypeUrl), con.proxy.ID, details, wantChanged.Difference(gotChanged)) } // Still make sure we didn't delete anything extra if len(extraDeletes) > 0 { log.Errorf("%s: TEST for node:%s unexpected deletions: %v %v", v3.GetShortType(w.TypeUrl), con.proxy.ID, details, extraDeletes) } } else { if len(extraDeletes) > 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 5.7K bytes - Viewed (0) -
pkg/test/framework/components/prometheus/kube.go
if err != nil { return nil, err } c.api[cls.Name()] = prometheusApiV1.NewAPI(client) } return c, nil } func (c *kubeComponent) ID() resource.ID { return c.id } // API implements environment.DeployedPrometheus. func (c *kubeComponent) API() prometheusApiV1.API { return c.api[c.clusters.Default().Name()] }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/test/framework/components/ambient/waypoint.go
} func (k kubeComponent) Inbound() string { return k.inbound.Address() } func (k kubeComponent) Outbound() string { return k.outbound.Address() } func (k kubeComponent) ID() resource.ID { return k.id } func (k kubeComponent) Close() error { if k.inbound != nil { k.inbound.Close() } if k.outbound != nil { k.outbound.Close() } return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 6.5K bytes - Viewed (0) -
cmd/xl-storage-format-utils_test.go
if fi.VersionID != versions[i].VersionID { t.Fatalf("getFileInfoVersions: versions don't match at %d, version id expected %s but got %s", i, fi.VersionID, versions[i].VersionID) } if fi.NumVersions != len(fivs.Versions) { t.Fatalf("getFileInfoVersions: version with %s version id expected to have %d as NumVersions but got %d", fi.VersionID, len(fivs.Versions), fi.NumVersions) } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 22:18:44 UTC 2024 - 7.1K bytes - Viewed (0)