Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1091 - 1100 of 1,385 for _func (0.02 sec)

  1. istioctl/pkg/writer/pilot/status_test.go

    	"istio.io/istio/pilot/pkg/xds"
    	v3 "istio.io/istio/pilot/pkg/xds/v3"
    	"istio.io/istio/pkg/cluster"
    	"istio.io/istio/pkg/test/util/assert"
    	istioversion "istio.io/istio/pkg/version"
    	"istio.io/istio/tests/util"
    )
    
    func TestXdsStatusWriter_PrintAll(t *testing.T) {
    	tests := []struct {
    		name    string
    		input   map[string]*discovery.DiscoveryResponse
    		want    string
    		wantErr bool
    	}{
    		{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Aug 14 19:36:19 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  2. internal/s3select/select_test.go

    	statusCode int
    	response   []byte
    }
    
    func (w *testResponseWriter) Header() http.Header {
    	return nil
    }
    
    func (w *testResponseWriter) Write(p []byte) (int, error) {
    	w.response = append(w.response, p...)
    	return len(p), nil
    }
    
    func (w *testResponseWriter) WriteHeader(statusCode int) {
    	w.statusCode = statusCode
    }
    
    func (w *testResponseWriter) Flush() {
    }
    
    func TestJSONQueries(t *testing.T) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 23 07:19:11 UTC 2023
    - 76.2K bytes
    - Viewed (0)
  3. tests/multi_primary_keys_test.go

    	Value  string
    	Blogs  []*Blog `gorm:"many2many:blog_tags"`
    }
    
    func compareTags(tags []Tag, contents []string) bool {
    	var tagContents []string
    	for _, tag := range tags {
    		tagContents = append(tagContents, tag.Value)
    	}
    	sort.Strings(tagContents)
    	sort.Strings(contents)
    	return reflect.DeepEqual(tagContents, contents)
    }
    
    func TestManyToManyWithMultiPrimaryKeys(t *testing.T) {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Jan 06 07:02:53 UTC 2022
    - 12.8K bytes
    - Viewed (0)
  4. tests/associations_belongs_to_test.go

    package tests_test
    
    import (
    	"testing"
    
    	"gorm.io/gorm"
    	. "gorm.io/gorm/utils/tests"
    )
    
    func TestBelongsToAssociation(t *testing.T) {
    	user := *GetUser("belongs-to", Config{Company: true, Manager: true})
    
    	if err := DB.Create(&user).Error; err != nil {
    		t.Fatalf("errors happened when create: %v", err)
    	}
    
    	CheckUser(t, user, user)
    
    	// Find
    	var user2 User
    	DB.Find(&user2, "id = ?", user.ID)
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Oct 30 09:15:49 UTC 2023
    - 9.3K bytes
    - Viewed (0)
  5. src/bytes/export_test.go

    // Copyright 2009 The Go Authors. All rights reserved.
    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    package bytes
    
    // Export func for testing
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Apr 24 00:56:36 UTC 2019
    - 244 bytes
    - Viewed (0)
  6. docs/extensions/s3zip/examples/minio-go/main.go

    package main
    
    import (
    	"context"
    	"io"
    	"log"
    	"os"
    
    	"github.com/minio/minio-go/v7"
    	"github.com/minio/minio-go/v7/pkg/credentials"
    )
    
    func main() {
    	s3Client, err := minio.New("minio-server-address:9000", &minio.Options{
    		Creds: credentials.NewStaticV4("access-key", "secret-key", ""),
    	})
    	if err != nil {
    		log.Fatalln(err)
    	}
    
    	var opts minio.GetObjectOptions
    
    	// Add extract header to request:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 14 18:04:14 UTC 2021
    - 694 bytes
    - Viewed (0)
  7. cmd/metrics-v3-cluster-health.go

    		"Count of all drives in the cluster")
    )
    
    // loadClusterHealthDriveMetrics - `MetricsLoaderFn` for cluster storage drive metrics
    // such as online, offline and total drives.
    func loadClusterHealthDriveMetrics(ctx context.Context, m MetricValues,
    	c *metricsCache,
    ) error {
    	clusterDriveMetrics, _ := c.clusterDriveMetrics.Get()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 10 09:15:15 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  8. cni/pkg/install/kubeconfig_test.go

    	testutils "istio.io/istio/pilot/test/util"
    )
    
    const (
    	k8sServiceHost = "10.96.0.1"
    	k8sServicePort = "443"
    	kubeCAFilepath = "testdata/kube-ca.crt"
    	saToken        = "service_account_token_string"
    )
    
    func TestCreateValidKubeconfigFile(t *testing.T) {
    	tmp := t.TempDir()
    	os.WriteFile(filepath.Join(tmp, "token"), []byte(saToken), 0o644)
    	cases := []struct {
    		name               string
    		expectedFailure    bool
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Aug 14 19:36:19 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  9. src/archive/tar/fuzz_test.go

    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    package tar
    
    import (
    	"bytes"
    	"io"
    	"testing"
    )
    
    func FuzzReader(f *testing.F) {
    	b := bytes.NewBuffer(nil)
    	w := NewWriter(b)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Jan 13 18:06:33 UTC 2022
    - 2.2K bytes
    - Viewed (0)
  10. tensorflow/c/eager/abstract_context.h

      // available to be called/referenced by its name in this context.
      virtual absl::Status RegisterFunction(AbstractFunction*) = 0;
      // Remove a function. 'func' argument is the name of a previously added
      // FunctionDef. The name is in fdef.signature.name.
      virtual absl::Status RemoveFunction(const string& func) = 0;
    
     private:
      const AbstractContextKind kind_;
    };
    
    namespace internal {
    struct AbstractContextDeleter {
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 3K bytes
    - Viewed (0)
Back to top