| -- returning updated values and old values by using a sub-expression | |
| update orders | |
| set type = 'delivery' | |
| where id = 3767 | |
| returning id, type, ( | |
| select type from orders where id = 3767 | |
| ) as old_type; |
| /* | |
| Summary | |
| As expected, the time increase to loop an array is linear. | |
| If we consider anything under 1ms as unnoticable then everything up to around 1 mil is realtively safe | |
| depending on the work that you're doing. | |
| The run times of 100 mil and larger have a lot of variance because of the low iteration counts so the overall | |
| runtime is unreliable (i.e. too much of the run is taken up by allocating the array), but their runtimes |
Grand Central is the messaging service that will distribute information between the applications.
The central concept revolves around Topics and Channels to support pubsub Event distribution.
Publishers POST an event to a topic.
| package main | |
| import ( | |
| "fmt" | |
| "log" | |
| "math/rand" | |
| "sync" | |
| "time" | |
| ) |
| // We would make a seaprate {service}/data package. The reason to separate out the data module is to utilize | |
| // private methods to not expose lower-level resources | |
| // We would no longer need the big global Databinder and instead replace it with a smaller Binder for each resource | |
| // The benifit of switching off of the interface is we can then leverage private attributes like the clients | |
| // The Binders can expose sqlx components like tx in private functions | |
| // The binder methods would be raw management of the resources with no side-effects (i.e. creating a guest | |
| // would not create a guest token) | |
| type GuestBinder struct { |
| package main | |
| import ( | |
| "context" | |
| "log" | |
| "net/http" | |
| "os" | |
| "os/signal" | |
| "time" | |
| ) |
| #!/usr/bin/env bash | |
| TIMEOUT=5 | |
| until psql -h $PG_HOST -U $PG_USER -d $PG_DATABASE -c "select 1" > /dev/null 2>&1 || [ $TIMEOUT -eq 0 ]; do | |
| echo "Waiting for postgres server, $((TIMEOUT--)) remaining attempts..." | |
| sleep 1 | |
| done |
| target, _ := url.Parse(h.ProxyHost) | |
| proxy := httputil.NewSingleHostReverseProxy(target) | |
| proxy.ServeHTTP(w, r) |