Skip to content

Commit 1719e53

Browse files
stainless-app[bot]stainless-app[bot]
committed
feat(api): update via SDK Studio (#21)
1 parent c5697d2 commit 1719e53

File tree

132 files changed

+10245
-8459
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

132 files changed

+10245
-8459
lines changed

‎openlayer-java-client-okhttp/src/main/kotlin/com/openlayer/api/client/okhttp/OkHttpClient.kt

+9-10
Original file line numberDiff line numberDiff line change
@@ -4,27 +4,28 @@ import com.google.common.collect.ListMultimap
44
import com.google.common.collect.MultimapBuilder
55
import com.openlayer.api.core.RequestOptions
66
import com.openlayer.api.core.http.HttpClient
7-
import com.openlayer.api.core.http.HttpMethod
87
import com.openlayer.api.core.http.HttpRequest
98
import com.openlayer.api.core.http.HttpRequestBody
109
import com.openlayer.api.core.http.HttpResponse
10+
import com.openlayer.api.core.http.HttpMethod
1111
import com.openlayer.api.errors.OpenlayerIoException
1212
import java.io.IOException
1313
import java.io.InputStream
1414
import java.net.Proxy
1515
import java.time.Duration
1616
import java.util.concurrent.CompletableFuture
17+
import java.util.concurrent.TimeUnit
1718
import okhttp3.Call
1819
import okhttp3.Callback
19-
import okhttp3.Headers
2020
import okhttp3.HttpUrl
21-
import okhttp3.HttpUrl.Companion.toHttpUrl
22-
import okhttp3.MediaType
23-
import okhttp3.MediaType.Companion.toMediaType
21+
import okhttp3.Response
2422
import okhttp3.Request
2523
import okhttp3.RequestBody
24+
import okhttp3.MediaType
25+
import okhttp3.Headers
26+
import okhttp3.HttpUrl.Companion.toHttpUrl
27+
import okhttp3.MediaType.Companion.toMediaType
2628
import okhttp3.RequestBody.Companion.toRequestBody
27-
import okhttp3.Response
2829
import okio.BufferedSink
2930

3031
class OkHttpClient
@@ -33,8 +34,7 @@ private constructor(private val okHttpClient: okhttp3.OkHttpClient, private val
3334

3435
private fun getClient(requestOptions: RequestOptions): okhttp3.OkHttpClient {
3536
val timeout = requestOptions.timeout ?: return okHttpClient
36-
return okHttpClient
37-
.newBuilder()
37+
return okHttpClient.newBuilder()
3838
.connectTimeout(timeout)
3939
.readTimeout(timeout)
4040
.writeTimeout(timeout)
@@ -76,8 +76,7 @@ private constructor(private val okHttpClient: okhttp3.OkHttpClient, private val
7676
override fun onFailure(call: Call, e: IOException) {
7777
future.completeExceptionally(OpenlayerIoException("Request failed", e))
7878
}
79-
}
80-
)
79+
})
8180

8281
return future
8382
}

‎openlayer-java-client-okhttp/src/main/kotlin/com/openlayer/api/client/okhttp/OpenlayerOkHttpClient.kt

+44-25
Original file line numberDiff line numberDiff line change
@@ -3,20 +3,25 @@
33
package com.openlayer.api.client.okhttp
44

55
import com.fasterxml.jackson.databind.json.JsonMapper
6-
import com.openlayer.api.client.OpenlayerClient
7-
import com.openlayer.api.client.OpenlayerClientImpl
8-
import com.openlayer.api.core.ClientOptions
6+
import com.google.common.collect.Multimap
97
import java.net.Proxy
108
import java.time.Clock
119
import java.time.Duration
10+
import java.util.Optional
11+
import com.openlayer.api.core.ClientOptions
12+
import com.openlayer.api.core.http.HttpClient
13+
import com.openlayer.api.client.OpenlayerClient
14+
import com.openlayer.api.client.OpenlayerClientImpl
1215

1316
class OpenlayerOkHttpClient private constructor() {
1417

1518
companion object {
1619

17-
@JvmStatic fun builder() = Builder()
20+
@JvmStatic
21+
fun builder() = Builder()
1822

19-
@JvmStatic fun fromEnv(): OpenlayerClient = builder().fromEnv().build()
23+
@JvmStatic
24+
fun fromEnv(): OpenlayerClient = builder().fromEnv().build()
2025
}
2126

2227
class Builder {
@@ -32,15 +37,21 @@ class OpenlayerOkHttpClient private constructor() {
3237
this.baseUrl = baseUrl
3338
}
3439

35-
fun jsonMapper(jsonMapper: JsonMapper) = apply { clientOptions.jsonMapper(jsonMapper) }
40+
fun jsonMapper(jsonMapper: JsonMapper) = apply {
41+
clientOptions.jsonMapper(jsonMapper)
42+
}
3643

37-
fun clock(clock: Clock) = apply { clientOptions.clock(clock) }
44+
fun clock(clock: Clock) = apply {
45+
clientOptions.clock(clock)
46+
}
3847

3948
fun headers(headers: Map<String, Iterable<String>>) = apply {
4049
clientOptions.headers(headers)
4150
}
4251

43-
fun putHeader(name: String, value: String) = apply { clientOptions.putHeader(name, value) }
52+
fun putHeader(name: String, value: String) = apply {
53+
clientOptions.putHeader(name, value)
54+
}
4455

4556
fun putHeaders(name: String, values: Iterable<String>) = apply {
4657
clientOptions.putHeaders(name, values)
@@ -50,34 +61,42 @@ class OpenlayerOkHttpClient private constructor() {
5061
clientOptions.putAllHeaders(headers)
5162
}
5263

53-
fun removeHeader(name: String) = apply { clientOptions.removeHeader(name) }
64+
fun removeHeader(name: String) = apply {
65+
clientOptions.removeHeader(name)
66+
}
5467

55-
fun timeout(timeout: Duration) = apply { this.timeout = timeout }
68+
fun timeout(timeout: Duration) = apply {
69+
this.timeout = timeout
70+
}
5671

57-
fun maxRetries(maxRetries: Int) = apply { clientOptions.maxRetries(maxRetries) }
72+
fun maxRetries(maxRetries: Int) = apply {
73+
clientOptions.maxRetries(maxRetries)
74+
}
5875

59-
fun proxy(proxy: Proxy) = apply { this.proxy = proxy }
76+
fun proxy(proxy: Proxy) = apply {
77+
this.proxy = proxy
78+
}
6079

6180
fun responseValidation(responseValidation: Boolean) = apply {
6281
clientOptions.responseValidation(responseValidation)
6382
}
6483

65-
fun apiKey(apiKey: String?) = apply { clientOptions.apiKey(apiKey) }
84+
fun apiKey(apiKey: String?) = apply {
85+
clientOptions.apiKey(apiKey)
86+
}
6687

67-
fun fromEnv() = apply { clientOptions.fromEnv() }
88+
fun fromEnv() = apply {
89+
clientOptions.fromEnv()
90+
}
6891

6992
fun build(): OpenlayerClient {
70-
return OpenlayerClientImpl(
71-
clientOptions
72-
.httpClient(
73-
OkHttpClient.builder()
74-
.baseUrl(baseUrl)
75-
.timeout(timeout)
76-
.proxy(proxy)
77-
.build()
78-
)
79-
.build()
80-
)
93+
return OpenlayerClientImpl(clientOptions
94+
.httpClient(OkHttpClient.builder()
95+
.baseUrl(baseUrl)
96+
.timeout(timeout)
97+
.proxy(proxy)
98+
.build())
99+
.build())
81100
}
82101
}
83102
}

‎openlayer-java-client-okhttp/src/main/kotlin/com/openlayer/api/client/okhttp/OpenlayerOkHttpClientAsync.kt

+44-25
Original file line numberDiff line numberDiff line change
@@ -3,20 +3,25 @@
33
package com.openlayer.api.client.okhttp
44

55
import com.fasterxml.jackson.databind.json.JsonMapper
6-
import com.openlayer.api.client.OpenlayerClientAsync
7-
import com.openlayer.api.client.OpenlayerClientAsyncImpl
8-
import com.openlayer.api.core.ClientOptions
6+
import com.google.common.collect.Multimap
97
import java.net.Proxy
108
import java.time.Clock
119
import java.time.Duration
10+
import java.util.Optional
11+
import com.openlayer.api.core.ClientOptions
12+
import com.openlayer.api.core.http.HttpClient
13+
import com.openlayer.api.client.OpenlayerClientAsync
14+
import com.openlayer.api.client.OpenlayerClientAsyncImpl
1215

1316
class OpenlayerOkHttpClientAsync private constructor() {
1417

1518
companion object {
1619

17-
@JvmStatic fun builder() = Builder()
20+
@JvmStatic
21+
fun builder() = Builder()
1822

19-
@JvmStatic fun fromEnv(): OpenlayerClientAsync = builder().fromEnv().build()
23+
@JvmStatic
24+
fun fromEnv(): OpenlayerClientAsync = builder().fromEnv().build()
2025
}
2126

2227
class Builder {
@@ -32,15 +37,21 @@ class OpenlayerOkHttpClientAsync private constructor() {
3237
this.baseUrl = baseUrl
3338
}
3439

35-
fun jsonMapper(jsonMapper: JsonMapper) = apply { clientOptions.jsonMapper(jsonMapper) }
40+
fun jsonMapper(jsonMapper: JsonMapper) = apply {
41+
clientOptions.jsonMapper(jsonMapper)
42+
}
3643

37-
fun clock(clock: Clock) = apply { clientOptions.clock(clock) }
44+
fun clock(clock: Clock) = apply {
45+
clientOptions.clock(clock)
46+
}
3847

3948
fun headers(headers: Map<String, Iterable<String>>) = apply {
4049
clientOptions.headers(headers)
4150
}
4251

43-
fun putHeader(name: String, value: String) = apply { clientOptions.putHeader(name, value) }
52+
fun putHeader(name: String, value: String) = apply {
53+
clientOptions.putHeader(name, value)
54+
}
4455

4556
fun putHeaders(name: String, values: Iterable<String>) = apply {
4657
clientOptions.putHeaders(name, values)
@@ -50,34 +61,42 @@ class OpenlayerOkHttpClientAsync private constructor() {
5061
clientOptions.putAllHeaders(headers)
5162
}
5263

53-
fun removeHeader(name: String) = apply { clientOptions.removeHeader(name) }
64+
fun removeHeader(name: String) = apply {
65+
clientOptions.removeHeader(name)
66+
}
5467

55-
fun timeout(timeout: Duration) = apply { this.timeout = timeout }
68+
fun timeout(timeout: Duration) = apply {
69+
this.timeout = timeout
70+
}
5671

57-
fun maxRetries(maxRetries: Int) = apply { clientOptions.maxRetries(maxRetries) }
72+
fun maxRetries(maxRetries: Int) = apply {
73+
clientOptions.maxRetries(maxRetries)
74+
}
5875

59-
fun proxy(proxy: Proxy) = apply { this.proxy = proxy }
76+
fun proxy(proxy: Proxy) = apply {
77+
this.proxy = proxy
78+
}
6079

6180
fun responseValidation(responseValidation: Boolean) = apply {
6281
clientOptions.responseValidation(responseValidation)
6382
}
6483

65-
fun apiKey(apiKey: String?) = apply { clientOptions.apiKey(apiKey) }
84+
fun apiKey(apiKey: String?) = apply {
85+
clientOptions.apiKey(apiKey)
86+
}
6687

67-
fun fromEnv() = apply { clientOptions.fromEnv() }
88+
fun fromEnv() = apply {
89+
clientOptions.fromEnv()
90+
}
6891

6992
fun build(): OpenlayerClientAsync {
70-
return OpenlayerClientAsyncImpl(
71-
clientOptions
72-
.httpClient(
73-
OkHttpClient.builder()
74-
.baseUrl(baseUrl)
75-
.timeout(timeout)
76-
.proxy(proxy)
77-
.build()
78-
)
79-
.build()
80-
)
93+
return OpenlayerClientAsyncImpl(clientOptions
94+
.httpClient(OkHttpClient.builder()
95+
.baseUrl(baseUrl)
96+
.timeout(timeout)
97+
.proxy(proxy)
98+
.build())
99+
.build())
81100
}
82101
}
83102
}

‎openlayer-java-core/src/main/kotlin/com/openlayer/api/client/OpenlayerClient.kt

+19
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,27 @@
44

55
package com.openlayer.api.client
66

7+
import java.time.Duration
8+
import java.util.Base64
9+
import java.util.Optional
10+
import java.util.concurrent.CompletableFuture
11+
import com.openlayer.api.core.ClientOptions
12+
import com.openlayer.api.core.http.HttpMethod
13+
import com.openlayer.api.core.http.HttpRequest
14+
import com.openlayer.api.core.http.HttpResponse.Handler
15+
import com.openlayer.api.core.JsonField
16+
import com.openlayer.api.core.RequestOptions
17+
import com.openlayer.api.errors.OpenlayerError
18+
import com.openlayer.api.errors.OpenlayerInvalidDataException
719
import com.openlayer.api.models.*
820
import com.openlayer.api.services.blocking.*
21+
import com.openlayer.api.services.emptyHandler
22+
import com.openlayer.api.services.errorHandler
23+
import com.openlayer.api.services.json
24+
import com.openlayer.api.services.jsonHandler
25+
import com.openlayer.api.services.stringHandler
26+
import com.openlayer.api.services.binaryHandler
27+
import com.openlayer.api.services.withErrorHandler
928

1029
interface OpenlayerClient {
1130

‎openlayer-java-core/src/main/kotlin/com/openlayer/api/client/OpenlayerClientAsync.kt

+19
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,27 @@
44

55
package com.openlayer.api.client
66

7+
import java.time.Duration
8+
import java.util.Base64
9+
import java.util.Optional
10+
import java.util.concurrent.CompletableFuture
11+
import com.openlayer.api.core.ClientOptions
12+
import com.openlayer.api.core.http.HttpMethod
13+
import com.openlayer.api.core.http.HttpRequest
14+
import com.openlayer.api.core.http.HttpResponse.Handler
15+
import com.openlayer.api.core.JsonField
16+
import com.openlayer.api.core.RequestOptions
17+
import com.openlayer.api.errors.OpenlayerError
18+
import com.openlayer.api.errors.OpenlayerInvalidDataException
719
import com.openlayer.api.models.*
820
import com.openlayer.api.services.async.*
21+
import com.openlayer.api.services.emptyHandler
22+
import com.openlayer.api.services.errorHandler
23+
import com.openlayer.api.services.json
24+
import com.openlayer.api.services.jsonHandler
25+
import com.openlayer.api.services.stringHandler
26+
import com.openlayer.api.services.binaryHandler
27+
import com.openlayer.api.services.withErrorHandler
928

1029
interface OpenlayerClientAsync {
1130

‎openlayer-java-core/src/main/kotlin/com/openlayer/api/client/OpenlayerClientAsyncImpl.kt

+17-7
Original file line numberDiff line numberDiff line change
@@ -2,17 +2,29 @@
22

33
package com.openlayer.api.client
44

5+
import java.time.Duration
6+
import java.util.Base64
7+
import java.util.Optional
8+
import java.util.concurrent.CompletableFuture
59
import com.openlayer.api.core.ClientOptions
10+
import com.openlayer.api.core.http.HttpMethod
11+
import com.openlayer.api.core.http.HttpRequest
612
import com.openlayer.api.core.http.HttpResponse.Handler
13+
import com.openlayer.api.core.JsonField
14+
import com.openlayer.api.core.RequestOptions
715
import com.openlayer.api.errors.OpenlayerError
16+
import com.openlayer.api.errors.OpenlayerInvalidDataException
817
import com.openlayer.api.models.*
918
import com.openlayer.api.services.async.*
19+
import com.openlayer.api.services.emptyHandler
1020
import com.openlayer.api.services.errorHandler
21+
import com.openlayer.api.services.json
22+
import com.openlayer.api.services.jsonHandler
23+
import com.openlayer.api.services.stringHandler
24+
import com.openlayer.api.services.binaryHandler
25+
import com.openlayer.api.services.withErrorHandler
1126

12-
class OpenlayerClientAsyncImpl
13-
constructor(
14-
private val clientOptions: ClientOptions,
15-
) : OpenlayerClientAsync {
27+
class OpenlayerClientAsyncImpl constructor(private val clientOptions: ClientOptions, ) : OpenlayerClientAsync {
1628

1729
private val errorHandler: Handler<OpenlayerError> = errorHandler(clientOptions.jsonMapper)
1830

@@ -22,9 +34,7 @@ constructor(
2234

2335
private val commits: CommitServiceAsync by lazy { CommitServiceAsyncImpl(clientOptions) }
2436

25-
private val inferencePipelines: InferencePipelineServiceAsync by lazy {
26-
InferencePipelineServiceAsyncImpl(clientOptions)
27-
}
37+
private val inferencePipelines: InferencePipelineServiceAsync by lazy { InferencePipelineServiceAsyncImpl(clientOptions) }
2838

2939
private val storage: StorageServiceAsync by lazy { StorageServiceAsyncImpl(clientOptions) }
3040

0 commit comments

Comments
 (0)