- Sort Score
- Result 10 results
- Languages All
Results 711 - 720 of 1,384 for funcs (0.04 sec)
-
cni/pkg/plugin/kubernetes.go
// getK8sPodInfo returns information of a POD func getK8sPodInfo(client kubernetes.Interface, podName, podNamespace string) (*PodInfo, error) { pod, err := client.CoreV1().Pods(podNamespace).Get(context.TODO(), podName, metav1.GetOptions{}) if err != nil { return nil, err } pi := ExtractPodInfo(pod) log.Debugf("Pod %v/%v info: \n%+v", podNamespace, podName, pi) return pi, nil } func ExtractPodInfo(pod *v1.Pod) *PodInfo {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Aug 01 18:38:14 UTC 2024 - 3.7K bytes - Viewed (0) -
cmd/bucket-replication-stats.go
qTimer *time.Ticker // ticker for calculating queue stats } func (r *ReplicationStats) trackEWMA() { for { select { case <-r.movingAvgTicker.C: r.updateMovingAvg() case <-GlobalContext.Done(): return } } } func (r *ReplicationStats) updateMovingAvg() { r.RLock() for _, s := range r.Cache { for _, st := range s.Stats {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 13.6K bytes - Viewed (0) -
cmd/admin-heal-ops.go
return func() error { // NOTE: Healing on meta is run regardless // of any bucket being selected, this is to ensure that // meta are always upto date and correct. return objAPI.HealObjects(h.ctx, minioMetaBucket, metaPrefix, h.settings, func(bucket, object, versionID string, scanMode madmin.HealScanMode) error { if h.isQuitting() { return errHealStopSignalled } err := h.queueHealTask(healSource{
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 25.6K bytes - Viewed (0) -
schema/naming.go
// RelationshipFKName generate fk name for relation func (ns NamingStrategy) RelationshipFKName(rel Relationship) string { return ns.formatName("fk", rel.Schema.Table, ns.toDBName(rel.Name)) } // CheckerName generate checker name func (ns NamingStrategy) CheckerName(table, column string) string { return ns.formatName("chk", table, column) } // IndexName generate index name func (ns NamingStrategy) IndexName(table, column string) string {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Wed Jun 12 03:46:59 UTC 2024 - 5.3K bytes - Viewed (0) -
cmd/format_string.go
// Code generated by "stringer -type=format -trimprefix=format untar.go"; DO NOT EDIT. package cmd import "strconv" func _() { // An "invalid array index" compiler error signifies that the constant values have changed. // Re-run the stringer command to generate them again. var x [1]struct{} _ = x[formatUnknown-0] _ = x[formatGzip-1] _ = x[formatZstd-2] _ = x[formatLZ4-3] _ = x[formatS2-4] _ = x[formatBZ2-5] }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Apr 23 18:58:53 UTC 2021 - 737 bytes - Viewed (0) -
internal/s3select/parquet/args.go
type ReaderArgs struct { unmarshaled bool } // IsEmpty - returns whether reader args is empty or not. func (args *ReaderArgs) IsEmpty() bool { return !args.unmarshaled } // UnmarshalXML - decodes XML data. func (args *ReaderArgs) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error { // Make subtype to avoid recursive UnmarshalXML(). type subReaderArgs ReaderArgs
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jun 01 21:59:40 UTC 2021 - 1.4K bytes - Viewed (0) -
internal/ioutil/discard.go
// and as such incurred latencies. var Discard io.Writer = discard{} // discard is /dev/null for Golang. type discard struct{} func (discard) Write(p []byte) (int, error) { return len(p), nil } // DiscardReader discarded reader func DiscardReader(r io.Reader) { Copy(Discard, r)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Nov 06 22:26:08 UTC 2023 - 1.3K bytes - Viewed (0) -
istioctl/pkg/install/k8sversion/version.go
func CheckKubernetesVersion(versionInfo *version.Info) (bool, error) { v, err := extractKubernetesVersion(versionInfo) if err != nil { return false, err } return MinK8SVersion <= v, nil } // extractKubernetesVersion returns the Kubernetes minor version. For example, `v1.19.1` will return `19` func extractKubernetesVersion(versionInfo *version.Info) (int, error) {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 30 21:50:50 UTC 2024 - 2.6K bytes - Viewed (0) -
cmd/site-replication-metrics_gen.go
} } o = bts return } // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message func (z RStat) Msgsize() (s int) { s = 1 + 6 + msgp.Int64Size + 6 + msgp.Int64Size return } // DecodeMsg implements msgp.Decodable func (z *RTimedMetrics) DecodeMsg(dc *msgp.Reader) (err error) { var field []byte _ = field var zb0001 uint32 zb0001, err = dc.ReadMapHeader()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Feb 06 06:00:45 UTC 2024 - 40.6K bytes - Viewed (0) -
cmd/bucket-object-lock.go
"github.com/minio/pkg/v3/policy" ) // BucketObjectLockSys - map of bucket and retention configuration. type BucketObjectLockSys struct{} // Get - Get retention configuration. func (sys *BucketObjectLockSys) Get(bucketName string) (r objectlock.Retention, err error) { config, _, err := globalBucketMetadataSys.GetObjectLockConfig(bucketName) if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 13.2K bytes - Viewed (0)