- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for Mock (0.13 sec)
-
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) -
maven-compat/src/test/java/org/apache/maven/AbstractCoreMavenComponentTestCase.java
import org.eclipse.aether.internal.impl.SimpleLocalRepositoryManagerFactory; import org.eclipse.aether.repository.LocalRepository; import static org.codehaus.plexus.testing.PlexusExtension.getBasedir; import static org.mockito.Mockito.mock; @PlexusTest @Deprecated public abstract class AbstractCoreMavenComponentTestCase { @Inject protected PlexusContainer container; @Inject protected RepositorySystem repositorySystem;
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Thu May 02 15:10:38 GMT 2024 - 11.7K 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) -
cmd/bucket-targets.go
func (sys *BucketTargetSys) markOffline(ep *url.URL) { sys.hMutex.Lock() defer sys.hMutex.Unlock() if h, ok := sys.hc[ep.Host]; ok { h.Online = false sys.hc[ep.Host] = h } } func (sys *BucketTargetSys) initHC(ep *url.URL) { sys.hMutex.Lock() sys.hc[ep.Host] = epHealth{ Endpoint: ep.Host, Scheme: ep.Scheme, Online: true, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 20.9K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
return err } // if no update is needed return right away. if !update { z.poolMetaMutex.Lock() z.poolMeta = meta z.poolMetaMutex.Unlock() } else { newMeta := newPoolMeta(z, meta) if err = newMeta.save(ctx, z.serverPools); err != nil { return err } z.poolMetaMutex.Lock() z.poolMeta = newMeta z.poolMetaMutex.Unlock() } pools := meta.returnResumablePools()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
cmd/metacache-set.go
"fmt" "io" "math/rand" "strconv" "strings" "sync" "time" jsoniter "github.com/json-iterator/go" "github.com/minio/minio/internal/bucket/lifecycle" "github.com/minio/minio/internal/bucket/object/lock" "github.com/minio/minio/internal/bucket/versioning" "github.com/minio/minio/internal/color" "github.com/minio/minio/internal/hash" xioutil "github.com/minio/minio/internal/ioutil" "github.com/minio/pkg/v2/console" )
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:59:08 GMT 2024 - 30.4K bytes - Viewed (0) -
cmd/config-current.go
// found, otherwise use default parameters func newSrvConfig(objAPI ObjectLayer) error { // Initialize server config. srvCfg := newServerConfig() // hold the mutex lock before a new config is assigned. globalServerConfigMu.Lock() globalServerConfig = srvCfg globalServerConfigMu.Unlock() // Save config into file. return saveServerConfig(GlobalContext, objAPI, srvCfg) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 30.8K bytes - Viewed (0) -
cmd/erasure-sets.go
sets []*erasureObjects // Reference format. format *formatErasureV3 // erasureDisks mutex to lock erasureDisks. erasureDisksMu sync.RWMutex // Re-ordered list of disks per set. erasureDisks [][]StorageAPI // Distributed locker clients. erasureLockers setsDsyncLockers // Distributed lock owner (constant per running instance). erasureLockOwner string // List of endpoints provided on the command line.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 37.7K bytes - Viewed (5) -
cmd/admin-bucket-handlers.go
i.Buckets[bucket] = st } // ImportBucketMetadataHandler - imports all bucket metadata from a zipped file and overwrite bucket metadata config // There are some caveats regarding the following: // 1. object lock config - object lock should have been specified at time of bucket creation. Only default retention settings are imported here.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 32.5K bytes - Viewed (0) -
cmd/object-api-interface.go
CreatedAt time.Time // only for site replication NoLock bool // does not lock the make bucket call if set to 'true' } // DeleteBucketOptions provides options for DeleteBucket calls. type DeleteBucketOptions struct { NoLock bool // does not lock the delete bucket call if set to 'true' NoRecreate bool // do not recreate bucket on delete failures
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 17K bytes - Viewed (0)