Search Options

Results per page
Sort
Preferred Languages
Advance

Results 261 - 270 of 453 for ctx_ (0.07 sec)

  1. cni/pkg/nodeagent/server.go

    	ConstructInitialSnapshot(ambientPods []*corev1.Pod) error
    	Start(ctx context.Context)
    
    	//	IsPodInMesh(ctx context.Context, pod *metav1.ObjectMeta, netNs string) (bool, error)
    	AddPodToMesh(ctx context.Context, pod *corev1.Pod, podIPs []netip.Addr, netNs string) error
    	RemovePodFromMesh(ctx context.Context, pod *corev1.Pod, isDelete bool) error
    
    	Stop()
    }
    
    type Server struct {
    	ctx        context.Context
    	kubeClient kube.Client
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Sep 25 20:54:34 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  2. cmd/metrics-v3-api.go

    // loadAPIRequestsHTTPMetrics - reads S3 HTTP metrics.
    //
    // This is a `MetricsLoaderFn`.
    //
    // This includes node level S3 HTTP metrics.
    //
    // This function currently ignores `opts`.
    func loadAPIRequestsHTTPMetrics(ctx context.Context, m MetricValues, _ *metricsCache) error {
    	// Collect node level S3 HTTP metrics.
    	httpStats := globalHTTPStats.toServerHTTPStats(false)
    
    	// Currently we only collect S3 API related stats, so we set the "type"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  3. cmd/object-api-options_test.go

    // it is intended to be expanded when the function is worked on in the future.
    func TestGetAndValidateAttributesOpts(t *testing.T) {
    	globalBucketVersioningSys = &BucketVersioningSys{}
    	bucket := minioMetaBucket
    	ctx := context.Background()
    	testCases := []struct {
    		name            string
    		headers         http.Header
    		wantObjectAttrs map[string]struct{}
    	}{
    		{
    			name:            "empty header",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 21 21:13:59 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  4. cmd/metrics-v3-scanner.go

    		"Time elapsed (in seconds) since last scan activity.")
    )
    
    // loadClusterScannerMetrics - `MetricsLoaderFn` for cluster webhook
    // such as failed objects and directories scanned.
    func loadClusterScannerMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
    	m.Set(scannerBucketScansFinished, float64(globalScannerMetrics.lifetime(scannerMetricScanBucketDrive)))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 19:29:25 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  5. docs/site-replication/gen-oidc-sts-cred.go

    import (
    	"context"
    	"fmt"
    	"log"
    	"net/http"
    	"os"
    
    	cr "github.com/minio/minio-go/v7/pkg/credentials"
    	cmd "github.com/minio/minio/cmd"
    )
    
    func main() {
    	ctx := context.Background()
    
    	endpoint := os.Getenv("MINIO_ENDPOINT")
    	if endpoint == "" {
    		log.Fatalf("Please specify a MinIO server endpoint environment variable like:\n\n\texport MINIO_ENDPOINT=http://localhost:9000")
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 29 01:27:09 UTC 2022
    - 2.3K bytes
    - Viewed (0)
  6. istioctl/pkg/kubeinject/google.go

    	// A bit inexact but should be good enough.
    	return strings.Contains(addr, ".googleapis.com/") || strings.Contains(addr, ".googleapis.com:443/")
    }
    
    func mcpTransport(ctx context.Context, tr http.RoundTripper) (http.RoundTripper, error) {
    	creds, err := google.FindDefaultCredentials(ctx, "https://www.googleapis.com/auth/cloud-platform")
    	if err != nil {
    		return nil, fmt.Errorf("finding default GCP credentials: %w", err)
    	}
    	return &oauth2.Transport{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jun 15 15:02:17 UTC 2023
    - 1.2K bytes
    - Viewed (0)
  7. internal/grid/README.md

    Sample handler:
    ```go
        handler :=  func(ctx context.Context, payload []byte, in <-chan []byte, out chan<- []byte) *RemoteErr {
            fmt.Println("Got request with initial payload", p, "from", GetCaller(ctx context.Context))
            fmt.Println("Subroute:", GetSubroute(ctx))
            for {
                select {
                case <-ctx.Done():
                    return nil
                case req, ok := <-in:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  8. internal/config/dns/etcd_dns.go

    			key = key + etcdPathSeparator + ip
    			ctx, cancel := context.WithTimeout(context.Background(), defaultContextTimeout)
    			_, err = c.etcdClient.Put(ctx, key, string(bucketMsg))
    			cancel()
    			if err != nil {
    				ctx, cancel = context.WithTimeout(context.Background(), defaultContextTimeout)
    				c.etcdClient.Delete(ctx, key)
    				cancel()
    				return err
    			}
    		}
    	}
    	return nil
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 15:03:08 UTC 2024
    - 8K bytes
    - Viewed (0)
  9. cmd/metacache.go

    	}
    	return true
    }
    
    // keepAlive will continuously update lastHandout until ctx is canceled.
    func (m metacache) keepAlive(ctx context.Context, rpc *peerRESTClient) {
    	// we intentionally operate on a copy of m, so we can update without locks.
    	t := time.NewTicker(metacacheMaxClientWait / 10)
    	defer t.Stop()
    	for {
    		select {
    		case <-ctx.Done():
    			// Request is done, stop updating.
    			return
    		case <-t.C:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 6K bytes
    - Viewed (0)
  10. 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)
Back to top