Search Options

Results per page
Sort
Preferred Languages
Advance

Results 881 - 890 of 1,425 for Func (0.05 sec)

  1. clause/clause.go

    package clause
    
    // Interface clause interface
    type Interface interface {
    	Name() string
    	Build(Builder)
    	MergeClause(*Clause)
    }
    
    // ClauseBuilder clause builder, allows to customize how to build clause
    type ClauseBuilder func(Clause, Builder)
    
    type Writer interface {
    	WriteByte(byte) error
    	WriteString(string) (int, error)
    }
    
    // Builder builder interface
    type Builder interface {
    	Writer
    	WriteQuoted(field interface{})
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Feb 02 09:15:08 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  2. cmd/shared-lock.go

    				break keepLock
    			case ld.lockContext <- lkctx:
    				// Send the lock context to anyone asking for it
    			}
    		}
    	}
    }
    
    func mergeContext(ctx1, ctx2 context.Context) (context.Context, context.CancelFunc) {
    	ctx, cancel := context.WithCancel(context.Background())
    	go func() {
    		select {
    		case <-ctx1.Done():
    		case <-ctx2.Done():
    		// The lock acquirer decides to cancel, exit this goroutine
    		case <-ctx.Done():
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 13 09:26:38 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  3. internal/config/dns/dns_path.go

    // the root label it is ignored. Not other syntax checks are performed.
    func dnsJoin(labels ...string) string {
    	ll := len(labels)
    	if labels[ll-1] == "." {
    		return strings.Join(labels[:ll-1], ".") + "."
    	}
    	return dns.Fqdn(strings.Join(labels, "."))
    }
    
    // msgUnPath converts a etcd path to domainName.
    func msgUnPath(s string) string {
    	l := strings.Split(s, etcdPathSeparator)
    	if l[len(l)-1] == "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 15:03:08 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  4. misc/go_android_exec/exitcode_test.go

    		t.Errorf("want output %q, got %q", want, got)
    	}
    	if want := 1; want != code {
    		t.Errorf("want exit code %d, got %d", want, code)
    	}
    }
    
    func TestExitCodeMissing(t *testing.T) {
    	var wantErr *regexp.Regexp
    	check := func(text string) {
    		t.Helper()
    		var out strings.Builder
    		f, exitStr := newExitCodeFilter(&out)
    		if want := "exitcode="; want != exitStr {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed May 03 14:54:58 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  5. lib/time/mkzip.go

    package main
    
    import (
    	"archive/zip"
    	"bytes"
    	"flag"
    	"fmt"
    	"hash/crc32"
    	"io/fs"
    	"log"
    	"os"
    	"path/filepath"
    	"strings"
    )
    
    func usage() {
    	fmt.Fprintf(os.Stderr, "usage: go run mkzip.go zoneinfo.zip\n")
    	os.Exit(2)
    }
    
    func main() {
    	log.SetPrefix("mkzip: ")
    	log.SetFlags(0)
    	flag.Usage = usage
    	flag.Parse()
    	args := flag.Args()
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Mar 04 17:32:07 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  6. istioctl/cmd/root_test.go

    	"github.com/spf13/cobra"
    )
    
    func checkHelpForFlag(t *testing.T, gotHelpText, flag string, wantExists bool) {
    	t.Helper()
    
    	if strings.Contains(gotHelpText, flag) != wantExists {
    		if wantExists {
    			t.Errorf("%q flag was expected but not found in help text", flag)
    		} else {
    			t.Errorf("%q flag was found in help text but not expected", flag)
    		}
    	}
    }
    
    func TestHideInheritedFlags(t *testing.T) {
    	const (
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 15 17:59:55 UTC 2021
    - 2.4K bytes
    - Viewed (0)
  7. cmd/xl-storage_unix_test.go

    	"syscall"
    	"testing"
    )
    
    // Based on `man getumask` a vaporware GNU extension to glibc.
    // returns file mode creation mask.
    func getUmask() int {
    	mask := syscall.Umask(0)
    	syscall.Umask(mask)
    	return mask
    }
    
    // Tests if the directory and file creations happen with proper umask.
    func TestIsValidUmaskVol(t *testing.T) {
    	tmpPath := t.TempDir()
    	testCases := []struct {
    		volName       string
    		expectedUmask int
    	}{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 25 19:37:26 UTC 2022
    - 3.4K bytes
    - Viewed (0)
  8. istioctl/pkg/dashboard/dashboard_test.go

    		Namespace: "istio-system",
    	}))
    	for i, c := range cases {
    		t.Run(fmt.Sprintf("case %d %s", i, strings.Join(c.Args, " ")), func(t *testing.T) {
    			testutil.VerifyOutput(t, dbCmd, c)
    			cleanupTestCase()
    		})
    	}
    }
    
    func cleanupTestCase() {
    	labelSelector = ""
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Nov 21 01:17:24 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  9. cmd/metrics-v3-api.go

    )
    
    // loadAPIRequestsHTTPMetrics - reads S3 HTTP metrics.
    //
    // This is a `MetricsLoaderFn`.
    //
    // This includes node level S3 HTTP metrics.
    //
    // This function currently ignores `opts`.
    func loadAPIRequestsHTTPMetrics(ctx context.Context, m MetricValues, _ *metricsCache) error {
    	// Collect node level S3 HTTP metrics.
    	httpStats := globalHTTPStats.toServerHTTPStats(false)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  10. cmd/metrics-v3-system-drive.go

    		"Average time for write requests served on a drive",
    		allDriveLabels...)
    	drivePercUtilMD = NewGaugeMD(drivePercUtil,
    		"Percentage of time the disk was busy",
    		allDriveLabels...)
    )
    
    func getCurrentDriveIOStats() map[string]madmin.DiskIOStats {
    	var types madmin.MetricType = madmin.MetricsDisk
    	driveRealtimeMetrics := collectLocalMetrics(types, collectMetricsOpts{
    		hosts: map[string]struct{}{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun May 12 17:23:50 UTC 2024
    - 7.9K bytes
    - Viewed (0)
Back to top