Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for remoteClients (0.06 sec)

  1. istioctl/pkg/cli/context.go

    }
    
    type instance struct {
    	// clients are cached clients for each revision
    	clients map[string]kube.CLIClient
    	// remoteClients are cached clients for each context with empty revision.
    	remoteClients map[string]kube.CLIClient
    	RootFlags
    }
    
    func newKubeClientWithRevision(kubeconfig, configContext, revision string, impersonateConfig rest.ImpersonationConfig) (kube.CLIClient, error) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 23 19:31:32 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  2. istioctl/pkg/analyze/analyze.go

    		return nil, err
    	}
    	clients := []*Client{
    		{
    			client: client,
    			remote: false,
    		},
    	}
    	if len(remoteContexts) > 0 {
    		remoteClients, err := getClientsFromContexts(ctx)
    		if err != nil {
    			return nil, err
    		}
    		clients = append(clients, remoteClients...)
    		return clients, nil
    	}
    	secrets, err := client.Kube().CoreV1().Secrets(ctx.IstioNamespace()).List(context.Background(), metav1.ListOptions{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 31 06:53:50 UTC 2024
    - 17.6K bytes
    - Viewed (0)
  3. internal/grid/handlers.go

    	}
    	return r, err
    }
    
    // RemoteClient contains information about the caller.
    type RemoteClient struct {
    	Name string
    }
    
    type (
    	ctxCallerKey   = struct{}
    	ctxSubrouteKey = struct{}
    )
    
    // GetCaller returns caller information from contexts provided to handlers.
    func GetCaller(ctx context.Context) *RemoteClient {
    	val, _ := ctx.Value(ctxCallerKey{}).(*RemoteClient)
    	return val
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  4. internal/grid/connection.go

    	// Holding the lock allows safe reads of State, and guarantees that changes will be detected.
    	connChange *sync.Cond
    	handlers   *handlers
    
    	remote             *RemoteClient
    	clientPingInterval time.Duration
    	connPingInterval   time.Duration
    	blockConnect       chan struct{}
    
    	incomingBytes func(n int64) // Record incoming bytes.
    	outgoingBytes func(n int64) // Record outgoing bytes.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 46.7K bytes
    - Viewed (0)
Back to top