Skip to content

Commit

Permalink
Merge branch 'main' into fix/support-sla-policies
Browse files Browse the repository at this point in the history
  • Loading branch information
shortcuts authored Dec 24, 2024
2 parents b9d3fea + 8b40a31 commit a5b32f6
Show file tree
Hide file tree
Showing 35 changed files with 41 additions and 66 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1612,7 +1612,7 @@ public interface IIngestionClient
List<Transformation> SearchTransformations(TransformationSearch transformationSearch, RequestOptions options = null, CancellationToken cancellationToken = default);

/// <summary>
/// Triggers a stream-listing request for a source. Triggering stream-listing requests only works with sources with `type: docker` and `imageType: singer`.
/// Triggers a stream-listing request for a source. Triggering stream-listing requests only works with sources with `type: docker` and `imageType: airbyte`.
/// </summary>
///
/// Required API Key ACLs:
Expand All @@ -1629,7 +1629,7 @@ public interface IIngestionClient
Task<WatchResponse> TriggerDockerSourceDiscoverAsync(string sourceID, RequestOptions options = null, CancellationToken cancellationToken = default);

/// <summary>
/// Triggers a stream-listing request for a source. Triggering stream-listing requests only works with sources with `type: docker` and `imageType: singer`. (Synchronous version)
/// Triggers a stream-listing request for a source. Triggering stream-listing requests only works with sources with `type: docker` and `imageType: airbyte`. (Synchronous version)
/// </summary>
///
/// Required API Key ACLs:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,22 +18,16 @@ namespace Algolia.Search.Models.Ingestion;
[JsonConverter(typeof(Serializer.JsonStringEnumConverter<DockerImageType>))]
public enum DockerImageType
{
/// <summary>
/// Enum Singer for value: singer
/// </summary>
[JsonPropertyName("singer")]
Singer = 1,

/// <summary>
/// Enum Custom for value: custom
/// </summary>
[JsonPropertyName("custom")]
Custom = 2,
Custom = 1,

/// <summary>
/// Enum Airbyte for value: airbyte
/// </summary>
[JsonPropertyName("airbyte")]
Airbyte = 3
Airbyte = 2
}

Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@
namespace Algolia.Search.Models.Ingestion;

/// <summary>
/// The selected streams of a singer or airbyte connector.
/// The selected streams of an airbyte connector.
/// </summary>
public partial class DockerStreamsInput
{
Expand Down

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Original file line number Diff line number Diff line change
Expand Up @@ -3671,7 +3671,7 @@ public CompletableFuture<List<Transformation>> searchTransformationsAsync(@Nonnu

/**
* Triggers a stream-listing request for a source. Triggering stream-listing requests only works
* with sources with `type: docker` and `imageType: singer`.
* with sources with `type: docker` and `imageType: airbyte`.
*
* @param sourceID Unique identifier of a source. (required)
* @param requestOptions The requestOptions to send along with the query, they will be merged with
Expand All @@ -3684,7 +3684,7 @@ public WatchResponse triggerDockerSourceDiscover(@Nonnull String sourceID, Reque

/**
* Triggers a stream-listing request for a source. Triggering stream-listing requests only works
* with sources with `type: docker` and `imageType: singer`.
* with sources with `type: docker` and `imageType: airbyte`.
*
* @param sourceID Unique identifier of a source. (required)
* @throws AlgoliaRuntimeException If it fails to process the API call
Expand All @@ -3695,7 +3695,7 @@ public WatchResponse triggerDockerSourceDiscover(@Nonnull String sourceID) throw

/**
* (asynchronously) Triggers a stream-listing request for a source. Triggering stream-listing
* requests only works with sources with `type: docker` and `imageType: singer`.
* requests only works with sources with `type: docker` and `imageType: airbyte`.
*
* @param sourceID Unique identifier of a source. (required)
* @param requestOptions The requestOptions to send along with the query, they will be merged with
Expand All @@ -3712,7 +3712,7 @@ public CompletableFuture<WatchResponse> triggerDockerSourceDiscoverAsync(@Nonnul

/**
* (asynchronously) Triggers a stream-listing request for a source. Triggering stream-listing
* requests only works with sources with `type: docker` and `imageType: singer`.
* requests only works with sources with `type: docker` and `imageType: airbyte`.
*
* @param sourceID Unique identifier of a source. (required)
* @throws AlgoliaRuntimeException If it fails to process the API call
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,8 +8,6 @@

/** Image type. */
public enum DockerImageType {
SINGER("singer"),

CUSTOM("custom"),

AIRBYTE("airbyte");
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,7 @@
import java.util.List;
import java.util.Objects;

/** The selected streams of a singer or airbyte connector. */
/** The selected streams of an airbyte connector. */
@JsonDeserialize(as = DockerStreamsInput.class)
public class DockerStreamsInput implements TaskInput {

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,4 +3,4 @@
/**
* Image type.
*/
export type DockerImageType = 'singer' | 'custom' | 'airbyte';
export type DockerImageType = 'custom' | 'airbyte';
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
import type { DockerStreams } from './dockerStreams';

/**
* The selected streams of a singer or airbyte connector.
* The selected streams of an airbyte connector.
*/
export type DockerStreamsInput = {
streams: Array<DockerStreams>;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2055,7 +2055,7 @@ export function createIngestionClient({
},

/**
* Triggers a stream-listing request for a source. Triggering stream-listing requests only works with sources with `type: docker` and `imageType: singer`.
* Triggers a stream-listing request for a source. Triggering stream-listing requests only works with sources with `type: docker` and `imageType: airbyte`.
*
* Required API Key ACLs:
* - addObject
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1142,7 +1142,7 @@ public class IngestionClient(
}

/**
* Triggers a stream-listing request for a source. Triggering stream-listing requests only works with sources with `type: docker` and `imageType: singer`.
* Triggers a stream-listing request for a source. Triggering stream-listing requests only works with sources with `type: docker` and `imageType: airbyte`.
*
* Required API Key ACLs:
* - addObject
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,9 +9,6 @@ import kotlinx.serialization.*
@Serializable
public enum class DockerImageType(public val value: kotlin.String) {

@SerialName(value = "singer")
Singer("singer"),

@SerialName(value = "custom")
Custom("custom"),

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ import kotlinx.serialization.*
import kotlinx.serialization.json.*

/**
* The selected streams of a singer or airbyte connector.
* The selected streams of an airbyte connector.
*
* @param streams
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2127,7 +2127,7 @@ public function searchTransformations($transformationSearch, $requestOptions = [
}

/**
* Triggers a stream-listing request for a source. Triggering stream-listing requests only works with sources with `type: docker` and `imageType: singer`.
* Triggers a stream-listing request for a source. Triggering stream-listing requests only works with sources with `type: docker` and `imageType: airbyte`.
*
* Required API Key ACLs:
* - addObject
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,8 +16,6 @@ class DockerImageType
/**
* Possible values of this enum.
*/
public const SINGER = 'singer';

public const CUSTOM = 'custom';

public const AIRBYTE = 'airbyte';
Expand All @@ -30,7 +28,6 @@ class DockerImageType
public static function getAllowableEnumValues()
{
return [
self::SINGER,
self::CUSTOM,
self::AIRBYTE,
];
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@
*
* @category Class
*
* @description The selected streams of a singer or airbyte connector.
* @description The selected streams of an airbyte connector.
*/
class DockerStreamsInput extends AbstractModel implements ModelInterface, \ArrayAccess, \JsonSerializable
{
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4125,7 +4125,7 @@ async def trigger_docker_source_discover_with_http_info(
request_options: Optional[Union[dict, RequestOptions]] = None,
) -> ApiResponse[str]:
"""
Triggers a stream-listing request for a source. Triggering stream-listing requests only works with sources with `type: docker` and `imageType: singer`.
Triggers a stream-listing request for a source. Triggering stream-listing requests only works with sources with `type: docker` and `imageType: airbyte`.
Required API Key ACLs:
- addObject
Expand Down Expand Up @@ -4167,7 +4167,7 @@ async def trigger_docker_source_discover(
request_options: Optional[Union[dict, RequestOptions]] = None,
) -> WatchResponse:
"""
Triggers a stream-listing request for a source. Triggering stream-listing requests only works with sources with `type: docker` and `imageType: singer`.
Triggers a stream-listing request for a source. Triggering stream-listing requests only works with sources with `type: docker` and `imageType: airbyte`.
Required API Key ACLs:
- addObject
Expand Down Expand Up @@ -8900,7 +8900,7 @@ def trigger_docker_source_discover_with_http_info(
request_options: Optional[Union[dict, RequestOptions]] = None,
) -> ApiResponse[str]:
"""
Triggers a stream-listing request for a source. Triggering stream-listing requests only works with sources with `type: docker` and `imageType: singer`.
Triggers a stream-listing request for a source. Triggering stream-listing requests only works with sources with `type: docker` and `imageType: airbyte`.
Required API Key ACLs:
- addObject
Expand Down Expand Up @@ -8942,7 +8942,7 @@ def trigger_docker_source_discover(
request_options: Optional[Union[dict, RequestOptions]] = None,
) -> WatchResponse:
"""
Triggers a stream-listing request for a source. Triggering stream-listing requests only works with sources with `type: docker` and `imageType: singer`.
Triggers a stream-listing request for a source. Triggering stream-listing requests only works with sources with `type: docker` and `imageType: airbyte`.
Required API Key ACLs:
- addObject
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,8 +24,6 @@ class DockerImageType(str, Enum):
"""
allowed enum values
"""
SINGER = "singer"

CUSTOM = "custom"

AIRBYTE = "airbyte"
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ def _alias_generator(name: str) -> str:

class DockerStreamsInput(BaseModel):
"""
The selected streams of a singer or airbyte connector.
The selected streams of an airbyte connector.
"""

streams: List[DockerStreams]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2616,7 +2616,7 @@ def search_transformations(transformation_search, request_options = {})
@api_client.deserialize(response.body, request_options[:debug_return_type] || "Array<Ingestion::Transformation>")
end

# Triggers a stream-listing request for a source. Triggering stream-listing requests only works with sources with `type: docker` and `imageType: singer`.
# Triggers a stream-listing request for a source. Triggering stream-listing requests only works with sources with `type: docker` and `imageType: airbyte`.
#
# Required API Key ACLs:
# - addObject
Expand Down Expand Up @@ -2651,7 +2651,7 @@ def trigger_docker_source_discover_with_http_info(source_id, request_options = {
@api_client.call_api(:POST, path, new_options)
end

# Triggers a stream-listing request for a source. Triggering stream-listing requests only works with sources with `type: docker` and `imageType: singer`.
# Triggers a stream-listing request for a source. Triggering stream-listing requests only works with sources with `type: docker` and `imageType: airbyte`.
#
# Required API Key ACLs:
# - addObject
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,12 +6,11 @@
module Algolia
module Ingestion
class DockerImageType
SINGER = "singer".freeze
CUSTOM = "custom".freeze
AIRBYTE = "airbyte".freeze

def self.all_vars
@all_vars ||= [SINGER, CUSTOM, AIRBYTE].freeze
@all_vars ||= [CUSTOM, AIRBYTE].freeze
end

# Builds the enum from string
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@

module Algolia
module Ingestion
# The selected streams of a singer or airbyte connector.
# The selected streams of an airbyte connector.
class DockerStreamsInput
attr_accessor :streams

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1429,7 +1429,7 @@ class IngestionClient(
}

/** Triggers a stream-listing request for a source. Triggering stream-listing requests only works with sources with
* `type: docker` and `imageType: singer`.
* `type: docker` and `imageType: airbyte`.
*
* Required API Key ACLs:
* - addObject
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,16 +26,13 @@ sealed trait DockerImageType
/** Image type.
*/
object DockerImageType {
case object Singer extends DockerImageType {
override def toString = "singer"
}
case object Custom extends DockerImageType {
override def toString = "custom"
}
case object Airbyte extends DockerImageType {
override def toString = "airbyte"
}
val values: Seq[DockerImageType] = Seq(Singer, Custom, Airbyte)
val values: Seq[DockerImageType] = Seq(Custom, Airbyte)

def withName(name: String): DockerImageType = DockerImageType.values
.find(_.toString == name)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@
*/
package algoliasearch.ingestion

/** The selected streams of a singer or airbyte connector.
/** The selected streams of an airbyte connector.
*/
case class DockerStreamsInput(
streams: Seq[DockerStreams]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2988,7 +2988,7 @@ open class IngestionClient {
}

// Triggers a stream-listing request for a source. Triggering stream-listing requests only works with sources with
// `type: docker` and `imageType: singer`.
// `type: docker` and `imageType: airbyte`.
// Required API Key ACLs:
// - addObject
// - deleteIndex
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@ import Foundation

/// Image type.
public enum DockerImageType: String, Codable, CaseIterable {
case singer
case custom
case airbyte
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import Foundation
import Core
#endif

/// The selected streams of a singer or airbyte connector.
/// The selected streams of an airbyte connector.
public struct DockerStreamsInput: Codable, JSONEncodable {
public var streams: [DockerStreams]

Expand Down
Loading

0 comments on commit a5b32f6

Please sign in to comment.