- Sort Score
- Result 10 results
- Languages All
Results 761 - 770 of 1,423 for Func (0.03 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)