- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for exclusion (0.26 sec)
-
internal/lsync/lrwmutex.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package lsync import ( "context" "math" "math/rand" "sync" "time" ) // A LRWMutex is a mutual exclusion lock with timeouts. type LRWMutex struct { id string source string isWriteLock bool ref int mu sync.Mutex // Mutex to prevent multiple simultaneous locks }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.8K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
fs.AssertExpectations(t) // annotate Pod as disabled should cause only one RemovePodFromMesh to happen fs.On("RemovePodFromMesh", ctx, mock.Anything, ).Once().Return(nil) // label the pod for exclusion labelsPatch := []byte(fmt.Sprintf(`{"metadata":{"labels":{"%s":"%s"}}}`, constants.DataplaneModeLabel, constants.DataplaneModeNone)) _, err = client.Kube().CoreV1().Pods(pod.Namespace).Patch(ctx, pod.Name,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 15.8K bytes - Viewed (0) -
internal/bucket/versioning/versioning.go
XMLName xml.Name `xml:"VersioningConfiguration"` // MFADelete State `xml:"MFADelete,omitempty"` // not supported yet. Status State `xml:"Status,omitempty"` // MinIO extension - allows selective, prefix-level versioning exclusion. // Requires versioning to be enabled ExcludedPrefixes []ExcludedPrefix `xml:",omitempty"` ExcludeFolders bool `xml:",omitempty"` } // Validate - validates the versioning configuration
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 4.6K bytes - Viewed (0) -
internal/dsync/drwmutex.go
RefreshCall: drwMutexRefreshCallTimeout, UnlockCall: drwMutexUnlockCallTimeout, ForceUnlockCall: drwMutexForceUnlockCallTimeout, } // A DRWMutex is a distributed mutual exclusion lock. type DRWMutex struct { Names []string writeLocks []string // Array of nodes that granted a write lock readLocks []string // Array of array of nodes that granted reader locks
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
cmd/object-api-utils.go
return false } if len(cfg.MimeTypes) > 0 && hasPattern(cfg.MimeTypes, contentType) { // Matched an MIME type to compress, do not exclude. return false } // Did not match any inclusion filters, exclude from compression. return true } // Utility which returns if a string is present in the list. // Comparison is case insensitive. Explicit short-circuit if // the list contains the wildcard "*".
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) -
internal/dsync/dsync-server_test.go
nodes[i] = httptest.NewServer(router) } } const WriteLock = -1 type lockServer struct { mutex sync.Mutex // Map of locks, with negative value indicating (exclusive) write lock // and positive values indicating number of read locks lockMap map[string]int64 // Refresh returns lock not found if set to true lockNotFound bool
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jan 23 16:46:37 GMT 2023 - 8.3K bytes - Viewed (0) -
istioctl/pkg/workload/workload.go
return nil }, PreRunE: func(cmd *cobra.Command, args []string) error { if len(internalIP) > 0 && len(externalIP) > 0 { return fmt.Errorf("the flags --internalIP and --externalIP are mutually exclusive") } return nil }, } configureCmd.PersistentFlags().StringVarP(&filename, "file", "f", "", "filename of the WorkloadGroup artifact. Leave this field empty if using the API server")
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) -
src/bytes/bytes.go
func FieldsFunc(s []byte, f func(rune) bool) [][]byte { // A span is used to record a slice of s of the form s[start:end]. // The start index is inclusive and the end index is exclusive. type span struct { start int end int } spans := make([]span, 0, 32) // Find the field start and end indices. // Doing this in a separate pass (rather than slicing the string s
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Feb 19 19:51:15 GMT 2024 - 33.8K bytes - Viewed (0) -
internal/kms/config.go
EnvKESAPIKey = "MINIO_KMS_KES_API_KEY" // Access credential for KES - API keys and private key / certificate are mutually exclusive EnvKESClientKey = "MINIO_KMS_KES_KEY_FILE" // Path to TLS private key for authenticating to KES with mTLS - usually prefer API keys
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 07:42:50 GMT 2024 - 2K bytes - Viewed (0) -
istioctl/pkg/util/formatting/formatter_test.go
g.Expect(output).To(Equal( "Error [B1] (SoapBubble) Explosion accident: the bubble is too big\n" + "Warning [C1] (GrandCastle) Collapse danger: the castle is too old", )) } func TestFormatter_PrintLogWithColor(t *testing.T) { g := NewWithT(t) firstMsg := diag.NewMessage( diag.NewMessageType(diag.Error, "B1", "Explosion accident: %v"), diag.MockResource("SoapBubble"), "the bubble is too big",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Oct 31 14:48:28 GMT 2023 - 4.1K bytes - Viewed (0)