Search Options

Results per page
Sort
Preferred Languages
Advance

Results 751 - 760 of 1,425 for Func (0.03 sec)

  1. istioctl/pkg/install/k8sversion/version.go

    func CheckKubernetesVersion(versionInfo *version.Info) (bool, error) {
    	v, err := extractKubernetesVersion(versionInfo)
    	if err != nil {
    		return false, err
    	}
    	return MinK8SVersion <= v, nil
    }
    
    // extractKubernetesVersion returns the Kubernetes minor version. For example, `v1.19.1` will return `19`
    func extractKubernetesVersion(versionInfo *version.Info) (int, error) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 30 21:50:50 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  2. internal/bucket/lifecycle/rule.go

    	if r.Status != Enabled && r.Status != Disabled {
    		return errInvalidRuleStatus
    	}
    	return nil
    }
    
    func (r Rule) validateExpiration() error {
    	return r.Expiration.Validate()
    }
    
    func (r Rule) validateNoncurrentExpiration() error {
    	return r.NoncurrentVersionExpiration.Validate()
    }
    
    func (r Rule) validatePrefixAndFilter() error {
    	if !r.Prefix.set && r.Filter.IsEmpty() || r.Prefix.set && !r.Filter.IsEmpty() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 01:11:10 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. tests/soft_delete_test.go

    	}
    }
    
    func TestDeletedAtUnMarshal(t *testing.T) {
    	expected := &gorm.Model{}
    	b, _ := json.Marshal(expected)
    
    	result := &gorm.Model{}
    	_ = json.Unmarshal(b, result)
    	if result.DeletedAt != expected.DeletedAt {
    		t.Errorf("Failed, result.DeletedAt: %v is not same as expected.DeletedAt: %v", result.DeletedAt, expected.DeletedAt)
    	}
    }
    
    func TestDeletedAtOneOr(t *testing.T) {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Feb 01 06:40:55 UTC 2023
    - 5.7K bytes
    - Viewed (0)
  7. istioctl/pkg/internaldebug/internal-debug.go

    	"istio.io/istio/istioctl/pkg/clioptions"
    	"istio.io/istio/istioctl/pkg/multixds"
    	"istio.io/istio/istioctl/pkg/util"
    	v3 "istio.io/istio/pilot/pkg/xds/v3"
    	"istio.io/istio/pkg/kube"
    )
    
    func HandlerForRetrieveDebugList(kubeClient kube.CLIClient,
    	centralOpts clioptions.CentralControlPlaneOptions,
    	writer io.Writer,
    	istioNamespace string,
    ) (map[string]*discovery.DiscoveryResponse, error) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jul 12 11:30:24 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  8. 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)
  9. scan.go

    package gorm
    
    import (
    	"database/sql"
    	"database/sql/driver"
    	"reflect"
    	"time"
    
    	"gorm.io/gorm/schema"
    	"gorm.io/gorm/utils"
    )
    
    // prepareValues prepare values slice
    func prepareValues(values []interface{}, db *DB, columnTypes []*sql.ColumnType, columns []string) {
    	if db.Statement.Schema != nil {
    		for idx, name := range columns {
    			if field := db.Statement.Schema.LookUpField(name); field != nil {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Jun 24 09:42:59 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  10. cmd/veeam-sos-api.go

    	veeamAgentSubstr  = "APN/1.0 Veeam/1.0"
    )
    
    func isVeeamSOSAPIObject(object string) bool {
    	switch object {
    	case systemXMLObject, capacityXMLObject:
    		return true
    	default:
    		return false
    	}
    }
    
    // isVeeamClient - returns true if the request is from Veeam client.
    func isVeeamClient(ctx context.Context) bool {
    	ri := logger.GetReqInfo(ctx)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 8.8K bytes
    - Viewed (0)
Back to top