zilla examplesのダウンロード - zilla examplesソースコードのダウンロード

zilla examples

その他のソースコード

1.0.0

ダウンロード

Zilla の例

このリポジトリには、主要な Zilla 機能をデモンストレーションするために個別に使用できるサンプルフォルダーのコレクションが含まれています。これが Zilla を使用する最初のステップである場合は、クイックスタートを試すことをお勧めします。

前提条件

Docker または Helm と Kubernetes がインストールされた環境が必要です。例を操作するその他の方法については、Postman コレクションを確認してください。

はじめる

startup.shスクリプトは、各例に必要なコンポーネントのセットアップと破棄を支援することを目的としています。これを使用するのが、各例を操作する最も簡単な方法です。

startup.shスクリプトを使用して、いずれかの例をインストールして実行します。

./startup.sh -m example.name

独自の Kafka ホストとポート、またはサンプルをダウンロードする作業ディレクトリを指定できます。既存のサンプルディレクトリは上書きされませnot 。

./startup.sh -m -k kafka:9092 -d /tmp example.name

あるいは、リポジトリのクローンを作成せずに、このスクリプトを同じ方法で実行することもできます。

wget -qO- https://raw.githubusercontent.com/aklivity/zilla-examples/main/startup.sh | sh -s -- -m example.name

使用法

./startup.sh --help

 Usage: startup.sh [-hm][-k KAFKA_BOOTSTRAP_SERVER][-d WORKDIR][-v ZILLA_VERSION][-e EX_VERSION][--no-kafka-init][--redpanda] example.name

Operand:
    example.name          The name of the example to use                                 [default: quickstart][string]

Options:
    -d | --workdir        Sets the directory used to download and run the example                             [string]
    -e | --ex-version     Sets the examples version to download                              [default: latest][string]
    -h | --use-helm       Use the helm install, if available, instead of compose                             [boolean]
    -k | --kafka-server   Sets the Kafka Boostrap Server to use                                               [string]
    -m | --use-main       Download the head of the main branch                                               [boolean]
    -v | --zilla-version  Sets the zilla version to use                                      [default: latest][string]
         --auto-teardown  Executes the teardown script immediately after setup                               [boolean]
         --no-kafka-init  The script wont try to bootstrap the kafka broker                                  [boolean]
         --redpanda       Makes the included kafka broker and scripts use Redpanda                           [boolean]
         --help           Print help                                                                         [boolean]

例

名前	説明
asyncapi.mqtt.proxy	検証された MQTT パブリッシュメッセージを転送し、MQTT ブローカーにサブスクライブするプロキシを作成します。
asyncapi.mqtt.kafka.proxy	MQTT パブリッシュメッセージを Kafka に転送し、サブスクライブされたすべての MQTT クライアントにブロードキャストします。
asyncapi.http.kafka.proxy	別々の Kafka トピック上で HTTP リクエストとレスポンスを関連付けます
asyncapi.sse.proxy	SSE サーバーによって配信されるプロキシ検証済みメッセージ
asyncapi.sse.kafka.proxy	SSE 経由で Kafka トピックにパブリッシュされたメッセージをストリーム配信します
tcp.echo	TCPサーバーに送信されたバイトをエコーします。
tcp.reflect	TCP サーバーに送信されたバイトをエコーし、すべての TCP クライアントにブロードキャストします。
tls.echo	TLS サーバーに送信された暗号化されたバイトをエコーします。
tls.reflect	TLS サーバーに送信された暗号化バイトをエコーし、すべての TLS クライアントにブロードキャストします。
http.ファイルシステム	ローカルファイルシステム上のディレクトリからファイルを提供します
http.filesystem.config.server	ローカルファイルシステム上のディレクトリからファイルを提供し、http サーバーから構成を取得します
http.エコー	HTTP クライアントから HTTP サーバーに送信されたリクエストをエコーします。
http.echo.jwt	JWT認可されたHTTPクライアントからHTTPサーバーに送信されたエコーリクエスト
http.プロキシ	HTTPクライアントからHTTPサーバーに送信されるプロキシリクエスト
http.proxy.schema.inline	スキーマ強制を使用して HTTP クライアントから HTTP サーバーに送信されるプロキシリクエスト
http.kafka.sync	別々の Kafka トピック上で HTTP リクエストとレスポンスを関連付けます
http.kafka.async	HTTP リクエストとレスポンスを個別の Kafka トピック上で非同期的に関連付けます
http.kafka.キャッシュ	Kafka トピックからのキャッシュされた応答を提供し、更新されたときに検出します
http.kafka.oneway	Kafka トピックにメッセージをファイアアンドフォーゲットで送信します
http.kafka.crud	ログ圧縮された Kafka トピックがテーブルとして機能する CRUD 操作を使用して REST API を公開します
http.kafka.sasl.scram	SASL/SCRAM が有効な Kafka にメッセージを送信します
http.kafka.karapace	Kafka トピックの生成およびフェッチ中にメッセージを検証する
http.redpanda.sasl.scram	SASL/SCRAM が有効になっている Redpanda クラスターにメッセージを送信します
kubernetes.prometheus.autoscale	Prometheus を使用したカスタムメトリックに基づく Kubernetes の水平ポッド自動スケーリング機能のデモ
grpc.echo	gRPC クライアントから gRPC サーバーに送信されたメッセージをエコーします。
grpc.kafka.echo	gRPC クライアントから gRPC 経由で Kafka トピックに送信されたメッセージをエコーします。
grpc.kafka.fanout	Kafka トピックにパブリッシュされたメッセージをストリームし、ログ圧縮に基づいて結合を適用します。
grpc.kafka.proxy	個別の Kafka トピック上で gRPC リクエストとレスポンスを関連付けます
grpc.プロキシ	gRPC クライアントから gRPC サーバーに送信される gRPC リクエストと応答をプロキシします。
amqp.reflect	AMQP サーバーにパブリッシュされたメッセージをエコーし、受信側のすべての AMQP クライアントにブロードキャストします。
mqtt.kafka.broker	MQTT パブリッシュメッセージを Kafka に転送し、サブスクライブされたすべての MQTT クライアントにブロードキャストします。
mqtt.kafka.broker.jwt	MQTT パブリッシュメッセージを Kafka に転送し、サブスクライブされたすべての JWT 承認 MQTT クライアントにブロードキャストします。
クイックスタート	すべてのプロトコル (HTTP、SSE、gRPC、MQTT) のエンドポイントを開始します。
sse.kafka.fanout	Kafka トピックにパブリッシュされたメッセージをストリームし、ログ圧縮に基づいて結合を適用します。
sse.proxy.jwt	SSE サーバーによって配信されるメッセージをプロキシし、ストリーミングセキュリティ制約を強制します
ws.エコー	WebSocket サーバーに送信されたメッセージをエコーします。
ws.reflect	WebSocket サーバーに送信されたメッセージをエコーし、すべての WebSocket クライアントにブロードキャストします。