Search Options

Results per page
Sort
Preferred Languages
Advance

Results 701 - 710 of 1,423 for Func (0.03 sec)

  1. 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)
  2. docs/debugging/s3-verify/main.go

    	wg.Add(2)
    	go func() {
    		defer wg.Done()
    		srcSize, err := io.Copy(srcSha256, sobj)
    		if err != nil {
    			fmt.Printf("unreadable on source: %s (%s)\n", srcCtnt.Key, err)
    			sourceFailed = true
    		} else if srcSize != srcCtnt.Size {
    			fmt.Printf("unreadable on source - size differs upon read: %s\n", srcCtnt.Key)
    			sourceFailed = true
    		}
    	}()
    	go func() {
    		defer wg.Done()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 22 15:12:47 UTC 2022
    - 8.4K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top