Search Options

Results per page
Sort
Preferred Languages
Advance

Results 711 - 720 of 1,384 for funcs (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top