Search Options

Results per page
Sort
Preferred Languages
Advance

Results 991 - 1000 of 1,423 for Func (0.03 sec)

  1. istioctl/pkg/xds/client.go

    	defaultExpirationSeconds = 60 * 60
    )
    
    // Audience to create tokens for
    var tokenAudiences = []string{"istio-ca"}
    
    // GetXdsResponse opens a gRPC connection to opts.xds and waits for a single response
    func GetXdsResponse(dr *discovery.DiscoveryRequest, ns string, serviceAccount string, opts clioptions.CentralControlPlaneOptions,
    	grpcOpts []grpc.DialOption,
    ) (*discovery.DiscoveryResponse, error) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Dec 19 22:42:42 UTC 2023
    - 3.7K bytes
    - Viewed (0)
  2. cmd/server-startup-msg_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"context"
    	"os"
    	"reflect"
    	"testing"
    )
    
    // Tests stripping standard ports from apiEndpoints.
    func TestStripStandardPorts(t *testing.T) {
    	apiEndpoints := []string{"http://127.0.0.1:9000", "http://127.0.0.2:80", "https://127.0.0.3:443"}
    	expectedAPIEndpoints := []string{"http://127.0.0.1:9000", "http://127.0.0.2", "https://127.0.0.3"}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 3K bytes
    - Viewed (0)
  3. istioctl/pkg/writer/envoy/configdump/route_test.go

    			expected: "example.com, www.example.com + 1 more...",
    		},
    	}
    
    	for _, tt := range tests {
    		t.Run(tt.desc, func(t *testing.T) {
    			if got := describeRouteDomains(tt.domains); got != tt.expected {
    				t.Errorf("%s: expect %v got %v", tt.desc, tt.expected, got)
    			}
    		})
    	}
    }
    
    func TestPrintRoutesSummary(t *testing.T) {
    	tests := []struct {
    		name string
    	}{
    		{
    			name: "empty-gateway",
    		},
    		{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Nov 29 12:37:14 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  4. internal/s3select/jstream/errors.go

    	pos       errPos
    	atChar    byte
    	readerErr error // underlying reader error, if any
    }
    
    // ReaderErr returns the underlying error.
    func (e DecoderError) ReaderErr() error { return e.readerErr }
    
    // Error returns a string representation of the error.
    func (e DecoderError) Error() string {
    	loc := fmt.Sprintf("%s [%d,%d]", quoteChar(e.atChar), e.pos[0], e.pos[1])
    	s := fmt.Sprintf("%s %s: %s", e.msg, e.context, loc)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  5. schema/schema.go

    	namer                     Namer
    	cacheStore                *sync.Map
    }
    
    func (schema Schema) String() string {
    	if schema.ModelType.Name() == "" {
    		return fmt.Sprintf("%s(%s)", schema.Name, schema.Table)
    	}
    	return fmt.Sprintf("%s.%s", schema.ModelType.PkgPath(), schema.ModelType.Name())
    }
    
    func (schema Schema) MakeSlice() reflect.Value {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Jun 20 12:19:31 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  6. internal/s3select/genmessage.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package s3select
    
    import (
    	"bytes"
    	"encoding/binary"
    	"fmt"
    	"hash/crc32"
    )
    
    func genRecordsHeader() {
    	buf := new(bytes.Buffer)
    
    	buf.WriteByte(13)
    	buf.WriteString(":message-type")
    	buf.WriteByte(7)
    	buf.Write([]byte{0, 5})
    	buf.WriteString("event")
    
    	buf.WriteByte(13)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 19 01:35:22 UTC 2021
    - 4.4K bytes
    - Viewed (0)
  7. cmd/policy_test.go

    import (
    	"reflect"
    	"testing"
    
    	miniogopolicy "github.com/minio/minio-go/v7/pkg/policy"
    	"github.com/minio/minio-go/v7/pkg/set"
    	"github.com/minio/pkg/v3/policy"
    	"github.com/minio/pkg/v3/policy/condition"
    )
    
    func TestPolicySysIsAllowed(t *testing.T) {
    	p := &policy.BucketPolicy{
    		Version: policy.DefaultVersion,
    		Statements: []policy.BPStatement{
    			policy.NewBPStatement("",
    				policy.Allow,
    				policy.NewPrincipal("*"),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  8. tensorflow/c/eager/c_api_remote_test_util.cc

      return def.SerializeAsString();
    }
    
    void TestRemoteExecuteSilentCopies(bool async, bool remote, bool func,
                                       bool heavy_load_on_streaming_rpc,
                                       bool remote_func_outputs,
                                       bool has_packed_input) {
      CHECK(!has_packed_input || func);
      tensorflow::ServerDef server_def = GetServerDef(3);
    
      // This server def has the task index set to 0.
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Fri Dec 11 22:56:03 UTC 2020
    - 9.1K bytes
    - Viewed (0)
  9. cmd/acl-handlers.go

    }
    
    // PutBucketACLHandler - PUT Bucket ACL
    // -----------------
    // This operation uses the ACL subresource
    // to set ACL for a bucket, this is a dummy call
    // only responds success if the ACL is private.
    func (api objectAPIHandlers) PutBucketACLHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "PutBucketACL")
    
    	defer logger.AuditLog(ctx, w, r, mustGetClaimsFromToken(r))
    
    	vars := mux.Vars(r)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  10. src/archive/zip/reader_test.go

    	{
    		Name:  "comment-truncated.zip",
    		Error: ErrFormat,
    	},
    }
    
    func TestReader(t *testing.T) {
    	for _, zt := range tests {
    		t.Run(zt.Name, func(t *testing.T) {
    			readTestZip(t, zt)
    		})
    	}
    }
    
    func readTestZip(t *testing.T, zt ZipTest) {
    	var z *Reader
    	var err error
    	var raw []byte
    	if zt.Source != nil {
    		rat, size := zt.Source()
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Jul 25 00:25:45 UTC 2024
    - 55.6K bytes
    - Viewed (0)
Back to top