Search Options

Results per page
Sort
Preferred Languages
Advance

Results 761 - 770 of 1,423 for Func (0.02 sec)

  1. src/arena/arena.go

    func Clone[T any](s T) T {
    	return runtime_arena_heapify(s).(T)
    }
    
    //go:linkname reflect_arena_New reflect.arena_New
    func reflect_arena_New(a *Arena, typ any) any {
    	return runtime_arena_arena_New(a.a, typ)
    }
    
    //go:linkname runtime_arena_newArena
    func runtime_arena_newArena() unsafe.Pointer
    
    //go:linkname runtime_arena_arena_New
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 12 20:23:36 UTC 2022
    - 4.3K bytes
    - Viewed (0)
  2. istioctl/pkg/writer/envoy/clusters/clusters.go

    		}
    	}
    	return "unknown"
    }
    
    func retrieveEndpointPort(l *admin.HostStatus) uint32 {
    	addr := l.Address.GetSocketAddress()
    	if addr != nil {
    		return addr.GetPortValue()
    	}
    	return 0
    }
    
    func retrieveEndpointStatus(l *admin.HostStatus) core.HealthStatus {
    	return l.HealthStatus.GetEdsHealthStatus()
    }
    
    func retrieveFailedOutlierCheck(l *admin.HostStatus) bool {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Nov 03 08:41:32 UTC 2022
    - 5.8K bytes
    - Viewed (0)
  3. istioctl/pkg/admin/istiodconfig_test.go

    			},
    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			if got := chooseClientFlag(tt.args.ctrzClient, tt.args.reset, tt.args.outputLogLevel,
    				tt.args.stackTraceLevel, tt.args.outputFormat); !reflect.DeepEqual(got, tt.want) {
    				t.Errorf("chooseClientFlag() = %v, want %v", got, tt.want)
    			}
    		})
    	}
    }
    
    func resourceHandler(writer http.ResponseWriter, request *http.Request) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jun 15 15:02:17 UTC 2023
    - 6.2K bytes
    - Viewed (0)
  4. clause/locking_test.go

    package clause_test
    
    import (
    	"fmt"
    	"testing"
    
    	"gorm.io/gorm/clause"
    )
    
    func TestLocking(t *testing.T) {
    	results := []struct {
    		Clauses []clause.Interface
    		Result  string
    		Vars    []interface{}
    	}{
    		{
    			[]clause.Interface{clause.Select{}, clause.From{}, clause.Locking{Strength: clause.LockingStrengthUpdate}},
    			"SELECT * FROM `users` FOR UPDATE", nil,
    		},
    		{
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri Dec 15 08:32:56 UTC 2023
    - 1.2K bytes
    - Viewed (0)
  5. internal/grid/msg_string.go

    // Code generated by "stringer -type=Op -output=msg_string.go -trimprefix=Op msg.go"; DO NOT EDIT.
    
    package grid
    
    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[OpConnect-1]
    	_ = x[OpConnectResponse-2]
    	_ = x[OpPing-3]
    	_ = x[OpPong-4]
    	_ = x[OpConnectMux-5]
    	_ = x[OpMuxConnectError-6]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 1.2K bytes
    - Viewed (0)
  6. src/bytes/buffer.go

    // b.Len() == len(b.Bytes()).
    func (b *Buffer) Len() int { return len(b.buf) - b.off }
    
    // Cap returns the capacity of the buffer's underlying byte slice, that is, the
    // total space allocated for the buffer's data.
    func (b *Buffer) Cap() int { return cap(b.buf) }
    
    // Available returns how many bytes are unused in the buffer.
    func (b *Buffer) Available() int { return cap(b.buf) - len(b.buf) }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Oct 29 16:47:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool-rebalance.go

    		Duration:  duration,
    		Path:      path,
    		Error:     errStr,
    		Bytes:     sz,
    	}
    }
    
    func (p *rebalanceMetrics) log(r rebalanceMetric, poolIdx int, paths ...string) func(sz int64, err error) {
    	startTime := time.Now()
    	return func(sz int64, err error) {
    		duration := time.Since(startTime)
    		if globalTrace.NumSubscribers(madmin.TraceRebalance) > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  8. cni/pkg/pluginlistener/listener_test.go

    	"google.golang.org/grpc/credentials/insecure"
    )
    
    func TestCNIListener(t *testing.T) {
    	f := filepath.Join(t.TempDir(), "test")
    	l, err := NewListener(f)
    	if err != nil {
    		t.Fatalf("unexpected error %v", err)
    	}
    	defer l.Close()
    	conn, err := connect(f)
    	if err != nil {
    		t.Fatalf("failed to connect %v", err)
    	}
    	conn.Close()
    }
    
    func connect(socket string) (*grpc.ClientConn, error) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Feb 08 21:58:32 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  9. cmd/metacache-set.go

    // or the context is canceled.
    func (o *listPathOptions) gatherResults(ctx context.Context, in <-chan metaCacheEntry) func() (metaCacheEntriesSorted, error) {
    	resultsDone := make(chan metaCacheEntriesSorted)
    	// Copy so we can mutate
    	resCh := resultsDone
    	var done bool
    	var mu sync.Mutex
    	resErr := io.EOF
    
    	go func() {
    		var results metaCacheEntriesSorted
    		var returned bool
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  10. cmd/ftp-server.go

    // minioLogger use an instance of this to log in a standard format
    type minioLogger struct{}
    
    // Print implement Logger
    func (log *minioLogger) Print(sessionID string, message interface{}) {
    	if serverDebugLog {
    		fmt.Printf("%s %s\n", sessionID, message)
    	}
    }
    
    // Printf implement Logger
    func (log *minioLogger) Printf(sessionID string, format string, v ...interface{}) {
    	if serverDebugLog {
    		if sessionID != "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Mar 09 03:07:08 UTC 2024
    - 4.8K bytes
    - Viewed (0)
Back to top