- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 86 for val1 (0.23 sec)
-
docs/bucket/replication/setup_ilm_expiry_replication.sh
## Add ILM rules ./mc ilm add sitea/bucket --transition-days 0 --transition-tier WARM-TIER --transition-days 0 --noncurrent-expire-days 2 --expire-days 3 --prefix "myprefix" --tags "tag1=val1&tag2=val2" ./mc ilm rule list sitea/bucket ## Check ilm expiry flag ./mc admin replicate info sitea --json flag1=$(./mc admin replicate info sitea --json | jq '.sites[0]."replicate-ilm-expiry"')
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 00:31:12 GMT 2024 - 12.7K bytes - Viewed (0) -
docs/site-replication/run-multi-site-minio-idp.sh
exit_1 fi # "Test if most recent tag update is replicated" ./mc tag set minio2/newbucket "key=val1" if [ $? -ne 0 ]; then echo "expecting tag set to be successful. exiting.." exit_1 fi sleep 5 val=$(./mc tag list minio1/newbucket --json | jq -r .tagset | jq -r .key) if [ "${val}" != "val1" ]; then echo "expected bucket tag to have replicated, exiting..." exit_1 fi
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 07 00:19:24 GMT 2024 - 11.9K bytes - Viewed (0) -
okhttp-logging-interceptor/src/main/kotlin/okhttp3/logging/HttpLoggingInterceptor.kt
override fun intercept(chain: Interceptor.Chain): Response { val level = this.level val request = chain.request() if (level == Level.NONE) { return chain.proceed(request) } val logBody = level == Level.BODY val logHeaders = logBody || level == Level.HEADERS val requestBody = request.body val connection = chain.connection() var requestStartMessage =
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 09:14:38 GMT 2024 - 11.2K bytes - Viewed (1) -
build-logic/dependency-modules/src/main/kotlin/gradlebuild/modules/extension/ExternalModulesExtension.kt
val antLauncher = "org.apache.ant:ant-launcher" val antJunit = "org.apache.ant:ant-junit" val asm = "org.ow2.asm:asm" val asmAnalysis = "org.ow2.asm:asm-analysis" val asmCommons = "org.ow2.asm:asm-commons" val asmTree = "org.ow2.asm:asm-tree" val asmUtil = "org.ow2.asm:asm-util" val assertj = "org.assertj:assertj-core" val awsS3Core = "com.amazonaws:aws-java-sdk-core"
Plain Text - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Tue Apr 16 15:50:58 GMT 2024 - 14.4K bytes - Viewed (0) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirCompilerFacility.kt
configuration: CompilerConfiguration, ): CodeFragmentMappings { val codeFragment = mainFirFile.codeFragment val capturedData = CodeFragmentCapturedValueAnalyzer.analyze(resolveSession, codeFragment) val capturedSymbols = capturedData.symbols val capturedValues = capturedSymbols.map { it.value } val injectedSymbols = capturedSymbols.map {
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Fri Apr 19 11:06:47 GMT 2024 - 32.2K bytes - Viewed (1) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirScopeProvider.kt
import org.jetbrains.kotlin.utils.exceptions.errorWithAttachment import org.jetbrains.kotlin.utils.exceptions.withPsiEntry internal class KtFirScopeProvider( override val analysisSession: KtFirAnalysisSession, private val builder: KtSymbolByFirBuilder, private val firResolveSession: LLFirResolveSession, ) : KtScopeProvider() { private fun getScopeSession(): ScopeSession {
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Thu Apr 25 18:05:58 GMT 2024 - 18.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
*/ class RealCall( val client: OkHttpClient, /** The application's original request unadulterated by redirects or auth headers. */ val originalRequest: Request, val forWebSocket: Boolean, ) : Call, Cloneable { internal val lock: ReentrantLock = ReentrantLock() private val connectionPool: RealConnectionPool = client.connectionPool.delegate
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 17.9K bytes - Viewed (2) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt
} } @Throws(IOException::class) private fun startHttp2() { val socket = this.socket!! val source = this.source!! val sink = this.sink!! socket.soTimeout = 0 // HTTP/2 connection timeouts are set per-stream. val flowControlListener = connectionListener as? FlowControlListener ?: FlowControlListener.None val http2Connection = Http2Connection.Builder(client = true, taskRunner)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 15.4K bytes - Viewed (0) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/KtSymbolByFirBuilder.kt
*/ internal class KtSymbolByFirBuilder( private val project: Project, val analysisSession: KtFirAnalysisSession, val token: KtLifetimeToken, ) { private val firResolveSession: LLFirResolveSession get() = analysisSession.firResolveSession private val firProvider: FirSymbolProvider get() = rootSession.symbolProvider val rootSession: FirSession = firResolveSession.useSiteFirSession
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Thu Mar 28 09:06:28 GMT 2024 - 32.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/RouteSelectorTest.kt
class RouteSelectorTest { @RegisterExtension val platform = PlatformRule() @RegisterExtension val clientTestRule = OkHttpClientTestRule() private val dns = FakeDns() private val proxySelector = RecordingProxySelector() private val uriHost = "hosta" private val uriPort = 1003 private val factory = TestValueFactory().apply { this.dns = ******@****.***
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Mar 06 17:33:38 GMT 2024 - 20.8K bytes - Viewed (0)