Skip to content

Commit

Permalink
2540 - Additional conditioning and single sourcing for Cloud RPCN lau…
Browse files Browse the repository at this point in the history
…nch (#35)

Co-authored-by: JakeSCahill <[email protected]>
  • Loading branch information
asimms41 and JakeSCahill authored Sep 9, 2024
1 parent a7c2aad commit 775dff3
Show file tree
Hide file tree
Showing 43 changed files with 1,689 additions and 966 deletions.
3 changes: 1 addition & 2 deletions local-antora-playbook.yml
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,6 @@ urls:
html_extension_style: indexify
content:
sources:
# Fetches autogenerated docs.
- url: .
branches: HEAD
- url: https://github.com/redpanda-data/documentation
Expand All @@ -32,8 +31,8 @@ asciidoc:
- '@redpanda-data/docs-extensions-and-macros/asciidoc-extensions/add-line-numbers-highlights'
antora:
extensions:
- require: '@redpanda-data/docs-extensions-and-macros/extensions/generate-rp-connect-info'
- require: '@redpanda-data/docs-extensions-and-macros/extensions/generate-rp-connect-categories'
- require: '@redpanda-data/docs-extensions-and-macros/extensions/generate-rp-connect-info'
- require: '@redpanda-data/docs-extensions-and-macros/extensions/unpublish-pages'
- require: '@redpanda-data/docs-extensions-and-macros/extensions/unlisted-pages'
- require: '@redpanda-data/docs-extensions-and-macros/extensions/add-global-attributes'
Expand Down
7 changes: 6 additions & 1 deletion modules/components/pages/about.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,12 @@ These are the main components within Redpanda Connect and they provide the major

== Observability components

There are also the observability components xref:components:http/about.adoc[http], xref:components:logger/about.adoc[logger], xref:components:metrics/about.adoc[metrics], and xref:components:tracers/about.adoc[tracing], which allow you to specify how Redpanda Connect exposes observability data:
ifndef::env-cloud[]
There are also the observability components: xref:components:http/about.adoc[http], xref:components:logger/about.adoc[logger], xref:components:metrics/about.adoc[metrics], and xref:components:tracers/about.adoc[tracing], which allow you to specify how Redpanda Connect exposes observability data.
endif::[]
ifdef::env-cloud[]
There are also the observability components: xref:components:logger/about.adoc[logger], xref:components:metrics/about.adoc[metrics], and xref:components:tracers/about.adoc[tracing], which allow you to specify how Redpanda Connect exposes observability data.
endif::[]

[source,yaml]
----
Expand Down
2 changes: 2 additions & 0 deletions modules/components/pages/caches/about.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -32,6 +32,8 @@ pipeline:

For the simple case where you wish to store messages in a cache as an output destination for your pipeline check out the xref:components:outputs/cache.adoc[`cache` output]. To see examples of more advanced uses of caches such as hydration and deduplication check out the xref:components:processors/cache.adoc[`cache` processor].

ifndef::env-cloud[]
You can find out more about resources xref:configuration:resources.adoc[in this document.]
endif::[]

// end::single-source[]
4 changes: 2 additions & 2 deletions modules/components/pages/caches/gcp_cloud_storage.adoc
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
= gcp_cloud_storage
// tag::single-source[]
:type: cache
:status: beta

Expand Down Expand Up @@ -37,5 +38,4 @@ Optional field to explicitly set the Content-Type.

*Type*: `string`



// end::single-source[]
5 changes: 5 additions & 0 deletions modules/components/pages/inputs/about.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,12 @@ input:
root.link_count = this.links.length()
----

ifndef::env-cloud[]
Some inputs have a logical end, for example a xref:components:inputs/csv.adoc[`csv` input] ends once the last row is consumed, when this happens the input gracefully terminates and Redpanda Connect will shut itself down once all messages have been processed fully.
endif::[]
ifdef::env-cloud[]
Some inputs have a logical end, when this happens the input gracefully terminates and Redpanda Connect will shut itself down once all messages have been processed fully.
endif::[]

It's also possible to specify a logical end for an input that otherwise doesn't have one with the xref:components:inputs/read_until.adoc[`read_until` input], which checks a condition against each consumed message in order to determine whether it should be the last.

Expand Down
14 changes: 12 additions & 2 deletions modules/components/pages/inputs/azure_blob_storage.adoc
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
= azure_blob_storage
// tag::single-source[]
:type: input
:status: beta
:categories: ["Services","Azure"]
Expand All @@ -11,8 +12,9 @@ component_type_dropdown::[]

Downloads objects within an Azure Blob Storage container, optionally filtered by a prefix.

ifndef::env-cloud[]
Introduced in version 3.36.0.

endif::[]

[tabs]
======
Expand Down Expand Up @@ -158,7 +160,10 @@ The xref:components:scanners/about.adoc[scanner] by which the stream of bytes co
*Type*: `scanner`

*Default*: `{"to_the_end":{}}`

ifndef::env-cloud[]
Requires version 4.25.0 or newer
endif::[]

=== `delete_objects`

Expand All @@ -180,7 +185,9 @@ This requires setting up https://learn.microsoft.com/en-gb/azure/event-grid/even

*Type*: `input`

ifndef::env-cloud[]
Requires version 4.27.0 or newer
endif::[]

[tabs]
======
Expand Down Expand Up @@ -239,4 +246,7 @@ targets_input:
```
--
======
======

// end::single-source[]

6 changes: 4 additions & 2 deletions modules/components/pages/inputs/azure_cosmosdb.adoc
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
= azure_cosmosdb
// tag::single-source[]
:type: input
:status: experimental
:categories: ["Azure"]
Expand All @@ -11,8 +12,9 @@ component_type_dropdown::[]

Executes a SQL query against https://learn.microsoft.com/en-us/azure/cosmos-db/introduction[Azure CosmosDB^] and creates a batch of messages from each page of items.

ifndef::env-cloud[]
Introduced in version v4.25.0.

endif::[]

[tabs]
======
Expand Down Expand Up @@ -288,4 +290,4 @@ Additionally, instead of installing the container self-signed certificate which

Then you can access the CosmosDB UI via `http://localhost:8080/_explorer/index.html` and use `http://localhost:8080` as the CosmosDB endpoint.


// end::single-source[]
9 changes: 7 additions & 2 deletions modules/components/pages/inputs/azure_queue_storage.adoc
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
= azure_queue_storage
// tag::single-source[]
:type: input
:status: beta
:categories: ["Services","Azure"]
Expand All @@ -11,8 +12,9 @@ component_type_dropdown::[]

Dequeue objects from an Azure Storage Queue.

ifndef::env-cloud[]
Introduced in version 3.42.0.

endif::[]

[tabs]
======
Expand Down Expand Up @@ -118,7 +120,10 @@ The timeout duration until a dequeued message gets visible again, 30s by default
*Type*: `string`

*Default*: `"30s"`

ifndef::env-cloud[]
Requires version 3.45.0 or newer
endif::[]

=== `max_in_flight`

Expand All @@ -138,4 +143,4 @@ If set to `true` the queue is polled on each read request for information such a

*Default*: `false`


// end::single-source[]
8 changes: 6 additions & 2 deletions modules/components/pages/inputs/azure_table_storage.adoc
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
= azure_table_storage
// tag::single-source[]
:type: input
:status: beta
:categories: ["Services","Azure"]
Expand All @@ -11,8 +12,9 @@ component_type_dropdown::[]

Queries an Azure Storage Account Table, optionally with multiple filters.

ifndef::env-cloud[]
Introduced in version 4.10.0.

endif::[]

[tabs]
======
Expand Down Expand Up @@ -56,7 +58,9 @@ input:
======

Queries an Azure Storage Account Table, optionally with multiple filters.

== Metadata

This input adds the following metadata fields to each message:

- table_storage_name
Expand Down Expand Up @@ -155,4 +159,4 @@ Maximum number of records to return on each page.

*Default*: `1000`


// end::single-source[]
6 changes: 4 additions & 2 deletions modules/components/pages/inputs/gcp_bigquery_select.adoc
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
= gcp_bigquery_select
// tag::single-source[]
:type: input
:status: beta
:categories: ["Services","GCP"]
Expand All @@ -12,7 +13,9 @@ component_type_dropdown::[]

Executes a `SELECT` query against BigQuery and creates a message for each row received.

ifndef::env-cloud[]
Introduced in version 3.63.0.
endif::[]

```yml
# Config fields, showing default values
Expand Down Expand Up @@ -168,5 +171,4 @@ An optional suffix to append to the select query.

*Type*: `string`



// end::single-source[]
9 changes: 7 additions & 2 deletions modules/components/pages/inputs/gcp_cloud_storage.adoc
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
= gcp_cloud_storage
// tag::single-source[]
:type: input
:status: beta
:categories: ["Services","GCP"]
Expand All @@ -11,8 +12,9 @@ component_type_dropdown::[]

Downloads objects within a Google Cloud Storage bucket, optionally filtered by a prefix.

ifndef::env-cloud[]
Introduced in version 3.43.0.

endif::[]

[tabs]
======
Expand Down Expand Up @@ -98,7 +100,10 @@ The xref:components:scanners/about.adoc[scanner] by which the stream of bytes co
*Type*: `scanner`

*Default*: `{"to_the_end":{}}`

ifndef::env-cloud[]
Requires version 4.25.0 or newer
endif::[]

=== `delete_objects`

Expand All @@ -109,4 +114,4 @@ Whether to delete downloaded objects from the bucket once they are processed.

*Default*: `false`


// end::single-source[]
3 changes: 2 additions & 1 deletion modules/components/pages/inputs/gcp_pubsub.adoc
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
= gcp_pubsub
// tag::single-source[]
:type: input
:status: stable
:categories: ["Services","GCP"]
Expand Down Expand Up @@ -156,4 +157,4 @@ Defines the topic that the subscription should be vinculated to.

*Default*: `""`


// end::single-source[]
7 changes: 7 additions & 0 deletions modules/components/pages/inputs/inproc.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -18,8 +18,15 @@ input:
inproc: ""
```

ifndef::env-cloud[]
Directly connect to an output within a Redpanda Connect process by referencing it by a chosen ID. This allows you to hook up isolated streams whilst running Redpanda Connect in xref:guides:streams_mode/about.adoc[streams mode], it is NOT recommended that you connect the inputs of a stream with an output of the same stream, as feedback loops can lead to deadlocks in your message flow.

It is possible to connect multiple inputs to the same inproc ID, resulting in messages dispatching in a round-robin fashion to connected inputs. However, only one output can assume an inproc ID, and will replace existing outputs if a collision occurs.
endif::[]
ifdef::env-cloud[]
Directly connect to an output within a Redpanda Connect process by referencing it by a chosen ID.

It is possible to connect multiple inputs to the same inproc ID, resulting in messages dispatching in a round-robin fashion to connected inputs. However, only one output can assume an inproc ID, and will replace existing outputs if a collision occurs.
endif::[]

// end::single-source[]
2 changes: 2 additions & 0 deletions modules/components/pages/inputs/resource.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -57,6 +57,8 @@ input_resources:

Resources also allow you to reference a single input in multiple places, such as multiple streams mode configs, or multiple entries in a broker input. However, when a resource is referenced more than once the messages it produces are distributed across those references, so each message will only be directed to a single reference, not all of them.

ifndef::env-cloud[]
You can find out more about resources in xref:configuration:resources.adoc[].
endif::[]

// end::single-source[]
10 changes: 10 additions & 0 deletions modules/components/pages/metrics/about.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,12 @@ metrics:
flush_period: 100ms
----

ifndef::env-cloud[]
The default metrics configuration is to expose Prometheus metrics on the xref:components:http/about.adoc[service-wide HTTP endpoint] at the endpoints `/metrics` and `/stats`.
endif::[]
ifdef::env-cloud[]
Redpanda Connect automatically xref:develop:connect/configuration/monitor-connect.adoc[exports detailed metrics] for each component of your data pipeline to a Prometheus endpoint.
endif::[]

== Timings

Expand Down Expand Up @@ -101,7 +106,12 @@ The `label` label contains the unique label configured for a component emitting

=== `stream`

ifndef::env-cloud[]
The `stream` label is present in a metric series emitted from a stream config executed when Redpanda Connect is running in xref:guides:streams_mode/about.adoc[streams mode], and is populated with the stream name.
endif::[]
ifdef::env-cloud[]
The `stream` label is present in a metric series emitted from a stream config executed when Redpanda Connect is running in streams mode, and is populated with the stream name.
endif::[]

== Example

Expand Down
6 changes: 4 additions & 2 deletions modules/components/pages/outputs/azure_blob_storage.adoc
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
= azure_blob_storage
// tag::single-source[]
:type: output
:status: beta
:categories: ["Services","Azure"]
Expand All @@ -11,8 +12,9 @@ component_type_dropdown::[]

Sends message parts as objects to an Azure Blob Storage Account container. Each object is uploaded with the filename specified with the `container` field.

ifndef::env-cloud[]
Introduced in version 3.36.0.

endif::[]

[tabs]
======
Expand Down Expand Up @@ -191,4 +193,4 @@ The maximum number of messages to have in flight at a given time. Increase this

*Default*: `64`


// end::single-source[]
6 changes: 4 additions & 2 deletions modules/components/pages/outputs/azure_cosmosdb.adoc
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
= azure_cosmosdb
// tag::single-source[]
:type: output
:status: experimental
:categories: ["Azure"]
Expand All @@ -11,8 +12,9 @@ component_type_dropdown::[]

Creates or updates messages as JSON documents in https://learn.microsoft.com/en-us/azure/cosmos-db/introduction[Azure CosmosDB^].

ifndef::env-cloud[]
Introduced in version v4.25.0.

endif::[]

[tabs]
======
Expand Down Expand Up @@ -517,4 +519,4 @@ Additionally, instead of installing the container self-signed certificate which

Then you can access the CosmosDB UI via `http://localhost:8080/_explorer/index.html` and use `http://localhost:8080` as the CosmosDB endpoint.


// end::single-source[]
Loading

0 comments on commit 775dff3

Please sign in to comment.