Search Options

Results per page
Sort
Preferred Languages
Advance

Results 701 - 710 of 1,387 for funcs (0.06 sec)

  1. 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)
  2. internal/bucket/lifecycle/tag.go

    			default:
    				return errUnknownXMLTag
    			}
    		}
    	}
    
    	return nil
    }
    
    func (tag Tag) String() string {
    	return tag.Key + "=" + tag.Value
    }
    
    // IsEmpty returns whether this tag is empty or not.
    func (tag Tag) IsEmpty() bool {
    	return tag.Key == ""
    }
    
    // Validate checks this tag.
    func (tag Tag) Validate() error {
    	if len(tag.Key) == 0 || utf8.RuneCountInString(tag.Key) > 128 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 2.4K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/error.go

    )
    
    var ErrPartialAdd = errors.New("partial add error")
    
    type PartialAddError struct {
    	inner error
    }
    
    func (e *PartialAddError) Error() string {
    	return fmt.Sprintf("%s: %v", ErrPartialAdd.Error(), e.inner)
    }
    
    func (e *PartialAddError) Unwrap() []error {
    	return []error{ErrPartialAdd, e.inner}
    }
    
    func NewErrPartialAdd(err error) *PartialAddError {
    	return &PartialAddError{
    		inner: err,
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 1K bytes
    - Viewed (0)
  4. cmd/rebalancemetric_string.go

    // Code generated by "stringer -type=rebalanceMetric -trimprefix=rebalanceMetric erasure-server-pool-rebalance.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[rebalanceMetricRebalanceBuckets-0]
    	_ = x[rebalanceMetricRebalanceBucket-1]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 25 19:36:57 UTC 2022
    - 988 bytes
    - Viewed (0)
  5. clause/returning_test.go

    package clause_test
    
    import (
    	"fmt"
    	"testing"
    
    	"gorm.io/gorm/clause"
    )
    
    func TestReturning(t *testing.T) {
    	results := []struct {
    		Clauses []clause.Interface
    		Result  string
    		Vars    []interface{}
    	}{
    		{
    			[]clause.Interface{clause.Select{}, clause.From{}, clause.Returning{
    				[]clause.Column{clause.PrimaryColumn},
    			}},
    			"SELECT * FROM `users` RETURNING `users`.`id`", nil,
    		}, {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Jun 02 01:18:01 UTC 2020
    - 845 bytes
    - Viewed (0)
  6. cni/pkg/install/cniconfig_test.go

    			CNIConfName:      c.specifiedConfName,
    			ChainedCNIPlugin: c.chainedCNIPlugin,
    			PluginLogLevel:   "debug",
    			CNIAgentRunDir:   kubeconfigFilename,
    		}
    		test := func(cfg config.InstallConfig) func(t *testing.T) {
    			return func(t *testing.T) {
    				// Create temp directory for files
    				tempDir := t.TempDir()
    
    				// Create existing config files if specified in test case
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 18:38:14 UTC 2024
    - 15.3K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. cmd/api-resources.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"encoding/base64"
    	"net/url"
    	"strconv"
    )
    
    // Parse bucket url queries
    func getListObjectsV1Args(values url.Values) (prefix, marker, delimiter string, maxkeys int, encodingType string, errCode APIErrorCode) {
    	errCode = ErrNone
    
    	if values.Get("max-keys") != "" {
    		var err error
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 07 18:25:26 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  10. 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)
Back to top