- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for Hockin (0.15 sec)
-
clause/locking.go
LockingOptionsNoWait = "NOWAIT" ) type Locking struct { Strength string Table Table Options string } // Name where clause name func (locking Locking) Name() string { return "FOR" } // Build build where clause func (locking Locking) Build(builder Builder) { builder.WriteString(locking.Strength) if locking.Table.Name != "" { builder.WriteString(" OF ")
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Fri Dec 15 08:32:56 GMT 2023 - 773 bytes - Viewed (0) -
cmd/namespace-lock.go
nsMutex := nsLockMap{ isDistErasure: isDistErasure, } if isDistErasure { return &nsMutex } nsMutex.lockMap = make(map[string]*nsLock) return &nsMutex } // nsLock - provides primitives for locking critical namespace regions. type nsLock struct { ref int32 *lsync.LRWMutex } // nsLockMap - namespace lock map, provides primitives to Lock, // Unlock, RLock and RUnlock. type nsLockMap struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jun 05 23:56:35 GMT 2023 - 9.2K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache.go
func closeNetns(netns NetnsCloser) { netns.Close() } func (p *podNetnsCache) ReadCurrentPodSnapshot() map[string]WorkloadInfo { p.mu.RLock() defer p.mu.RUnlock() // snapshot the cache to avoid long locking return maps.Clone(p.currentPodCache) } // Remove and return the Netns for the given uid // No need to return NetnsCloser here it will be closed automatically on GC.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0) -
chainable_api.go
// // tell the optimizer to use the `idx_user_name` index // db.Clauses(hints.UseIndex("idx_user_name")).Find(&User{}) // // specify the lock strength to UPDATE // db.Clauses(clause.Locking{Strength: "UPDATE"}).Find(&users) // // [docs]: https://gorm.io/docs/sql_builder.html#Clauses func (db *DB) Clauses(conds ...clause.Expression) (tx *DB) { tx = db.getInstance() var whereConds []interface{}
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) -
internal/dsync/lock-args.go
Quorum int } // ResponseCode is the response code for a locking request. type ResponseCode uint8 // Response codes for a locking request. const ( RespOK ResponseCode = iota RespLockConflict RespLockNotInitialized RespLockNotFound RespErr ) // LockResp is a locking request response. type LockResp struct { Code ResponseCode Err string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 04:34:26 GMT 2024 - 1.7K bytes - Viewed (0) -
cmd/bucket-object-lock.go
return r, err } return r, err } return config.ToRetention(), nil } // enforceRetentionForDeletion checks if it is appropriate to remove an // object according to locking configuration when this is lifecycle/ bucket quota asking. func enforceRetentionForDeletion(ctx context.Context, objInfo ObjectInfo) (locked bool) { if objInfo.DeleteMarker { return false }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 13.2K bytes - Viewed (0) -
internal/grid/muxclient.go
m.closeLocked() return false } } func (m *muxClient) close() { if debugPrint { fmt.Println("closing outgoing mux", m.MuxID) } if !m.respMu.TryLock() { // Cancel before locking - will unblock any pending sends. if m.cancelFn != nil { m.cancelFn(context.Canceled) } // Wait for senders to release. m.respMu.Lock() } defer m.respMu.Unlock() m.closeLocked() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/data-scanner_test.go
retention lock.Retention obj ObjectInfo want lifecycle.Action }{ { // with object locking ilm: *deleteAllLc, retention: lock.Retention{LockEnabled: true}, obj: obj, want: lifecycle.NoneAction, }, { // without object locking ilm: *deleteAllLc, retention: lock.Retention{}, obj: obj,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 6.9K bytes - Viewed (0) -
cni/pkg/plugin/cnieventclient.go
"time" "github.com/containernetworking/cni/pkg/skel" cniv1 "github.com/containernetworking/cni/pkg/types/100" "istio.io/istio/cni/pkg/nodeagent" ) // newCNIClient is a unit test override variable for mocking. var newCNIClient = buildClient // An udsCore write entries to an UDS server with HTTP Post. Log messages will be encoded into a JSON array. type CNIEventClient struct { client *http.Client url string }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 2.4K bytes - Viewed (0) -
istioctl/pkg/workload/workload.go
} return vs, nil } // Because we are placing into an Unstructured, place as a map instead // of structured Istio types. (The go-client can handle the structured data, but the // fake go-client used for mocking cannot.) func unstructureIstioType(spec any) (map[string]any, error) { b, err := yaml.Marshal(spec) if err != nil { return nil, err } iSpec := map[string]any{} err = yaml.Unmarshal(b, &iSpec)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 17 20:06:41 GMT 2024 - 25.5K bytes - Viewed (0)