- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 64 for init (0.19 sec)
-
cmd/server-main.go
}) // Initialize site replication manager after bucket metadata bootstrapTrace("globalSiteReplicationSys.Init", func() { globalSiteReplicationSys.Init(GlobalContext, newObject) }) // Initialize quota manager. bootstrapTrace("globalBucketQuotaSys.Init", func() { globalBucketQuotaSys.Init(newObject) }) // Populate existing buckets to the etcd backend if globalDNSConfig != nil {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 32.7K bytes - Viewed (1) -
.teamcity/src/main/kotlin/configurations/FlakyTestQuarantine.kt
import model.CIBuildModel import model.Stage import model.StageName class FlakyTestQuarantine(model: CIBuildModel, stage: Stage, os: Os, arch: Arch = Arch.AMD64) : BaseGradleBuildType(stage = stage, init = { id("${model.projectId}_FlakyQuarantine_${os.asName()}_${arch.asName()}") name = "Flaky Test Quarantine - ${os.asName()} ${arch.asName()}" description = "Run all flaky tests skipped multiple times"
Plain Text - Registered: Wed Apr 24 11:36:11 GMT 2024 - Last Modified: Wed Apr 24 08:17:56 GMT 2024 - 3.4K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/configdump.go
func (c *ConfigWriter) PrintPodRootCAFromDynamicSecretDump() (string, error) { // TODO return "", nil } func (c *ConfigWriter) tabwriter() *tabwriter.Writer { w := new(tabwriter.Writer).Init(c.Stdout, 0, 8, 1, ' ', 0) return w
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 2.8K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/certificates.go
secret.CertChain = secret.CertChain[1:] n := new(big.Int) n, _ = n.SetString(ca.SerialNumber, 10) fmt.Fprintf(w, "%v\t%v\t%v\t%v\t%x\t%v\t%v\n", secret.Identity, "CA", secret.State, certNotExpired(ca), n, valueOrNA(ca.ExpirationTime), valueOrNA(ca.ValidFrom)) // print the rest of the cert chain for _, ca := range secret.CertChain { n := new(big.Int) n, _ = n.SetString(ca.SerialNumber, 10)
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 3.5K bytes - Viewed (0) -
.teamcity/src/main/kotlin/configurations/PerformanceTest.kt
description: String, performanceSubProject: String, val testProjects: List<String>, val bucketIndex: Int, extraParameters: String = "", performanceTestTaskSuffix: String = "PerformanceTest", preBuildSteps: BuildSteps.() -> Unit = {} ) : BaseGradleBuildType( stage = stage, init = { this.id(performanceTestBuildSpec.asConfigurationId(model, "bucket${bucketIndex + 1}"))
Plain Text - Registered: Wed Apr 24 11:36:11 GMT 2024 - Last Modified: Wed Apr 24 08:17:56 GMT 2024 - 5.3K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/endpoint.go
return err } } _, _ = fmt.Fprintln(c.Stdout, string(out)) return nil } func (c *ConfigWriter) PrintEndpointsSummary(filter EndpointFilter) error { w := new(tabwriter.Writer).Init(c.Stdout, 0, 8, 5, ' ', 0) fmt.Fprintln(w, "NAME\tSTATUS\tLOCALITY\tCLUSTER") dump, err := c.retrieveSortedEndpointsSlice(filter) if err != nil { return err } for _, eds := range dump {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Sun Apr 21 17:42:54 GMT 2024 - 5.6K bytes - Viewed (0) -
.teamcity/src/test/kotlin/PerformanceTestBuildTypeTest.kt
import model.Stage import model.StageName import org.junit.jupiter.api.Assertions.assertEquals import org.junit.jupiter.api.Test import java.io.File class PerformanceTestBuildTypeTest { init { DslContext.initForTest() } private val buildModel = CIBuildModel( projectId = "Gradle_Check", branch = VersionedSettingsBranch("master"),
Plain Text - Registered: Wed Apr 24 11:36:11 GMT 2024 - Last Modified: Wed Apr 24 08:17:56 GMT 2024 - 7.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
init { // Put a floor on the keep alive duration, otherwise cleanup will spin loop. require(keepAliveDuration > 0L) { "keepAliveDuration <= 0: $keepAliveDuration" } } fun idleConnectionCount(): Int { return connections.count { it.withLock { it.calls.isEmpty() } } } fun connectionCount(): Int { return connections.size } /**
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 16.2K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint.go
if err != nil { return err } if len(gws.Items) == 0 { fmt.Fprintln(writer, "No waypoints found.") return nil } w := new(tabwriter.Writer).Init(writer, 0, 8, 5, ' ', 0) slices.SortFunc(gws.Items, func(i, j gateway.Gateway) int { if r := cmp.Compare(i.Namespace, j.Namespace); r != 0 { return r } return cmp.Compare(i.Name, j.Name) }) filteredGws := make([]gateway.Gateway, 0)
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Mon Apr 22 20:20:40 GMT 2024 - 15K bytes - Viewed (0) -
cmd/globals.go
diskMinInodes = 1000 // tlsClientSessionCacheSize is the cache size for client sessions. tlsClientSessionCacheSize = 100 ) func init() { // Injected to prevent circular dependency. pubsub.GetByteBuffer = grid.GetByteBuffer } type poolDisksLayout struct { cmdline string layout [][]string } type disksLayout struct {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 16.5K bytes - Viewed (0)