- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for mock (0.26 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 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 1.8K bytes - Viewed (0) -
istioctl/pkg/cli/mock_client.go
Xiaopeng Han <******@****.***> 1709887099 +0800
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 2.1K bytes - Viewed (0) -
cni/pkg/nodeagent/server_test.go
UID: types.UID("test"), Annotations: map[string]string{ constants.AmbientRedirection: constants.AmbientRedirectionEnabled, }, }, } } type fakeServer struct { mock.Mock testWG *WaitGroup // optional waitgroup, if code under test makes a number of async calls to fakeServer } func (f *fakeServer) AddPodToMesh(ctx context.Context, pod *corev1.Pod, podIPs []netip.Addr, netNs string) error {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 7.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 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 15.8K 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 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 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 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 21:29:40 GMT 2024 - 5.4K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache.go
func (p *podNetnsCache) UpsertPodCacheWithNetns(uid string, workload WorkloadInfo) Netns { // lock current snapshot pod map p.mu.Lock() defer p.mu.Unlock() if existing := p.currentPodCache[uid]; existing.Netns != nil { if existing.Netns.Inode() == workload.Netns.Inode() { workload.Netns.Close()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.5K bytes - Viewed (0) -
operator/cmd/mesh/manifest_shared_test.go
} } else if err != nil { return err } obj.SetResourceVersion(check.GetResourceVersion()) return clnt.Update(ctx, obj) }} // recreateSimpleTestEnv mocks fake kube api server which relies on a simple object tracker func recreateSimpleTestEnv() { log.Infof("Creating simple test environment\n") helmreconciler.TestMode = true s := scheme.Scheme
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 20 22:39:28 GMT 2024 - 11.7K bytes - Viewed (1) -
cni/pkg/nodeagent/fakes_test.go
} func (f *fakeZtunnel) PodAdded(ctx context.Context, pod *corev1.Pod, netns Netns) error { f.addedPods.Add(1) return f.addError } func (f *fakeZtunnel) Close() error { return nil } // fakeNs is a mock struct for testing type fakeNs struct { closed *atomic.Bool fd uintptr inode uint64 } func newFakeNs(fd uintptr) *fakeNs { // the fake inode is the fd! magic.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 3.9K 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 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0)