- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 57 for function (0.15 sec)
-
cmd/admin-heal-ops.go
// map of the heal path to `healSequence` which holds state about the // heal sequence. // // Heal results are persisted in server memory for // `keepHealSeqStateDuration`. This function also launches a // background routine to clean up heal results after the // aforementioned duration. func (ahs *allHealState) LaunchNewHealSequence(h *healSequence, objAPI ObjectLayer) (
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
cmd/encryption-v1.go
if crypto.S3.IsRequested(header) && crypto.SSEC.IsRequested(header) { return key, crypto.ErrIncompatibleEncryptionMethod } k, err := crypto.SSEC.ParseHTTP(header) return k[:], err } // This function rotates old to new key. func rotateKey(ctx context.Context, oldKey []byte, newKeyID string, newKey []byte, bucket, object string, metadata map[string]string, cryptoCtx kms.Context) error { kind, _ := crypto.IsEncrypted(metadata)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 36.5K bytes - Viewed (0) -
cmd/storage-rest-client.go
case strings.Contains(err.Error(), "server closed idle connection"): return true } return false } // Converts network error to storageErr. This function is // written so that the storageAPI errors are consistent // across network disks. func toStorageErr(err error) error { if err == nil { return nil } if isNetworkError(err) { return errDiskNotFound
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
log.Debugf("ignoring error deleting optional iptables rule: %v", err) } } } return errors.Join(delErrs...) } // Setup iptables rules for in-pod mode. Ideally this should be an idempotent function. // NOTE that this expects to be run from within the pod network namespace! func (cfg *IptablesConfigurator) CreateInpodRules(hostProbeSNAT *netip.Addr) error { // Append our rules here
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue May 07 19:54:50 GMT 2024 - 19.7K bytes - Viewed (0) -
cmd/update.go
// // Any change here should be discussed by opening an issue at // https://github.com/minio/minio/issues. func getUserAgent(mode string) string { userAgentParts := []string{} // Helper function to concisely append a pair of strings to a // the user-agent slice. uaAppend := func(p, q string) { userAgentParts = append(userAgentParts, p, q) } uaAppend(MinioUAName, " (") uaAppend("", runtime.GOOS)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 18.7K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
res := make(DailyAllTierStats, len(t.lastDayStats)) for tier, st := range t.lastDayStats { res[tier] = st.clone() } return res } // UpdateWorkers at the end of this function leaves n goroutines waiting for // transition tasks func (t *transitionState) UpdateWorkers(n int) { t.mu.Lock() defer t.mu.Unlock() if t.objAPI == nil { // Init hasn't been called yet. return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/peer-s3-client.go
return deleteBucketLocal(ctx, bucket, opts) } // client to talk to peer Nodes. type remotePeerS3Client struct { node Node pools []int // Function that returns the grid connection for this peer when initialized. // Will return nil if the grid connection is not initialized yet. gridConn func() *grid.Connection } // S3PeerSys - S3 peer call system.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.8K bytes - Viewed (0) -
istioctl/cmd/root.go
validateCmd := validate.NewValidateCommand(ctx) hideInheritedFlags(validateCmd, "kubeconfig") rootCmd.AddCommand(validateCmd) rootCmd.AddCommand(optionsCommand(rootCmd)) // BFS applies the flag error function to all subcommands seenCommands := make(map[*cobra.Command]bool) var commandStack []*cobra.Command commandStack = append(commandStack, rootCmd) for len(commandStack) > 0 { n := len(commandStack) - 1
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 11 20:51:30 GMT 2024 - 10K bytes - Viewed (0) -
cmd/tier.go
return valid } // isTierNameInUse returns tier type and true if there exists a remote tier by // name tierName, otherwise returns madmin.Unsupported and false. N B this // function is meant for internal use, where the caller is expected to take // appropriate locks. func (config *TierConfigMgr) isTierNameInUse(tierName string) (madmin.TierType, bool) { if t, ok := config.Tiers[tierName]; ok {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 15.5K bytes - Viewed (0) -
internal/grid/muxclient.go
} m.addResponse(Response{Err: err}) return } atomic.StoreInt64(&m.LastPong, time.Now().Unix()) } // addResponse will add a response to the response channel. // This function will never block func (m *muxClient) addResponse(r Response) (ok bool) { m.respMu.Lock() defer m.respMu.Unlock() if m.closed { return false } select { case m.respWait <- r:
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)