Skip to content

Commit

Permalink
deploy: 6978596
Browse files Browse the repository at this point in the history
  • Loading branch information
whynowy committed Jan 6, 2025
1 parent 49ef133 commit a5d6afb
Show file tree
Hide file tree
Showing 6 changed files with 125 additions and 125 deletions.
2 changes: 1 addition & 1 deletion eventsources/generic/index.html
Original file line number Diff line number Diff line change
Expand Up @@ -2156,7 +2156,7 @@ <h2 id="contract">Contract<a class="headerlink" href="#contract" title="Permanen
<span class="w"> </span><span class="p">}</span>
</code></pre></div>

<p>The proto file is available <a href="https://github.com/argoproj/argo-events/blob/master/eventsources/sources/generic/generic.proto">here</a>.</p>
<p>The proto file is available <a href="https://github.com/argoproj/argo-events/blob/master/pkg/eventsources/sources/generic/generic.proto">here</a>.</p>
<h2 id="architecture">Architecture<a class="headerlink" href="#architecture" title="Permanent link">&para;</a></h2>
<p><img alt="arch" src="../../assets/generic-eventsource.png" /></p>
<p>Consider a generic eventsource.</p>
Expand Down
8 changes: 4 additions & 4 deletions eventsources/setup/amqp/index.html
Original file line number Diff line number Diff line change
Expand Up @@ -2220,11 +2220,11 @@ <h2 id="setup">Setup<a class="headerlink" href="#setup" title="Permanent link">&
<li>
<p>Open a python REPL and run following code to publish a message on <code>exchange</code> called <code>test</code>.</p>
<div class="codehilite"><pre><span></span><code><span class="kn">import</span><span class="w"> </span><span class="nn">pika</span>
<span class="n">connection</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="n">pika</span><span class="o">.</span><span class="n">BlockingConnection</span><span class="p">(</span><span class="n">pika</span><span class="o">.</span><span class="n">ConnectionParameters</span><span class="p">(</span><span class="s1">&#39;localhost&#39;</span><span class="p">))</span>
<span class="n">channel</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="n">connection</span><span class="o">.</span><span class="n">channel</span><span class="p">()</span>
<span class="n">connection</span> <span class="o">=</span> <span class="n">pika</span><span class="o">.</span><span class="n">BlockingConnection</span><span class="p">(</span><span class="n">pika</span><span class="o">.</span><span class="n">ConnectionParameters</span><span class="p">(</span><span class="s1">&#39;localhost&#39;</span><span class="p">))</span>
<span class="n">channel</span> <span class="o">=</span> <span class="n">connection</span><span class="o">.</span><span class="n">channel</span><span class="p">()</span>
<span class="n">channel</span><span class="o">.</span><span class="n">basic_publish</span><span class="p">(</span><span class="n">exchange</span><span class="o">=</span><span class="s1">&#39;test&#39;</span><span class="p">,</span>
<span class="w"> </span><span class="n">routing_key</span><span class="o">=</span><span class="s1">&#39;hello&#39;</span><span class="p">,</span>
<span class="w"> </span><span class="n">body</span><span class="o">=</span><span class="s1">&#39;{&quot;message&quot;: &quot;hello&quot;}&#39;</span><span class="p">)</span>
<span class="n">routing_key</span><span class="o">=</span><span class="s1">&#39;hello&#39;</span><span class="p">,</span>
<span class="n">body</span><span class="o">=</span><span class="s1">&#39;{&quot;message&quot;: &quot;hello&quot;}&#39;</span><span class="p">)</span>
</code></pre></div>

</li>
Expand Down
14 changes: 7 additions & 7 deletions eventsources/setup/azure-service-bus/index.html
Original file line number Diff line number Diff line change
Expand Up @@ -2177,13 +2177,13 @@ <h2 id="setup">Setup<a class="headerlink" href="#setup" title="Permanent link">&
<p>Before running the code, make sure you have the <code>SERVICE_BUS_CONNECTION_STRING</code> environment variable set.
This is the connection string for your Azure Service Bus.</p>
<div class="codehilite"><pre><span></span><code><span class="kn">import</span><span class="w"> </span><span class="nn">os</span><span class="o">,</span><span class="w"> </span><span class="nn">json</span>
<span class="kn">from</span><span class="w"> </span><span class="nn">azure.servicebus</span><span class="w"> </span><span class="kn">import</span><span class="w"> </span><span class="n">ServiceBusClient</span><span class="p">,</span><span class="w"> </span><span class="n">ServiceBusMessage</span>
<span class="n">servicebus_client</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="n">ServiceBusClient</span><span class="o">.</span><span class="n">from_connection_string</span><span class="p">(</span><span class="n">conn_str</span><span class="o">=</span><span class="n">os</span><span class="o">.</span><span class="n">environ</span><span class="p">[</span><span class="s1">&#39;SERVICE_BUS_CONNECTION_STRING&#39;</span><span class="p">])</span>
<span class="k">with</span><span class="w"> </span><span class="n">servicebus_client</span><span class="p">:</span>
<span class="w"> </span><span class="n">sender</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="n">servicebus_client</span><span class="o">.</span><span class="n">get_queue_sender</span><span class="p">(</span><span class="n">queue_name</span><span class="o">=</span><span class="s2">&quot;test&quot;</span><span class="p">)</span>
<span class="w"> </span><span class="k">with</span><span class="w"> </span><span class="n">sender</span><span class="p">:</span>
<span class="w"> </span><span class="n">message</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="n">ServiceBusMessage</span><span class="p">(</span><span class="s1">&#39;{&quot;hello&quot;: &quot;world&quot;}&#39;</span><span class="p">)</span>
<span class="w"> </span><span class="n">sender</span><span class="o">.</span><span class="n">send_messages</span><span class="p">(</span><span class="n">message</span><span class="p">)</span>
<span class="kn">from</span><span class="w"> </span><span class="nn">azure.servicebus</span><span class="w"> </span><span class="kn">import</span> <span class="n">ServiceBusClient</span><span class="p">,</span> <span class="n">ServiceBusMessage</span>
<span class="n">servicebus_client</span> <span class="o">=</span> <span class="n">ServiceBusClient</span><span class="o">.</span><span class="n">from_connection_string</span><span class="p">(</span><span class="n">conn_str</span><span class="o">=</span><span class="n">os</span><span class="o">.</span><span class="n">environ</span><span class="p">[</span><span class="s1">&#39;SERVICE_BUS_CONNECTION_STRING&#39;</span><span class="p">])</span>
<span class="k">with</span> <span class="n">servicebus_client</span><span class="p">:</span>
<span class="n">sender</span> <span class="o">=</span> <span class="n">servicebus_client</span><span class="o">.</span><span class="n">get_queue_sender</span><span class="p">(</span><span class="n">queue_name</span><span class="o">=</span><span class="s2">&quot;test&quot;</span><span class="p">)</span>
<span class="k">with</span> <span class="n">sender</span><span class="p">:</span>
<span class="n">message</span> <span class="o">=</span> <span class="n">ServiceBusMessage</span><span class="p">(</span><span class="s1">&#39;{&quot;hello&quot;: &quot;world&quot;}&#39;</span><span class="p">)</span>
<span class="n">sender</span><span class="o">.</span><span class="n">send_messages</span><span class="p">(</span><span class="n">message</span><span class="p">)</span>
</code></pre></div>

</li>
Expand Down
48 changes: 24 additions & 24 deletions sensors/triggers/http-trigger/index.html
Original file line number Diff line number Diff line change
Expand Up @@ -2199,28 +2199,28 @@ <h2 id="rest-api-calls">REST API Calls<a class="headerlink" href="#rest-api-call
<ol>
<li>
<p>The HTTP server simply prints the request body as follows.</p>
<div class="codehilite"><pre><span></span><code><span class="n">package</span><span class="w"> </span><span class="n">main</span>
<div class="codehilite"><pre><span></span><code><span class="n">package</span> <span class="n">main</span>

<span class="kn">import</span><span class="w"> </span><span class="p">(</span>
<span class="w"> </span><span class="s2">&quot;fmt&quot;</span>
<span class="w"> </span><span class="s2">&quot;io&quot;</span>
<span class="w"> </span><span class="s2">&quot;net/http&quot;</span>
<span class="s2">&quot;fmt&quot;</span>
<span class="s2">&quot;io&quot;</span>
<span class="s2">&quot;net/http&quot;</span>
<span class="p">)</span>

<span class="n">func</span><span class="w"> </span><span class="n">hello</span><span class="p">(</span><span class="n">w</span><span class="w"> </span><span class="n">http</span><span class="o">.</span><span class="n">ResponseWriter</span><span class="p">,</span><span class="w"> </span><span class="n">req</span><span class="w"> </span><span class="o">*</span><span class="n">http</span><span class="o">.</span><span class="n">Request</span><span class="p">)</span><span class="w"> </span><span class="p">{</span>
<span class="w"> </span><span class="n">body</span><span class="p">,</span><span class="w"> </span><span class="n">err</span><span class="w"> </span><span class="o">:=</span><span class="w"> </span><span class="n">io</span><span class="o">.</span><span class="n">ReadAll</span><span class="p">(</span><span class="n">req</span><span class="o">.</span><span class="n">Body</span><span class="p">)</span>
<span class="w"> </span><span class="k">if</span><span class="w"> </span><span class="n">err</span><span class="w"> </span><span class="o">!=</span><span class="w"> </span><span class="n">nil</span><span class="w"> </span><span class="p">{</span>
<span class="w"> </span><span class="n">fmt</span><span class="o">.</span><span class="n">Printf</span><span class="p">(</span><span class="s2">&quot;%+v</span><span class="se">\n</span><span class="s2">&quot;</span><span class="p">,</span><span class="w"> </span><span class="n">err</span><span class="p">)</span>
<span class="w"> </span><span class="k">return</span>
<span class="w"> </span><span class="p">}</span>
<span class="w"> </span><span class="n">fmt</span><span class="o">.</span><span class="n">Println</span><span class="p">(</span><span class="n">string</span><span class="p">(</span><span class="n">body</span><span class="p">))</span>
<span class="w"> </span><span class="n">fmt</span><span class="o">.</span><span class="n">Fprintf</span><span class="p">(</span><span class="n">w</span><span class="p">,</span><span class="w"> </span><span class="s2">&quot;hello</span><span class="se">\n</span><span class="s2">&quot;</span><span class="p">)</span>
<span class="n">func</span> <span class="n">hello</span><span class="p">(</span><span class="n">w</span> <span class="n">http</span><span class="o">.</span><span class="n">ResponseWriter</span><span class="p">,</span> <span class="n">req</span> <span class="o">*</span><span class="n">http</span><span class="o">.</span><span class="n">Request</span><span class="p">)</span> <span class="p">{</span>
<span class="n">body</span><span class="p">,</span> <span class="n">err</span> <span class="o">:=</span> <span class="n">io</span><span class="o">.</span><span class="n">ReadAll</span><span class="p">(</span><span class="n">req</span><span class="o">.</span><span class="n">Body</span><span class="p">)</span>
<span class="k">if</span> <span class="n">err</span> <span class="o">!=</span> <span class="n">nil</span> <span class="p">{</span>
<span class="n">fmt</span><span class="o">.</span><span class="n">Printf</span><span class="p">(</span><span class="s2">&quot;%+v</span><span class="se">\n</span><span class="s2">&quot;</span><span class="p">,</span> <span class="n">err</span><span class="p">)</span>
<span class="k">return</span>
<span class="p">}</span>
<span class="n">fmt</span><span class="o">.</span><span class="n">Println</span><span class="p">(</span><span class="n">string</span><span class="p">(</span><span class="n">body</span><span class="p">))</span>
<span class="n">fmt</span><span class="o">.</span><span class="n">Fprintf</span><span class="p">(</span><span class="n">w</span><span class="p">,</span> <span class="s2">&quot;hello</span><span class="se">\n</span><span class="s2">&quot;</span><span class="p">)</span>
<span class="p">}</span>

<span class="n">func</span><span class="w"> </span><span class="n">main</span><span class="p">()</span><span class="w"> </span><span class="p">{</span>
<span class="w"> </span><span class="n">http</span><span class="o">.</span><span class="n">HandleFunc</span><span class="p">(</span><span class="s2">&quot;/hello&quot;</span><span class="p">,</span><span class="w"> </span><span class="n">hello</span><span class="p">)</span>
<span class="w"> </span><span class="n">fmt</span><span class="o">.</span><span class="n">Println</span><span class="p">(</span><span class="s2">&quot;server is listening on 8090&quot;</span><span class="p">)</span>
<span class="w"> </span><span class="n">http</span><span class="o">.</span><span class="n">ListenAndServe</span><span class="p">(</span><span class="s2">&quot;:8090&quot;</span><span class="p">,</span><span class="w"> </span><span class="n">nil</span><span class="p">)</span>
<span class="n">func</span> <span class="n">main</span><span class="p">()</span> <span class="p">{</span>
<span class="n">http</span><span class="o">.</span><span class="n">HandleFunc</span><span class="p">(</span><span class="s2">&quot;/hello&quot;</span><span class="p">,</span> <span class="n">hello</span><span class="p">)</span>
<span class="n">fmt</span><span class="o">.</span><span class="n">Println</span><span class="p">(</span><span class="s2">&quot;server is listening on 8090&quot;</span><span class="p">)</span>
<span class="n">http</span><span class="o">.</span><span class="n">ListenAndServe</span><span class="p">(</span><span class="s2">&quot;:8090&quot;</span><span class="p">,</span> <span class="n">nil</span><span class="p">)</span>
<span class="p">}</span>
</code></pre></div>

Expand Down Expand Up @@ -2338,16 +2338,16 @@ <h2 id="openfaas">OpenFaaS<a class="headerlink" href="#openfaas" title="Permanen
<li>
<p>Let's create a basic function. You can follow the <a href="https://blog.alexellis.io/serverless-golang-with-openfaas/">steps</a>.
to set up the function.</p>
<div class="codehilite"><pre><span></span><code><span class="w"> </span><span class="n">package</span><span class="w"> </span><span class="n">function</span>
<div class="codehilite"><pre><span></span><code> <span class="n">package</span> <span class="n">function</span>

<span class="w"> </span><span class="kn">import</span><span class="w"> </span><span class="p">(</span>
<span class="w"> </span><span class="s2">&quot;fmt&quot;</span>
<span class="w"> </span><span class="p">)</span>
<span class="kn">import</span><span class="w"> </span><span class="p">(</span>
<span class="s2">&quot;fmt&quot;</span>
<span class="p">)</span>

<span class="w"> </span><span class="o">//</span><span class="w"> </span><span class="n">Handle</span><span class="w"> </span><span class="n">a</span><span class="w"> </span><span class="n">serverless</span><span class="w"> </span><span class="n">request</span>
<span class="w"> </span><span class="n">func</span><span class="w"> </span><span class="n">Handle</span><span class="p">(</span><span class="n">req</span><span class="w"> </span><span class="p">[]</span><span class="n">byte</span><span class="p">)</span><span class="w"> </span><span class="n">string</span><span class="w"> </span><span class="p">{</span>
<span class="w"> </span><span class="k">return</span><span class="w"> </span><span class="n">fmt</span><span class="o">.</span><span class="n">Sprintf</span><span class="p">(</span><span class="s2">&quot;Hello, Go. You said: </span><span class="si">%s</span><span class="s2">&quot;</span><span class="p">,</span><span class="w"> </span><span class="n">string</span><span class="p">(</span><span class="n">req</span><span class="p">))</span>
<span class="w"> </span><span class="p">}</span>
<span class="o">//</span> <span class="n">Handle</span> <span class="n">a</span> <span class="n">serverless</span> <span class="n">request</span>
<span class="n">func</span> <span class="n">Handle</span><span class="p">(</span><span class="n">req</span> <span class="p">[]</span><span class="n">byte</span><span class="p">)</span> <span class="n">string</span> <span class="p">{</span>
<span class="k">return</span> <span class="n">fmt</span><span class="o">.</span><span class="n">Sprintf</span><span class="p">(</span><span class="s2">&quot;Hello, Go. You said: </span><span class="si">%s</span><span class="s2">&quot;</span><span class="p">,</span> <span class="n">string</span><span class="p">(</span><span class="n">req</span><span class="p">))</span>
<span class="p">}</span>
</code></pre></div>

</li>
Expand Down
Loading

0 comments on commit a5d6afb

Please sign in to comment.