- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 93 for uuid3 (0.24 sec)
-
internal/store/queuestore.go
func (store *QueueStore[I]) PutMultiple(item []I) error { store.Lock() defer store.Unlock() if uint64(len(store.entries)) >= store.entryLimit { return errLimitExceeded } // Generate a new UUID for the key. key, err := uuid.NewRandom() if err != nil { return err } return store.multiWrite(key.String(), item) } // multiWrite - writes an item to the directory.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Mar 25 16:44:20 UTC 2024 - 7.1K bytes - Viewed (0) -
tests/integration/telemetry/tracing/zipkin/client_tracing_test.go
// See the License for the specific language governing permissions and // limitations under the License. package zipkin import ( "errors" "fmt" "testing" "time" "github.com/google/uuid" "istio.io/istio/pkg/test/framework" "istio.io/istio/pkg/test/util/retry" "istio.io/istio/tests/integration/telemetry/tracing" )
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 2.4K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/test/kotlin/org/gradle/internal/cc/impl/ConfigurationCacheBuildOperationsTest.kt
import org.hamcrest.CoreMatchers.equalTo import org.hamcrest.MatcherAssert.assertThat import org.junit.Rule import org.junit.Test import org.mockito.ArgumentCaptor import org.mockito.ArgumentMatchers.any import java.util.UUID class ConfigurationCacheBuildOperationsTest { @JvmField @Rule val testDirectoryProvider = TestNameTestDirectoryProvider(javaClass) @Test fun `sets progress display name on store`() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:30 UTC 2024 - 3.1K bytes - Viewed (0) -
pkg/test/framework/resource/settings.go
if err != nil { t.Fatal(err) } return out } // Settings is the set of arguments to the test driver. type Settings struct { // Name of the test TestID string RunID uuid.UUID // Do not cleanup the resources after the test run. NoCleanup bool // Indicates that the tests are running in CI Mode CIMode bool
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 19:04:51 UTC 2024 - 9.2K bytes - Viewed (0) -
pkg/kubelet/winstats/perfcounter_nodestats_test.go
assert.NoError(t, err) assert.Equal(t, uint64(100), machineInfo.MemoryCapacity) hostname, _ := os.Hostname() assert.Equal(t, hostname, machineInfo.MachineID) // Check if it's an UUID. _, err = uuid.Parse(machineInfo.SystemUUID) assert.NoError(t, err) id, err := strconv.Atoi(machineInfo.BootID) assert.NoError(t, err) assert.NotZero(t, id) } func TestGetVersionInfo(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 26 18:37:21 UTC 2024 - 5.7K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/SingleUseDaemonClientServices.java
import org.gradle.launcher.daemon.configuration.DaemonParameters; import org.gradle.launcher.daemon.context.DaemonContext; import org.gradle.launcher.daemon.context.DaemonRequestContext; import java.io.InputStream; import java.util.UUID; /** * Takes care of instantiating and wiring together the services required by the single-use daemon client. */ public class SingleUseDaemonClientServices extends DaemonClientServicesSupport {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 09:21:42 UTC 2024 - 2.4K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/SingleUseDaemonClient.java
import org.gradle.launcher.daemon.protocol.Build; import org.gradle.launcher.exec.BuildActionParameters; import org.gradle.launcher.exec.BuildActionResult; import java.io.InputStream; import java.util.UUID; public class SingleUseDaemonClient extends DaemonClient { public static final String MESSAGE = "To honour the JVM settings for this build a single-use Daemon process will be forked.";
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 3.1K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/registry/PersistentDaemonRegistryTest.groovy
} def "clear the old entry with same port when storing new daemon info"() { given: MultiChoiceAddress address1 = new MultiChoiceAddress(UUID.randomUUID(), 54321, [InetAddress.localHost]) MultiChoiceAddress address2 = new MultiChoiceAddress(UUID.randomUUID(), 54321, [InetAddress.localHost]) registry.store(new DaemonInfo(address1, daemonContext(), "password".bytes, Idle))
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri May 24 00:09:57 UTC 2024 - 5.8K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/services/MessagingServices.java
import java.util.UUID; /** * A factory for a set of messaging services. Provides the following services: * * <ul> * * <li>{@link MessagingClient}</li> * * <li>{@link MessagingServer}</li> * * </ul> */ public class MessagingServices implements ServiceRegistrationProvider { private final IdGenerator<UUID> idGenerator = new UUIDGenerator(); @Provides
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:34:44 UTC 2024 - 2.8K bytes - Viewed (0) -
.teamcity/src/main/kotlin/model/FunctionalTestBucketGenerator.kt
buildProjectClassTimes[it.asId(MASTER_CHECK_CONFIGURATION)] }?.also { println("No test statistics found for ${testCoverage.asName()} (${testCoverage.uuid}), re-using the data from ${foundTestCoverage.asName()} (${foundTestCoverage.uuid})") } } } } fun onlyNativeSubprojectsForIntelMacs( testCoverage: TestCoverage, subprojectName: String ): Boolean {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Feb 15 17:04:41 UTC 2024 - 8.5K bytes - Viewed (0)