- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 25 for Rock (0.15 sec)
-
cni/pkg/ipset/nldeps_mock.go
// See the License for the specific language governing permissions and // limitations under the License. package ipset import ( "net/netip" "github.com/stretchr/testify/mock" ) type MockedIpsetDeps struct { mock.Mock } func FakeNLDeps() *MockedIpsetDeps { return &MockedIpsetDeps{} } func (m *MockedIpsetDeps) ipsetIPHashCreate(name string, v6 bool) error { args := m.Called(name, v6)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 1.8K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
// See the License for the specific language governing permissions and // limitations under the License. package nodeagent import ( "context" "fmt" "testing" "time" "github.com/stretchr/testify/mock" corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/types" "istio.io/istio/cni/pkg/util" "istio.io/istio/pkg/config/constants" "istio.io/istio/pkg/kube"
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Feb 08 01:03:24 GMT 2024 - 15.8K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
} func (c *connMgr) addConn(conn *ZtunnelConnection) { log.Debug("ztunnel connected") c.mu.Lock() defer c.mu.Unlock() c.connectionSet[conn] = struct{}{} c.latestConn = conn ztunnelConnected.RecordInt(int64(len(c.connectionSet))) } func (c *connMgr) LatestConn() *ZtunnelConnection { c.mu.Lock() defer c.mu.Unlock() return c.latestConn } func (c *connMgr) deleteConn(conn *ZtunnelConnection) {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
cni/pkg/log/uds.go
continue } msg.Msg = strings.TrimSpace(msg.Msg) messages = append(messages, msg) } // Lock log message printing to prevent log messages from different CNI // processes interleave. l.mu.Lock() defer l.mu.Unlock() for _, m := range messages { // There is no fatal log from CNI plugin switch m.Level { case "debug":
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Nov 29 01:05:12 GMT 2023 - 3.3K bytes - Viewed (0) -
cni/pkg/plugin/plugin_test.go
} func buildMockConf(ambientEnabled bool, eventURL string) string { return fmt.Sprintf( mockConfTmpl, "1.0.0", "1.0.0", "eth0", testSandboxDirectory, eventURL, ambientEnabled, "mock", ) } func buildFakePodAndNSForClient() (*corev1.Pod, *corev1.Namespace) { proxy := corev1.Container{Name: "mockContainer"} app := corev1.Container{Name: "foo-init"} fakePod := &corev1.Pod{
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 17.5K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher_test.go
Status: corev1.PodStatus{ PodIP: fakePodIP, }, } ns := &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "funkyns"}} client := kube.NewFakeClient(ns, pod) // We are expecting at most 1 calls to the mock, wait for them wg, waitForMockCalls := NewWaitForNCalls(t, 1) fs := &fakeServer{testWG: wg} fs.On("AddPodToMesh", ctx, pod, util.GetPodIPsIfPresent(pod), valid.Netns, ).Return(nil)
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Feb 02 08:18:40 GMT 2024 - 5.4K bytes - Viewed (0) -
istioctl/pkg/cli/mock_client.go
Xiaopeng Han <******@****.***> 1709887099 +0800
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 2.1K bytes - Viewed (0) -
manifests/charts/ztunnel/templates/daemonset.yaml
- mountPath: /var/run/secrets/istio name: istiod-ca-cert - mountPath: /var/run/secrets/tokens name: istio-token - mountPath: /var/run/ztunnel name: cni-ztunnel-sock-dir {{- with .Values.volumeMounts }} {{- toYaml . | nindent 8 }} {{- end }} priorityClassName: system-node-critical
Others - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 5K bytes - Viewed (0) -
istioctl/pkg/metrics/metrics_test.go
return promv1.AlertsResult{}, fmt.Errorf("TODO mockPromAPI doesn't mock Alerts") } func (client mockPromAPI) AlertManagers(ctx context.Context) (promv1.AlertManagersResult, error) { return promv1.AlertManagersResult{}, fmt.Errorf("TODO mockPromAPI doesn't mock AlertManagers") } func (client mockPromAPI) CleanTombstones(ctx context.Context) error { return nil }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Oct 25 02:07:44 GMT 2023 - 7.9K bytes - Viewed (0) -
manifests/charts/istio-control/istio-discovery/templates/role.yaml
- apiGroups: ["networking.istio.io"] verbs: ["create"] resources: ["gateways"] # For storing CA secret - apiGroups: [""] resources: ["secrets"] # TODO lock this down to istio-ca-cert if not using the DNS cert mesh config verbs: ["create", "get", "watch", "list", "update", "delete"] # For status controller, so it can delete the distribution report configmap - apiGroups: [""]
Others - Registered: Wed Mar 20 22:53:08 GMT 2024 - Last Modified: Thu May 04 16:21:31 GMT 2023 - 971 bytes - Viewed (0)