Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
84 changes: 8 additions & 76 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@ The Developer Portal UI can also be used to help build your integration by showi
### Gradle

```groovy
implementation 'com.airbyte.api:public-api:0.1.1'
implementation 'com.airbyte.api:public-api:0.2.0'
```
<!-- End SDK Installation -->

Expand All @@ -46,86 +46,18 @@ public class Application {
public static void main(String[] args) {
try {
Airbyte sdk = Airbyte.builder()
.setSecurity(new Security() {{
.setSecurity(new Security("corrupti") {{
bearerAuth = "Bearer YOUR_BEARER_TOKEN_HERE";
}})
.build();

com.airbyte.api.models.shared.ConnectionCreateRequest req = new ConnectionCreateRequest() {{
configurations = new StreamConfigurations() {{
streams = new com.airbyte.api.models.shared.StreamConfiguration[]{{
add(new StreamConfiguration() {{
cursorField = new String[]{{
add("distinctio"),
add("quibusdam"),
add("unde"),
}};
name = "Johnnie Stamm";
primaryKey = new String[][]{{
add(new String[]{{
add("iure"),
add("magnam"),
}}),
add(new String[]{{
add("ipsa"),
add("delectus"),
add("tempora"),
add("suscipit"),
}}),
add(new String[]{{
add("minus"),
add("placeat"),
}}),
}};
syncMode = "incremental_append";
}}),
add(new StreamConfiguration() {{
cursorField = new String[]{{
add("excepturi"),
add("nisi"),
}};
name = "Jake Bernier MD";
primaryKey = new String[][]{{
add(new String[]{{
add("repellendus"),
add("sapiente"),
}}),
}};
syncMode = "incremental_deduped_history";
}}),
add(new StreamConfiguration() {{
cursorField = new String[]{{
add("at"),
}};
name = "Emilio Krajcik";
primaryKey = new String[][]{{
add(new String[]{{
add("porro"),
add("dolorum"),
add("dicta"),
}}),
add(new String[]{{
add("officia"),
add("occaecati"),
add("fugit"),
}}),
}};
syncMode = "incremental_append";
}}),
}};
}};
dataResidency = "eu";
destinationId = "c816742c-b739-4205-9293-96fea7596eb1";
name = "Lela Orn";
namespaceDefinition = "source";
com.airbyte.api.models.shared.ConnectionCreateRequest req = new ConnectionCreateRequest("9bd9d8d6-9a67-44e0-b467-cc8796ed151a", "05dfc2dd-f7cc-478c-a1ba-928fc816742c") {{
dataResidency = "us";
name = "Kayla O'Kon";
namespaceDefinition = "custom_format";
namespaceFormat = "${SOURCE_NAMESPACE}";
prefix = "dolorem";
schedule = new ConnectionScheduleCreate() {{
cronExpression = "corporis";
scheduleType = "manual";
}};
sourceId = "c5955907-aff1-4a3a-afa9-467739251aa5";
}}
prefix = "sequi";
}};

CreateConnectionResponse res = sdk.connections.createConnection(req);

Expand Down
10 changes: 9 additions & 1 deletion RELEASES.md
Original file line number Diff line number Diff line change
Expand Up @@ -143,4 +143,12 @@ Based on:
- OpenAPI Doc 1.0.0 https://prod.speakeasyapi.dev/v1/apis/public-api/version/v0.1.0/schema/download
- Speakeasy CLI 1.21.4 (2.19.1) https://github.com/speakeasy-api/speakeasy
### Releases
- [Maven Central v0.1.1] https://central.sonatype.com/artifact/com.airbyte/api/0.1.1 - .
- [Maven Central v0.1.1] https://central.sonatype.com/artifact/com.airbyte/api/0.1.1 - .

## 2023-04-22 00:12:58
### Changes
Based on:
- OpenAPI Doc 1.0.0 https://prod.speakeasyapi.dev/v1/apis/public-api/version/v0.1.0/schema/download
- Speakeasy CLI 1.22.1 (2.20.1) https://github.com/speakeasy-api/speakeasy
### Releases
- [Maven Central v0.2.0] https://central.sonatype.com/artifact/com.airbyte/api/0.2.0 - .
82 changes: 7 additions & 75 deletions USAGE.md
Original file line number Diff line number Diff line change
Expand Up @@ -18,86 +18,18 @@ public class Application {
public static void main(String[] args) {
try {
Airbyte sdk = Airbyte.builder()
.setSecurity(new Security() {{
.setSecurity(new Security("corrupti") {{
bearerAuth = "Bearer YOUR_BEARER_TOKEN_HERE";
}})
.build();

com.airbyte.api.models.shared.ConnectionCreateRequest req = new ConnectionCreateRequest() {{
configurations = new StreamConfigurations() {{
streams = new com.airbyte.api.models.shared.StreamConfiguration[]{{
add(new StreamConfiguration() {{
cursorField = new String[]{{
add("distinctio"),
add("quibusdam"),
add("unde"),
}};
name = "Johnnie Stamm";
primaryKey = new String[][]{{
add(new String[]{{
add("iure"),
add("magnam"),
}}),
add(new String[]{{
add("ipsa"),
add("delectus"),
add("tempora"),
add("suscipit"),
}}),
add(new String[]{{
add("minus"),
add("placeat"),
}}),
}};
syncMode = "incremental_append";
}}),
add(new StreamConfiguration() {{
cursorField = new String[]{{
add("excepturi"),
add("nisi"),
}};
name = "Jake Bernier MD";
primaryKey = new String[][]{{
add(new String[]{{
add("repellendus"),
add("sapiente"),
}}),
}};
syncMode = "incremental_deduped_history";
}}),
add(new StreamConfiguration() {{
cursorField = new String[]{{
add("at"),
}};
name = "Emilio Krajcik";
primaryKey = new String[][]{{
add(new String[]{{
add("porro"),
add("dolorum"),
add("dicta"),
}}),
add(new String[]{{
add("officia"),
add("occaecati"),
add("fugit"),
}}),
}};
syncMode = "incremental_append";
}}),
}};
}};
dataResidency = "eu";
destinationId = "c816742c-b739-4205-9293-96fea7596eb1";
name = "Lela Orn";
namespaceDefinition = "source";
com.airbyte.api.models.shared.ConnectionCreateRequest req = new ConnectionCreateRequest("9bd9d8d6-9a67-44e0-b467-cc8796ed151a", "05dfc2dd-f7cc-478c-a1ba-928fc816742c") {{
dataResidency = "us";
name = "Kayla O'Kon";
namespaceDefinition = "custom_format";
namespaceFormat = "${SOURCE_NAMESPACE}";
prefix = "dolorem";
schedule = new ConnectionScheduleCreate() {{
cronExpression = "corporis";
scheduleType = "manual";
}};
sourceId = "c5955907-aff1-4a3a-afa9-467739251aa5";
}}
prefix = "sequi";
}};

CreateConnectionResponse res = sdk.connections.createConnection(req);

Expand Down
6 changes: 3 additions & 3 deletions gen.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -2,14 +2,14 @@ configVersion: 1.0.0
management:
docChecksum: b33273ead3e10c4bc4f9bfeed6ad97a4
docVersion: 1.0.0
speakeasyVersion: 1.21.4
generationVersion: 2.19.1
speakeasyVersion: 1.22.1
generationVersion: 2.20.1
generation:
telemetryEnabled: false
sdkClassName: airbyte
singleTagPerOp: false
java:
version: 0.1.1
version: 0.2.0
artifactID: api
companyEmail: info@airbyte.com
companyName: Airbyte
Expand Down
2 changes: 1 addition & 1 deletion lib/build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ publishing {
maven(MavenPublication) {
groupId = 'com.airbyte'
artifactId = 'api'
version = '0.1.1'
version = '0.2.0'

from components.java

Expand Down
4 changes: 2 additions & 2 deletions lib/src/main/java/com/airbyte/api/Airbyte.java
Original file line number Diff line number Diff line change
Expand Up @@ -30,8 +30,8 @@ public class Airbyte {
private com.airbyte.api.models.shared.Security _security;
private String _serverUrl;
private String _language = "java";
private String _sdkVersion = "0.1.1";
private String _genVersion = "2.19.1";
private String _sdkVersion = "0.2.0";
private String _genVersion = "2.20.1";
/**
* The Builder class allows the configuration of a new instance of the SDK.
*/
Expand Down
16 changes: 4 additions & 12 deletions lib/src/main/java/com/airbyte/api/Connections.java
Original file line number Diff line number Diff line change
Expand Up @@ -57,11 +57,9 @@ public com.airbyte.api.models.operations.CreateConnectionResponse createConnecti

String contentType = httpRes.headers().firstValue("Content-Type").orElse("application/octet-stream");

com.airbyte.api.models.operations.CreateConnectionResponse res = new com.airbyte.api.models.operations.CreateConnectionResponse() {{
com.airbyte.api.models.operations.CreateConnectionResponse res = new com.airbyte.api.models.operations.CreateConnectionResponse(contentType, httpRes.statusCode()) {{
connectionResponse = null;
}};
res.statusCode = httpRes.statusCode();
res.contentType = contentType;
res.rawResponse = httpRes;

if (httpRes.statusCode() == 200) {
Expand Down Expand Up @@ -98,10 +96,8 @@ public com.airbyte.api.models.operations.DeleteConnectionResponse deleteConnecti

String contentType = httpRes.headers().firstValue("Content-Type").orElse("application/octet-stream");

com.airbyte.api.models.operations.DeleteConnectionResponse res = new com.airbyte.api.models.operations.DeleteConnectionResponse() {{
com.airbyte.api.models.operations.DeleteConnectionResponse res = new com.airbyte.api.models.operations.DeleteConnectionResponse(contentType, httpRes.statusCode()) {{
}};
res.statusCode = httpRes.statusCode();
res.contentType = contentType;
res.rawResponse = httpRes;

if (httpRes.statusCode() == 204 || httpRes.statusCode() == 403 || httpRes.statusCode() == 404) {
Expand Down Expand Up @@ -131,11 +127,9 @@ public com.airbyte.api.models.operations.GetConnectionResponse getConnection(com

String contentType = httpRes.headers().firstValue("Content-Type").orElse("application/octet-stream");

com.airbyte.api.models.operations.GetConnectionResponse res = new com.airbyte.api.models.operations.GetConnectionResponse() {{
com.airbyte.api.models.operations.GetConnectionResponse res = new com.airbyte.api.models.operations.GetConnectionResponse(contentType, httpRes.statusCode()) {{
connectionResponse = null;
}};
res.statusCode = httpRes.statusCode();
res.contentType = contentType;
res.rawResponse = httpRes;

if (httpRes.statusCode() == 200) {
Expand Down Expand Up @@ -178,11 +172,9 @@ public com.airbyte.api.models.operations.ListConnectionsResponse listConnections

String contentType = httpRes.headers().firstValue("Content-Type").orElse("application/octet-stream");

com.airbyte.api.models.operations.ListConnectionsResponse res = new com.airbyte.api.models.operations.ListConnectionsResponse() {{
com.airbyte.api.models.operations.ListConnectionsResponse res = new com.airbyte.api.models.operations.ListConnectionsResponse(contentType, httpRes.statusCode()) {{
connectionsResponse = null;
}};
res.statusCode = httpRes.statusCode();
res.contentType = contentType;
res.rawResponse = httpRes;

if (httpRes.statusCode() == 200) {
Expand Down
16 changes: 4 additions & 12 deletions lib/src/main/java/com/airbyte/api/Destinations.java
Original file line number Diff line number Diff line change
Expand Up @@ -55,11 +55,9 @@ public com.airbyte.api.models.operations.CreateDestinationResponse createDestina

String contentType = httpRes.headers().firstValue("Content-Type").orElse("application/octet-stream");

com.airbyte.api.models.operations.CreateDestinationResponse res = new com.airbyte.api.models.operations.CreateDestinationResponse() {{
com.airbyte.api.models.operations.CreateDestinationResponse res = new com.airbyte.api.models.operations.CreateDestinationResponse(contentType, httpRes.statusCode()) {{
destinationResponse = null;
}};
res.statusCode = httpRes.statusCode();
res.contentType = contentType;
res.rawResponse = httpRes;

if (httpRes.statusCode() == 200) {
Expand Down Expand Up @@ -96,10 +94,8 @@ public com.airbyte.api.models.operations.DeleteDestinationResponse deleteDestina

String contentType = httpRes.headers().firstValue("Content-Type").orElse("application/octet-stream");

com.airbyte.api.models.operations.DeleteDestinationResponse res = new com.airbyte.api.models.operations.DeleteDestinationResponse() {{
com.airbyte.api.models.operations.DeleteDestinationResponse res = new com.airbyte.api.models.operations.DeleteDestinationResponse(contentType, httpRes.statusCode()) {{
}};
res.statusCode = httpRes.statusCode();
res.contentType = contentType;
res.rawResponse = httpRes;

if (httpRes.statusCode() == 204 || httpRes.statusCode() == 403 || httpRes.statusCode() == 404) {
Expand Down Expand Up @@ -129,11 +125,9 @@ public com.airbyte.api.models.operations.GetDestinationResponse getDestination(c

String contentType = httpRes.headers().firstValue("Content-Type").orElse("application/octet-stream");

com.airbyte.api.models.operations.GetDestinationResponse res = new com.airbyte.api.models.operations.GetDestinationResponse() {{
com.airbyte.api.models.operations.GetDestinationResponse res = new com.airbyte.api.models.operations.GetDestinationResponse(contentType, httpRes.statusCode()) {{
destinationResponse = null;
}};
res.statusCode = httpRes.statusCode();
res.contentType = contentType;
res.rawResponse = httpRes;

if (httpRes.statusCode() == 200) {
Expand Down Expand Up @@ -176,11 +170,9 @@ public com.airbyte.api.models.operations.ListDestinationsResponse listDestinatio

String contentType = httpRes.headers().firstValue("Content-Type").orElse("application/octet-stream");

com.airbyte.api.models.operations.ListDestinationsResponse res = new com.airbyte.api.models.operations.ListDestinationsResponse() {{
com.airbyte.api.models.operations.ListDestinationsResponse res = new com.airbyte.api.models.operations.ListDestinationsResponse(contentType, httpRes.statusCode()) {{
destinationsResponse = null;
}};
res.statusCode = httpRes.statusCode();
res.contentType = contentType;
res.rawResponse = httpRes;

if (httpRes.statusCode() == 200) {
Expand Down
Loading