Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. internal/kms/stub.go

    // StubKMS is a KMS implementation for tests
    type StubKMS struct {
    	KeyNames []string
    }
    
    // Version returns the type of the KMS.
    func (s StubKMS) Version(ctx context.Context) (string, error) {
    	return "stub", nil
    }
    
    // APIs returns supported APIs
    func (s StubKMS) APIs(ctx context.Context) ([]madmin.KMSAPI, error) {
    	return []madmin.KMSAPI{
    		{Method: http.MethodGet, Path: "stub/path"},
    	}, nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  2. 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)
  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/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)
  8. 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)
  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. cmd/test-utils_test.go

    }
    
    func prepareErasureSets32(ctx context.Context) (ObjectLayer, []string, error) {
    	return prepareErasure(ctx, 32)
    }
    
    func prepareErasure(ctx context.Context, nDisks int) (ObjectLayer, []string, error) {
    	fsDirs, err := getRandomDisks(nDisks)
    	if err != nil {
    		return nil, nil, err
    	}
    	obj, _, err := initObjectLayer(ctx, mustGetPoolEndpoints(0, fsDirs...))
    	if err != nil {
    		removeRoots(fsDirs)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
Back to top