- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for event (0.16 sec)
-
cni/pkg/nodeagent/informers.go
event := input.(controllers.Event) switch event.Latest().(type) { case *corev1.Namespace: return s.reconcileNamespace(input) case *corev1.Pod: return s.reconcilePod(input) default: return fmt.Errorf("unexpected event type: %+v", input) } } func (s *InformerHandlers) reconcileNamespace(input any) error { event := input.(controllers.Event) ns := event.Latest().(*corev1.Namespace)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 9.6K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
assert.NoError(t, err) // wait for an update event mt.Assert(EventTotals.Name(), map[string]string{"type": "update"}, monitortest.AtLeast(2)) // wait for the pod to be annotated // after Pod annotated, another update event will be triggered. assertPodAnnotated(t, client, pod) // Assert expected calls actually made fs.AssertExpectations(t)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 15.8K bytes - Viewed (0) -
licenses/cloud.google.com/go/auth/LICENSE
appropriateness of using or redistributing the Work and assume any risks associated with Your exercise of permissions under this License. 8. Limitation of Liability. In no event and under no legal theory, whether in tort (including negligence), contract, or otherwise, unless required by applicable law (such as deliberate and grossly
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 13:56:46 GMT 2024 - 11.1K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
// K8S may get a pod Add event without any IPs in the object, and the pod will later be updated with IPs. // // We always need the IPs, but this is fine because this AddPodToMesh can be called from the CNI plugin as well, // which always has the firsthand info of the IPs, even before K8S does - so we pass them separately here because
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
cni/pkg/plugin/plugin_test.go
cniAddServerCalled := false // replace the global CNI client with mock newCNIClient = func(address, path string) CNIEventClient { c := http.DefaultClient eventC := CNIEventClient{ client: c, url: address + path, } return eventC } testServer := httptest.NewServer(http.HandlerFunc(func(res http.ResponseWriter, req *http.Request) { cniAddServerCalled = true if serverErr {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 17.5K bytes - Viewed (0) -
cni/pkg/constants/constants.go
SkipTLSVerify = "skip-tls-verify" MonitoringPort = "monitoring-port" LogUDSAddress = "log-uds-address" ZtunnelUDSAddress = "ztunnel-uds-address" CNIEventAddress = "cni-event-address" AmbientEnabled = "ambient-enabled" AmbientDNSCapture = "ambient-dns-capture" AmbientIPv6 = "ambient-ipv6" // Repair RepairEnabled = "repair-enabled"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 2.7K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
type Config struct { types.NetConf // Add plugin-specific flags here LogLevel string `json:"log_level"` LogUDSAddress string `json:"log_uds_address"` CNIEventAddress string `json:"cni_event_address"` AmbientEnabled bool `json:"ambient_enabled"` Kubernetes Kubernetes `json:"kubernetes"` } // K8sArgs is the valid CNI_ARGS used for Kubernetes
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 10.5K bytes - Viewed (0) -
cni/README.md
1. By installing a separate, very basic "CNI plugin" binary onto the node to forward low-level pod lifecycle events (CmdAdd/CmdDel/etc) from whatever node-level CNI subsystem is in use to this node agent for processing via socket. 1. By running as a node-level daemonset that: - listens for these UDS events from the CNI plugin (which fire when new pods are spawned in an ambient-enabled namespace), and adds those pods to the ambient mesh.
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 12.3K bytes - Viewed (0) -
cni/pkg/config/config.go
// The HTTP port for monitoring MonitoringPort int // The UDS server address that CNI plugin will send log to. LogUDSAddress string // The watch server socket address that CNI plugin will forward CNI events to. CNIEventAddress string // The ztunnel server socket address that the ztunnel will connect to. ZtunnelUDSAddress string // Whether ambient is enabled AmbientEnabled bool
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 5.5K bytes - Viewed (0) -
manifests/charts/istiod-remote/templates/configmap.yaml
# The global default max number of annotation events per span. maxNumberOfAnnotations: {{ (($.Values.global.tracer).stackdriver).maxNumberOfAnnotations | default "200" }} # The global default max number of message events per span. maxNumberOfMessageEvents: {{ (($.Values.global.tracer).stackdriver).maxNumberOfMessageEvents | default "200" }}
Others - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 18 18:16:49 GMT 2024 - 4.9K bytes - Viewed (0)