airbyte_client

Crates.ioairbyte_client
lib.rsairbyte_client
version0.41.0
sourcesrc
created_at2022-01-05 16:19:07.109412
updated_at2023-09-27 09:16:13.475058
descriptionAirbyte Client is an unofficial client library for the Airbyte API
homepagehttps://github.com/agyleOS/airbyte_client
repositoryhttps://github.com/agyleOS/airbyte_client
max_upload_size
id508504
size1,433,539
Omid Rad (omid)

documentation

https://docs.rs/crate/airbyte_client/latest

README

Rust API client for openapi

Airbyte Configuration API https://airbyte.io.

The Configuration API is an internal Airbyte API that is designed for communications between different Airbyte components.

  • Its main purpose is to enable the Airbyte Engineering team to configure the internal state of Airbyte Cloud
  • It is also sometimes used by OSS users to configure their own Self-Hosted Airbyte deployment (internal state, etc)

WARNING

  • Airbyte does NOT have active commitments to support this API long-term.
  • OSS users can utilize the Configuration API, but at their own risk.
  • This API is utilized internally by the Airbyte Engineering team and may be modified in the future if the need arises.
  • Modifications by the Airbyte Engineering team could create breaking changes and OSS users would need to update their code to catch up to any backwards incompatible changes in the API.

This API is a collection of HTTP RPC-style methods. While it is not a REST API, those familiar with REST should find the conventions of this API recognizable.

Here are some conventions that this API follows:

  • All endpoints are http POST methods.
  • All endpoints accept data via application/json request bodies. The API does not accept any data via query params.
  • The naming convention for endpoints is: localhost:8000/api/{VERSION}/{METHOD_FAMILY}/{METHOD_NAME} e.g. localhost:8000/api/v1/connections/create.
  • For all update methods, the whole object must be passed in, even the fields that did not change.

Authentication (OSS):

  • When authenticating to the Configuration API, you must use Basic Authentication by setting the Authentication Header to Basic and base64 encoding the username and password (which are airbyte and password by default - so base64 encoding airbyte:password results in YWlyYnl0ZTpwYXNzd29yZA==). So the full header reads 'Authorization': \"Basic YWlyYnl0ZTpwYXNzd29yZA==\"

Overview

This API client was generated by the OpenAPI Generator project. By using the openapi-spec from a remote server, you can easily generate an API client.

  • API version: 1.0.0
  • Package version: 1.0.0
  • Build package: org.openapitools.codegen.languages.RustClientCodegen

Installation

Put the package under your project folder in a directory named openapi and add the following to Cargo.toml under [dependencies]:

openapi = { path = "./openapi" }

Documentation for API Endpoints

All URIs are relative to http://localhost:8000/api

Class Method HTTP request Description

AttemptApi | save_stats | POST /v1/attempt/save_stats | For worker to set sync stats of a running attempt. AttemptApi | save_sync_config | POST /v1/attempt/save_sync_config | For worker to save the AttemptSyncConfig for an attempt. AttemptApi | set_workflow_in_attempt | POST /v1/attempt/set_workflow_in_attempt | For worker to register the workflow id in attempt. ConnectionApi | create_connection | POST /v1/connections/create | Create a connection between a source and a destination ConnectionApi | delete_connection | POST /v1/connections/delete | Delete a connection ConnectionApi | get_connection | POST /v1/connections/get | Get a connection ConnectionApi | list_all_connections_for_workspace | POST /v1/connections/list_all | Returns all connections for a workspace, including deleted connections. ConnectionApi | list_connections_by_actor_definition | POST /v1/connections/list_by_actor_definition | List all connections that use the provided actor definition ConnectionApi | list_connections_for_workspace | POST /v1/connections/list | Returns all connections for a workspace. ConnectionApi | reset_connection | POST /v1/connections/reset | Reset the data for the connection. Deletes data generated by the connection in the destination. Resets any cursors back to initial state. ConnectionApi | reset_connection_stream | POST /v1/connections/reset/stream | Reset the data for a specific stream in the connection. Deletes data generated by the stream in the destination. Resets any cursors back to initial state. ConnectionApi | search_connections | POST /v1/connections/search | Search connections ConnectionApi | sync_connection | POST /v1/connections/sync | Trigger a manual sync of the connection ConnectionApi | update_connection | POST /v1/connections/update | Update a connection ConnectorBuilderProjectApi | create_connector_builder_project | POST /v1/connector_builder_projects/create | Create new connector builder project ConnectorBuilderProjectApi | delete_connector_builder_project | POST /v1/connector_builder_projects/delete | Deletes connector builder project ConnectorBuilderProjectApi | get_connector_builder_project | POST /v1/connector_builder_projects/get_with_manifest | Get a connector builder project with draft manifest ConnectorBuilderProjectApi | list_connector_builder_projects | POST /v1/connector_builder_projects/list | List connector builder projects for workspace ConnectorBuilderProjectApi | publish_connector_builder_project | POST /v1/connector_builder_projects/publish | Publish a connector to the workspace ConnectorBuilderProjectApi | update_connector_builder_project | POST /v1/connector_builder_projects/update | Update connector builder project DeclarativeSourceDefinitionsApi | create_declarative_source_definition_manifest | POST /v1/declarative_source_definitions/create_manifest | Create a declarative manifest to be used by the specified source definition DeclarativeSourceDefinitionsApi | list_declarative_manifests | POST /v1/declarative_source_definitions/list_manifests | List all available declarative manifest versions of a declarative source definition DeclarativeSourceDefinitionsApi | update_declarative_manifest_version | POST /v1/declarative_source_definitions/update_active_manifest | Update the declarative manifest version for a source DestinationApi | check_connection_to_destination | POST /v1/destinations/check_connection | Check connection to the destination DestinationApi | check_connection_to_destination_for_update | POST /v1/destinations/check_connection_for_update | Check connection for a proposed update to a destination DestinationApi | clone_destination | POST /v1/destinations/clone | Clone destination DestinationApi | create_destination | POST /v1/destinations/create | Create a destination DestinationApi | delete_destination | POST /v1/destinations/delete | Delete the destination DestinationApi | get_destination | POST /v1/destinations/get | Get configured destination DestinationApi | list_destinations_for_workspace | POST /v1/destinations/list | List configured destinations for a workspace DestinationApi | partial_update_destination | POST /v1/destinations/partial_update | Update a destination partially DestinationApi | search_destinations | POST /v1/destinations/search | Search destinations DestinationApi | update_destination | POST /v1/destinations/update | Update a destination DestinationDefinitionApi | create_custom_destination_definition | POST /v1/destination_definitions/create_custom | Creates a custom destinationDefinition for the given workspace DestinationDefinitionApi | delete_destination_definition | POST /v1/destination_definitions/delete | Delete a destination definition DestinationDefinitionApi | get_destination_definition | POST /v1/destination_definitions/get | Get destinationDefinition DestinationDefinitionApi | get_destination_definition_for_workspace | POST /v1/destination_definitions/get_for_workspace | Get a destinationDefinition that is configured for the given workspace DestinationDefinitionApi | grant_destination_definition_to_workspace | POST /v1/destination_definitions/grant_definition | grant a private, non-custom destinationDefinition to a given workspace DestinationDefinitionApi | list_destination_definitions | POST /v1/destination_definitions/list | List all the destinationDefinitions the current Airbyte deployment is configured to use DestinationDefinitionApi | list_destination_definitions_for_workspace | POST /v1/destination_definitions/list_for_workspace | List all the destinationDefinitions the given workspace is configured to use DestinationDefinitionApi | list_latest_destination_definitions | POST /v1/destination_definitions/list_latest | List the latest destinationDefinitions Airbyte supports DestinationDefinitionApi | list_private_destination_definitions | POST /v1/destination_definitions/list_private | List all private, non-custom destinationDefinitions, and for each indicate whether the given workspace has a grant for using the definition. Used by admins to view and modify a given workspace's grants. DestinationDefinitionApi | revoke_destination_definition_from_workspace | POST /v1/destination_definitions/revoke_definition | revoke a grant to a private, non-custom destinationDefinition from a given workspace DestinationDefinitionApi | update_destination_definition | POST /v1/destination_definitions/update | Update destinationDefinition DestinationDefinitionSpecificationApi | get_destination_definition_specification | POST /v1/destination_definition_specifications/get | Get specification for a destinationDefinition DestinationDefinitionSpecificationApi | get_specification_for_destination_id | POST /v1/destination_definition_specifications/get_for_destination | Get specification for a destination DestinationOauthApi | complete_destination_o_auth | POST /v1/destination_oauths/complete_oauth | Given a destination def ID generate an access/refresh token etc. DestinationOauthApi | get_destination_o_auth_consent | POST /v1/destination_oauths/get_consent_url | Given a destination connector definition ID, return the URL to the consent screen where to redirect the user to. DestinationOauthApi | set_instancewide_destination_oauth_params | POST /v1/destination_oauths/oauth_params/create | Sets instancewide variables to be used for the oauth flow when creating this destination. When set, these variables will be injected into a connector's configuration before any interaction with the connector image itself. This enables running oauth flows with consistent variables e.g: the company's Google Ads developer_token, client_id, and client_secret without the user having to know about these variables. HealthApi | get_health_check | GET /v1/health | Health Check InternalApi | create_or_update_state | POST /v1/state/create_or_update | Create or update the state for a connection. InternalApi | get_attempt_normalization_statuses_for_job | POST /v1/jobs/get_normalization_status | Get normalization status to determine if we can bypass normalization phase InternalApi | save_stats | POST /v1/attempt/save_stats | For worker to set sync stats of a running attempt. InternalApi | save_sync_config | POST /v1/attempt/save_sync_config | For worker to save the AttemptSyncConfig for an attempt. InternalApi | set_workflow_in_attempt | POST /v1/attempt/set_workflow_in_attempt | For worker to register the workflow id in attempt. InternalApi | write_discover_catalog_result | POST /v1/sources/write_discover_catalog_result | Should only called from worker, to write result from discover activity back to DB. JobsApi | cancel_job | POST /v1/jobs/cancel | Cancels a job JobsApi | get_attempt_normalization_statuses_for_job | POST /v1/jobs/get_normalization_status | Get normalization status to determine if we can bypass normalization phase JobsApi | get_job_debug_info | POST /v1/jobs/get_debug_info | Gets all information needed to debug this job JobsApi | get_job_info | POST /v1/jobs/get | Get information about a job JobsApi | get_job_info_light | POST /v1/jobs/get_light | Get information about a job excluding attempt info and logs JobsApi | get_job_info_without_logs | POST /v1/jobs/get_without_logs | Get information about a job excluding logs JobsApi | get_last_replication_job | POST /v1/jobs/get_last_replication_job | JobsApi | list_jobs_for | POST /v1/jobs/list | Returns recent jobs for a connection. Jobs are returned in descending order by createdAt. LogsApi | get_logs | POST /v1/logs/get | Get logs NotificationsApi | try_notification_config | POST /v1/notifications/try | Try sending a notifications OpenapiApi | get_open_api_spec | GET /v1/openapi | Returns the openapi specification OperationApi | check_operation | POST /v1/operations/check | Check if an operation to be created is valid OperationApi | create_operation | POST /v1/operations/create | Create an operation to be applied as part of a connection pipeline OperationApi | delete_operation | POST /v1/operations/delete | Delete an operation OperationApi | get_operation | POST /v1/operations/get | Returns an operation OperationApi | list_operations_for_connection | POST /v1/operations/list | Returns all operations for a connection. OperationApi | update_operation | POST /v1/operations/update | Update an operation SchedulerApi | execute_destination_check_connection | POST /v1/scheduler/destinations/check_connection | Run check connection for a given destination configuration SchedulerApi | execute_source_check_connection | POST /v1/scheduler/sources/check_connection | Run check connection for a given source configuration SchedulerApi | execute_source_discover_schema | POST /v1/scheduler/sources/discover_schema | Run discover schema for a given source a source configuration SourceApi | apply_schema_change_for_source | POST /v1/sources/apply_schema_changes | Auto propagate the change on a catalog to a catalog saved in the DB. It will fetch all the connections linked to a source id and apply the provided diff to their catalog. SourceApi | check_connection_to_source | POST /v1/sources/check_connection | Check connection to the source SourceApi | check_connection_to_source_for_update | POST /v1/sources/check_connection_for_update | Check connection for a proposed update to a source SourceApi | clone_source | POST /v1/sources/clone | Clone source SourceApi | create_source | POST /v1/sources/create | Create a source SourceApi | delete_source | POST /v1/sources/delete | Delete a source SourceApi | discover_schema_for_source | POST /v1/sources/discover_schema | Discover the schema catalog of the source SourceApi | get_most_recent_source_actor_catalog | POST /v1/sources/most_recent_source_actor_catalog | Get most recent ActorCatalog for source SourceApi | get_source | POST /v1/sources/get | Get source SourceApi | list_sources_for_workspace | POST /v1/sources/list | List sources for workspace SourceApi | partial_update_source | POST /v1/sources/partial_update | Partially update a source SourceApi | search_sources | POST /v1/sources/search | Search sources SourceApi | update_source | POST /v1/sources/update | Update a source SourceApi | write_discover_catalog_result | POST /v1/sources/write_discover_catalog_result | Should only called from worker, to write result from discover activity back to DB. SourceDefinitionApi | create_custom_source_definition | POST /v1/source_definitions/create_custom | Creates a custom sourceDefinition for the given workspace SourceDefinitionApi | delete_source_definition | POST /v1/source_definitions/delete | Delete a source definition SourceDefinitionApi | get_source_definition | POST /v1/source_definitions/get | Get source SourceDefinitionApi | get_source_definition_for_workspace | POST /v1/source_definitions/get_for_workspace | Get a sourceDefinition that is configured for the given workspace SourceDefinitionApi | grant_source_definition_to_workspace | POST /v1/source_definitions/grant_definition | grant a private, non-custom sourceDefinition to a given workspace SourceDefinitionApi | list_latest_source_definitions | POST /v1/source_definitions/list_latest | List the latest sourceDefinitions Airbyte supports SourceDefinitionApi | list_private_source_definitions | POST /v1/source_definitions/list_private | List all private, non-custom sourceDefinitions, and for each indicate whether the given workspace has a grant for using the definition. Used by admins to view and modify a given workspace's grants. SourceDefinitionApi | list_source_definitions | POST /v1/source_definitions/list | List all the sourceDefinitions the current Airbyte deployment is configured to use SourceDefinitionApi | list_source_definitions_for_workspace | POST /v1/source_definitions/list_for_workspace | List all the sourceDefinitions the given workspace is configured to use SourceDefinitionApi | revoke_source_definition_from_workspace | POST /v1/source_definitions/revoke_definition | revoke a grant to a private, non-custom sourceDefinition from a given workspace SourceDefinitionApi | update_source_definition | POST /v1/source_definitions/update | Update a sourceDefinition SourceDefinitionSpecificationApi | get_source_definition_specification | POST /v1/source_definition_specifications/get | Get specification for a SourceDefinition. SourceDefinitionSpecificationApi | get_specification_for_source_id | POST /v1/source_definition_specifications/get_for_source | Get specification for a source. SourceOauthApi | complete_source_o_auth | POST /v1/source_oauths/complete_oauth | Given a source def ID generate an access/refresh token etc. SourceOauthApi | get_source_o_auth_consent | POST /v1/source_oauths/get_consent_url | Given a source connector definition ID, return the URL to the consent screen where to redirect the user to. SourceOauthApi | revoke_source_o_auth_tokens | POST /v1/source_oauths/revoke | Given a source definition ID and workspace ID revoke access/refresh token etc. SourceOauthApi | set_instancewide_source_oauth_params | POST /v1/source_oauths/oauth_params/create | Sets instancewide variables to be used for the oauth flow when creating this source. When set, these variables will be injected into a connector's configuration before any interaction with the connector image itself. This enables running oauth flows with consistent variables e.g: the company's Google Ads developer_token, client_id, and client_secret without the user having to know about these variables. StateApi | create_or_update_state | POST /v1/state/create_or_update | Create or update the state for a connection. StateApi | get_state | POST /v1/state/get | Fetch the current state for a connection. StreamStatusesApi | create_stream_status | POST /v1/stream_statuses/create | Creates a stream status. StreamStatusesApi | get_stream_statuses | POST /v1/stream_statuses/list | Gets a list of stream statuses filtered by parameters (with AND semantics). StreamStatusesApi | update_stream_status | POST /v1/stream_statuses/update | Updates a stream status. StreamsApi | create_stream_status | POST /v1/stream_statuses/create | Creates a stream status. StreamsApi | get_stream_statuses | POST /v1/stream_statuses/list | Gets a list of stream statuses filtered by parameters (with AND semantics). StreamsApi | update_stream_status | POST /v1/stream_statuses/update | Updates a stream status. WebBackendApi | get_state_type | POST /v1/web_backend/state/get_type | Fetch the current state type for a connection. WebBackendApi | web_backend_check_updates | POST /v1/web_backend/check_updates | Returns a summary of source and destination definitions that could be updated. WebBackendApi | web_backend_create_connection | POST /v1/web_backend/connections/create | Create a connection WebBackendApi | web_backend_get_connection | POST /v1/web_backend/connections/get | Get a connection WebBackendApi | web_backend_get_workspace_state | POST /v1/web_backend/workspace/state | Returns the current state of a workspace WebBackendApi | web_backend_list_connections_for_workspace | POST /v1/web_backend/connections/list | Returns all non-deleted connections for a workspace. WebBackendApi | web_backend_list_geographies | POST /v1/web_backend/geographies/list | Returns available geographies can be selected to run data syncs in a particular geography. The 'auto' entry indicates that the sync will be automatically assigned to a geography according to the platform default behavior. Entries other than 'auto' are two-letter country codes that follow the ISO 3166-1 alpha-2 standard. WebBackendApi | web_backend_update_connection | POST /v1/web_backend/connections/update | Update a connection WorkspaceApi | create_workspace | POST /v1/workspaces/create | Creates a workspace WorkspaceApi | delete_workspace | POST /v1/workspaces/delete | Deletes a workspace WorkspaceApi | get_workspace | POST /v1/workspaces/get | Find workspace by ID WorkspaceApi | get_workspace_by_connection_id | POST /v1/workspaces/get_by_connection_id | Find workspace by connection id WorkspaceApi | get_workspace_by_slug | POST /v1/workspaces/get_by_slug | Find workspace by slug WorkspaceApi | list_workspaces | POST /v1/workspaces/list | List all workspaces registered in the current Airbyte deployment WorkspaceApi | update_workspace | POST /v1/workspaces/update | Update workspace state WorkspaceApi | update_workspace_feedback | POST /v1/workspaces/tag_feedback_status_as_done | Update workspace feedback state WorkspaceApi | update_workspace_name | POST /v1/workspaces/update_name | Update workspace name

Documentation For Models

To get access to the crate's generated documentation, use:

cargo doc --open

Author

contact@airbyte.io

Commit count: 13

cargo fmt