- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 5,770 for instanceId (0.16 sec)
-
pkg/test/framework/components/echo/kube/instance.go
} func (c *instance) Instances() echo.Instances { return echo.Instances{c} } func (c *instance) Close() (err error) { return c.workloadMgr.Close() } func (c *instance) NamespacedName() echo.NamespacedName { return c.cfg.NamespacedName() } func (c *instance) PortForName(name string) echo.Port { return c.cfg.Ports.MustForName(name) } func (c *instance) ServiceName() string {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 16 18:55:23 UTC 2023 - 9K bytes - Viewed (0) -
pkg/config/labels/instance.go
func (i Instance) Match(that Instance) bool { if len(i) == 0 { return false } return i.SubsetOf(that) } // Equals returns true if the labels are equal. func (i Instance) Equals(that Instance) bool { return maps.Equal(i, that) } // Validate ensures tag is well-formed func (i Instance) Validate() error { if i == nil { return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 16 06:54:36 UTC 2023 - 5K bytes - Viewed (0) -
pkg/config/protocol/instance.go
package protocol import "strings" // Instance defines network protocols for ports type Instance string func (i Instance) String() string { return string(i) } const ( // GRPC declares that the port carries gRPC traffic. GRPC Instance = "GRPC" // GRPCWeb declares that the port carries gRPC traffic. GRPCWeb Instance = "GRPC-Web" // HTTP declares that the port carries HTTP/1.1 traffic.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 01 02:46:15 UTC 2023 - 4.3K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/instance.go
"istio.io/istio/pkg/test/echo/proto" ) var _ io.Closer = &Instance{} // Instance is a client for forwarding requests to echo servers. type Instance struct { e *executor protocolMap map[scheme.Instance]protocol protocols []protocol } // New creates a new forwarder Instance. func New() *Instance { var protocols []protocol add := func(p protocol) protocol {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Oct 13 17:19:22 UTC 2022 - 2.3K bytes - Viewed (0) -
pkg/controlplane/instance.go
// used by the master. type EndpointReconcilerConfig struct { Reconciler reconcilers.EndpointReconciler Interval time.Duration } // Instance contains state for a Kubernetes cluster api server instance. type Instance struct { ControlPlane *controlplaneapiserver.Server } func (c *Config) createMasterCountReconciler() reconcilers.EndpointReconciler {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 03 11:50:04 UTC 2024 - 21.2K bytes - Viewed (0) -
pkg/test/framework/label/instance.go
// limitations under the License. package label import ( "sort" "strings" ) // Instance is a label instance. type Instance string // Set is a set of labels type Set map[Instance]struct{} // NewSet returns a new label set. func NewSet(labels ...Instance) Set { s := make(map[Instance]struct{}) for _, l := range labels { s[l] = struct{}{} } return s }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 29 20:42:01 UTC 2020 - 2K bytes - Viewed (0) -
pkg/test/echo/server/instance.go
var ( serverLog = log.RegisterScope("server", "echo server") _ io.Closer = &Instance{} ) // Instance of the Echo server. type Instance struct { Config endpoints []endpoint.Instance metricsServer *http.Server ready uint32 } // New creates a new server instance. func New(config Config) *Instance { log.Infof("Creating Server with config:\n%s", config)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 09 07:54:01 UTC 2023 - 7.1K bytes - Viewed (0) -
pkg/bootstrap/instance.go
var overrideVar = env.Register("ISTIO_BOOTSTRAP", "", "") // Instance of a configured Envoy bootstrap writer. type Instance interface { // WriteTo writes the content of the Envoy bootstrap to the given writer. WriteTo(templateFile string, w io.Writer) error // CreateFile generates an Envoy bootstrap file. CreateFile() (string, error) } // New creates a new Instance of an Envoy bootstrap writer. func New(cfg Config) Instance {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 20:38:02 UTC 2024 - 3.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/instance.go
import ( "istio.io/istio/pilot/pkg/model" "istio.io/istio/pilot/pkg/serviceregistry/provider" "istio.io/istio/pkg/cluster" ) // Instance of a service registry. A single service registry combines the capabilities of service discovery // and the controller for managing asynchronous events. type Instance interface { model.Controller model.ServiceDiscovery // Provider backing this service registry (i.e. Kubernetes etc.)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 07 18:40:05 UTC 2023 - 1.5K bytes - Viewed (0) -
pkg/queue/instance.go
startTime time.Time } // Instance of work tickets processed using a rate-limiting loop type baseInstance interface { // Push a task. Push(task Task) // Run the loop until a signal on the channel Run(<-chan struct{}) // Closed returns a chan that will be signaled when the Instance has stopped processing tasks. Closed() <-chan struct{} } type Instance interface { baseInstance
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jul 21 16:30:36 UTC 2023 - 4.1K bytes - Viewed (0)