Search Options

Results per page
Sort
Preferred Languages
Advance

Results 271 - 280 of 453 for ctx_ (0.04 sec)

  1. istioctl/pkg/waypoint/waypoint_test.go

    			},
    			expectedOutFile: "combined-gateway",
    		},
    	}
    	for _, tt := range cases {
    		t.Run(tt.name, func(t *testing.T) {
    			ctx := cli.NewFakeContext(&cli.NewFakeContextOption{
    				Namespace: "default",
    			})
    			client, err := ctx.CLIClient()
    			if err != nil {
    				t.Fatal(err)
    			}
    
    			for _, gw := range tt.gateways {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Apr 04 15:53:09 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  2. cni/pkg/pluginlistener/listener_test.go

    	var opts []grpc.DialOption
    
    	opts = append(opts, grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithContextDialer(func(ctx context.Context, addr string) (net.Conn, error) {
    		var d net.Dialer
    		return d.DialContext(ctx, "unix", socket)
    	}))
    
    	conn, err := grpc.Dial(socket, opts...)
    	if err != nil {
    		return nil, err
    	}
    
    	return conn, nil
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Feb 08 21:58:32 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  3. cmd/metrics-v3-cluster-config.go

    )
    
    // loadClusterConfigMetrics - `MetricsLoaderFn` for cluster config
    // such as standard and RRS parity.
    func loadClusterConfigMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
    	clusterDriveMetrics, err := c.clusterDriveMetrics.Get()
    	if err != nil {
    		metricsLogIf(ctx, err)
    	} else {
    		m.Set(configStandardParity, float64(clusterDriveMetrics.storageInfo.Backend.StandardSCParity))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 12:50:46 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  4. istioctl/pkg/admin/admin.go

    // limitations under the License.
    
    package admin
    
    import (
    	"fmt"
    
    	"github.com/spf13/cobra"
    
    	"istio.io/istio/istioctl/pkg/cli"
    )
    
    func Cmd(ctx cli.Context) *cobra.Command {
    	adminCmd := &cobra.Command{
    		Use:   "admin",
    		Short: "Manage control plane (istiod) configuration",
    		Long:  "A group of commands used to manage istiod configuration",
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jun 15 15:02:17 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  5. src/cmd/asm/internal/asm/parse.go

    	errorWriter   io.Writer
    }
    
    type Patch struct {
    	addr  *obj.Addr
    	label string
    }
    
    func NewParser(ctxt *obj.Link, ar *arch.Arch, lexer lex.TokenReader) *Parser {
    	pkgPrefix := obj.UnlinkablePkg
    	if ctxt != nil {
    		pkgPrefix = objabi.PathToPrefix(ctxt.Pkgpath)
    	}
    	return &Parser{
    		ctxt:        ctxt,
    		arch:        ar,
    		lex:         lexer,
    		labels:      make(map[string]*obj.Prog),
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Sep 04 18:16:59 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  6. cmd/peer-rest-server.go

    			return np, grid.NewRemoteErr(err)
    		}
    		subSys := vars.Get(peerRESTSubSys)
    		// Apply dynamic values.
    		ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
    		defer cancel()
    		if subSys == "" {
    			err = applyDynamicConfig(ctx, objAPI, srvCfg)
    		} else {
    			err = applyDynamicConfigForSubSys(ctx, objAPI, srvCfg, subSys)
    		}
    		if err != nil {
    			return np, grid.NewRemoteErr(err)
    		}
    	default:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  7. cmd/api-response.go

    	// Similar check to http.checkWriteHeaderCode
    	if err.HTTPStatusCode < 100 || err.HTTPStatusCode > 999 {
    		bugLogIf(ctx, fmt.Errorf("invalid WriteHeader code %v from %v", err.HTTPStatusCode, err.Code))
    		err.HTTPStatusCode = http.StatusInternalServerError
    	}
    
    	// Generate error response.
    	errorResponse := getAPIErrorResponse(ctx, err, reqURL.Path,
    		w.Header().Get(xhttp.AmzRequestID), w.Header().Get(xhttp.AmzRequestHostID))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 19:27:06 UTC 2024
    - 33.4K bytes
    - Viewed (0)
  8. cmd/admin-heal-ops.go

    )
    
    var (
    	errHealIdleTimeout   = errors.New("healing results were not consumed for too long")
    	errHealStopSignalled = errors.New("heal stop signaled")
    
    	errFnHealFromAPIErr = func(ctx context.Context, err error) error {
    		apiErr := toAdminAPIErr(ctx, err)
    		return fmt.Errorf("Heal internal error: %s: %s",
    			apiErr.Code, apiErr.Description)
    	}
    )
    
    // healSequenceStatus - accumulated status of the heal sequence
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  9. cmd/metacache-stream.go

    // The context allows the operation to be canceled.
    func (r *metacacheReader) readAll(ctx context.Context, dst chan<- metaCacheEntry) error {
    	r.checkInit()
    	if r.err != nil {
    		return r.err
    	}
    	defer xioutil.SafeClose(dst)
    	if r.current.name != "" {
    		select {
    		case <-ctx.Done():
    			r.err = ctx.Err()
    			return ctx.Err()
    		case dst <- r.current:
    		}
    		r.current.name = ""
    		r.current.metadata = nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  10. istioctl/pkg/internaldebug/internal-debug.go

    				namespace, serviceAccount, kubeClient, multixds.DefaultOptions)
    			if err != nil {
    				return err
    			}
    			sw := DebugWriter{
    				Writer:                 c.OutOrStdout(),
    				InternalDebugAllIstiod: internalDebugAllIstiod,
    			}
    			newResponse, err := HandlerForDebugErrors(kubeClient, &centralOpts, c.OutOrStdout(), ctx.IstioNamespace(), xdsResponses)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jul 12 11:30:24 UTC 2024
    - 6.7K bytes
    - Viewed (0)
Back to top