Search Options

Results per page
Sort
Preferred Languages
Advance

Results 291 - 300 of 1,425 for Func (0.1 sec)

  1. istioctl/pkg/precheck/precheck_test.go

    			"follow https://istio.io/latest/docs/tasks/observability/distributed-tracing/telemetry-api/",
    		"1.21")
    
    	assert.Equal(t, expectedOutput, messages[0])
    }
    
    func init() {
    	cli.MakeKubeFactory = func(k kube.CLIClient) cmdutil.Factory {
    		tf := cmdtesting.NewTestFactory()
    		_, _, codec := cmdtesting.NewExternalScheme()
    		tf.UnstructuredClient = &fake.RESTClient{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 09 12:01:22 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  2. misc/linkcheck/linkcheck.go

    	}
    	if crawled[url] {
    		return
    	}
    	crawled[url] = true
    
    	wg.Add(1)
    	go func() {
    		urlq <- url
    	}()
    }
    
    func addProblem(url, errmsg string) {
    	msg := fmt.Sprintf("Error on %s: %s (from %s)", url, errmsg, linkSources[url])
    	if *verbose {
    		log.Print(msg)
    	}
    	problems = append(problems, msg)
    }
    
    func crawlLoop() {
    	for url := range urlq {
    		if err := doCrawl(url); err != nil {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 06 15:53:04 UTC 2021
    - 3.9K bytes
    - Viewed (0)
  3. cni/pkg/nodeagent/ztunnelserver_test.go

    	}
    	return m, fdss
    }
    
    func sendAck(c *net.UnixConn) {
    	ack := &zdsapi.WorkloadResponse{
    		Payload: &zdsapi.WorkloadResponse_Ack{
    			Ack: &zdsapi.Ack{},
    		},
    	}
    	data, err := proto.Marshal(ack)
    	if err != nil {
    		panic(err)
    	}
    	err = c.SetWriteDeadline(time.Now().Add(time.Second))
    	if err != nil {
    		panic(err)
    	}
    	c.Write(data)
    }
    
    func sendHello(c *net.UnixConn) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Apr 12 21:47:31 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  4. cmd/admin-handler-utils.go

    }
    
    // AdminError - is a generic error for all admin APIs.
    type AdminError struct {
    	Code       string
    	Message    string
    	StatusCode int
    }
    
    func (ae AdminError) Error() string {
    	return ae.Message
    }
    
    func toAdminAPIErr(ctx context.Context, err error) APIError {
    	if err == nil {
    		return noError
    	}
    
    	var apiErr APIError
    	switch e := err.(type) {
    	case policy.Error:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 03 07:17:20 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  5. src/archive/tar/writer.go

    	default:
    		return n, nil
    	}
    }
    
    func (fw *regFileWriter) ReadFrom(r io.Reader) (int64, error) {
    	return io.Copy(struct{ io.Writer }{fw}, r)
    }
    
    // logicalRemaining implements fileState.logicalRemaining.
    func (fw regFileWriter) logicalRemaining() int64 {
    	return fw.nb
    }
    
    // physicalRemaining implements fileState.physicalRemaining.
    func (fw regFileWriter) physicalRemaining() int64 {
    	return fw.nb
    }
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 02 14:22:59 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  6. src/bufio/bufio.go

    // size, it returns the underlying [Reader].
    func NewReaderSize(rd io.Reader, size int) *Reader {
    	// Is it already a Reader?
    	b, ok := rd.(*Reader)
    	if ok && len(b.buf) >= size {
    		return b
    	}
    	r := new(Reader)
    	r.reset(make([]byte, max(size, minReadBufferSize)), rd)
    	return r
    }
    
    // NewReader returns a new [Reader] whose buffer has the default size.
    func NewReader(rd io.Reader) *Reader {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 12 14:39:08 UTC 2023
    - 21.8K bytes
    - Viewed (0)
  7. internal/s3select/sql/utils.go

    	return e.strippedPathExpr
    }
    
    func (e *JSONPathElement) String() string {
    	switch {
    	case e.Key != nil:
    		return e.Key.String()
    	case e.Index != nil:
    		return fmt.Sprintf("[%d]", *e.Index)
    	case e.ObjectWildcard:
    		return ".*"
    	case e.ArrayWildcard:
    		return "[*]"
    	}
    	return ""
    }
    
    // String removes double quotes in quoted identifiers
    func (i *Identifier) String() string {
    	if i.Unquoted != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Nov 10 16:12:50 UTC 2021
    - 3.6K bytes
    - Viewed (0)
  8. istioctl/pkg/writer/envoy/configdump/endpoint.go

    		return false
    	}
    	return true
    }
    
    func retrieveEndpointStatus(ep *endpoint.LbEndpoint) core.HealthStatus {
    	return ep.GetHealthStatus()
    }
    
    func retrieveEndpointPort(ep *endpoint.LbEndpoint) uint32 {
    	return ep.GetEndpoint().GetAddress().GetSocketAddress().GetPortValue()
    }
    
    func retrieveEndpointAddresses(ep *endpoint.LbEndpoint) []string {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 22 09:57:29 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  9. internal/s3select/jstream/decoder.go

    func (d *Decoder) Pos() int { return int(d.pos) }
    
    // Err returns the most recent decoder error if any, or nil
    func (d *Decoder) Err() error { return d.err }
    
    // MaxDepth will set the maximum recursion depth.
    // If the maximum depth is exceeded, ErrMaxDepth is returned.
    // Less than or 0 means no limit (default).
    func (d *Decoder) MaxDepth(n int) *Decoder {
    	d.maxDepth = n
    	return d
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  10. lib/wasm/wasm_exec.js

    					},
    
    					// func resetMemoryDataView()
    					"runtime.resetMemoryDataView": (sp) => {
    						sp >>>= 0;
    						this.mem = new DataView(this._inst.exports.mem.buffer);
    					},
    
    					// func nanotime1() int64
    					"runtime.nanotime1": (sp) => {
    						sp >>>= 0;
    						setInt64(sp + 8, (timeOrigin + performance.now()) * 1000000);
    					},
    
    					// func walltime() (sec int64, nsec int32)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Aug 30 19:15:21 UTC 2024
    - 16.5K bytes
    - Viewed (0)
Back to top