Merge pull request #68 from w-h-a/runner

feat: runner

Makefile

@@ -7,12 +7,12 @@ style:
 	goimports -l -w ./api
 	goimports -l -w ./broker
 	goimports -l -w ./client
+	goimports -l -w ./runner
 	goimports -l -w ./runtime
 	goimports -l -w ./security
 	goimports -l -w ./server
 	goimports -l -w ./sidecar
 	goimports -l -w ./store
-	goimports -l -w ./streams
 	goimports -l -w ./telemetry
 	goimports -l -w ./utils
 
@@ -48,10 +48,6 @@ proto-restore:
 proto-runtime:
 	protoc proto/runtime/*.proto --go_out=paths=source_relative:. --proto_path=.
 
-.PHONY: proto-streams
-proto-streams:
-	protoc proto/streams/*.proto --go_out=paths=source_relative:. --proto_path=.
-
 .PHONY: proto-cron
 proto-cron:
 	protoc proto/cron/*.proto --go_out=paths=source_relative:. --proto_path=.

README.md

@@ -2,15 +2,15 @@
 
 ## Features
 
-| Package   | Examples             | Use Case                   |
-| --------- | -------------------- | -------------------------- |
-| api       | http                 | build gateway servers      |
-| broker    | sns+sqs              | asynchronous communication |
-| client    | grpc, http           | synchronous communication  |
-| runtime   | kubernetes           | service info               |
-| security  | jwts, nacl, autocert | tokens, secrets, and certs |
-| server    | grpc                 | build backend servers      |
-| sidecar   | custom               | build sidecars             |
-| store     | cockroach            | data persistence           |
-| streams   | custom               | asynchronous communication |
-| telemetry | memory               | logs, metrics, and traces  |
+| Package   | Examples            | Use Case                     |
+| --------- | ------------------- | ---------------------------- |
+| api       | http                | build gateway servers        |
+| broker    | sns+sqs             | asynchronous communication   |
+| client    | grpc, http          | synchronous communication    |
+| runner    | docker              | test after file (.yml) apply |
+| runtime   | kubernetes          | service management           |
+| security  | jwts, tbd, autocert | tokens, secrets, and certs   |
+| server    | grpc                | build backend servers        |
+| sidecar   | custom              | build sidecars               |
+| store     | cockroach           | data persistence             |
+| telemetry | memory              | logs, metrics, and traces    |

broker/snssqs/snssqs.go

@@ -29,6 +29,12 @@ func (b *snssqs) Options() broker.BrokerOptions {
 	return b.options
 }
 
+// TODO: retry
+/* for loop with max retries
+**	go call a function that (a) calls exponential function (b) sleeps for the duration and (c) calls actual write that sends error to chan
+**  if err from chan is nil, stop
+**  else, keep looping
+ */
 func (b *snssqs) Publish(data interface{}, options broker.PublishOptions) error {
 	bs, err := datautils.Stringify(data)
 	if err != nil {

client/httpclient/http_client.go

@@ -137,6 +137,7 @@ func (c *httpClient) Call(ctx context.Context, req client.Request, rsp interface
 }
 
 func (c *httpClient) Stream(ctx context.Context, req client.Request, opts ...client.CallOption) (client.Stream, error) {
+	// TODO: implement
 	return nil, nil
 }
 

go.mod

@@ -9,22 +9,24 @@ require (
 	github.com/aws/aws-sdk-go-v2/config v1.27.30
 	github.com/aws/aws-sdk-go-v2/service/sns v1.31.5
 	github.com/aws/aws-sdk-go-v2/service/sqs v1.34.5
+	github.com/docker/docker v27.2.0+incompatible
 	github.com/golang-jwt/jwt v3.2.2+incompatible
 	github.com/google/uuid v1.6.0
 	github.com/gorilla/handlers v1.5.2
 	github.com/lib/pq v1.10.9
 	github.com/patrickmn/go-cache v2.1.0+incompatible
 	github.com/stretchr/testify v1.9.0
 	github.com/w-h-a/crd v0.1.0
-	golang.org/x/crypto v0.24.0
-	google.golang.org/grpc v1.64.0
+	golang.org/x/crypto v0.26.0
+	google.golang.org/grpc v1.65.0
 	google.golang.org/protobuf v1.34.2
 	k8s.io/api v0.31.0
 	k8s.io/apimachinery v0.31.0
 	k8s.io/client-go v0.31.0
 )
 
 require (
+	github.com/Microsoft/go-winio v0.4.14 // indirect
 	github.com/aws/aws-sdk-go-v2/credentials v1.17.29 // indirect
 	github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.16.12 // indirect
 	github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.16 // indirect
@@ -36,11 +38,16 @@ require (
 	github.com/aws/aws-sdk-go-v2/service/ssooidc v1.26.5 // indirect
 	github.com/aws/aws-sdk-go-v2/service/sts v1.30.5 // indirect
 	github.com/aws/smithy-go v1.20.4 // indirect
+	github.com/containerd/log v0.1.0 // indirect
 	github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc // indirect
+	github.com/distribution/reference v0.6.0 // indirect
+	github.com/docker/go-connections v0.5.0 // indirect
+	github.com/docker/go-units v0.5.0 // indirect
 	github.com/emicklei/go-restful/v3 v3.11.0 // indirect
-	github.com/felixge/httpsnoop v1.0.3 // indirect
+	github.com/felixge/httpsnoop v1.0.4 // indirect
 	github.com/fxamacker/cbor/v2 v2.7.0 // indirect
 	github.com/go-logr/logr v1.4.2 // indirect
+	github.com/go-logr/stdr v1.2.2 // indirect
 	github.com/go-openapi/jsonpointer v0.19.6 // indirect
 	github.com/go-openapi/jsonreference v0.20.2 // indirect
 	github.com/go-openapi/swag v0.22.4 // indirect
@@ -53,23 +60,36 @@ require (
 	github.com/josharian/intern v1.0.0 // indirect
 	github.com/json-iterator/go v1.1.12 // indirect
 	github.com/mailru/easyjson v0.7.7 // indirect
+	github.com/moby/docker-image-spec v1.3.1 // indirect
+	github.com/moby/term v0.5.0 // indirect
 	github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
 	github.com/modern-go/reflect2 v1.0.2 // indirect
+	github.com/morikuni/aec v1.0.0 // indirect
 	github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 // indirect
 	github.com/onsi/gomega v1.33.1 // indirect
+	github.com/opencontainers/go-digest v1.0.0 // indirect
+	github.com/opencontainers/image-spec v1.1.0 // indirect
+	github.com/pkg/errors v0.9.1 // indirect
 	github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 // indirect
 	github.com/spf13/pflag v1.0.5 // indirect
 	github.com/x448/float16 v0.8.4 // indirect
-	golang.org/x/net v0.26.0 // indirect
+	go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.54.0 // indirect
+	go.opentelemetry.io/otel v1.29.0 // indirect
+	go.opentelemetry.io/otel/exporters/otlp/otlptrace/otlptracehttp v1.29.0 // indirect
+	go.opentelemetry.io/otel/metric v1.29.0 // indirect
+	go.opentelemetry.io/otel/sdk v1.29.0 // indirect
+	go.opentelemetry.io/otel/trace v1.29.0 // indirect
+	golang.org/x/net v0.28.0 // indirect
 	golang.org/x/oauth2 v0.21.0 // indirect
-	golang.org/x/sys v0.21.0 // indirect
-	golang.org/x/term v0.21.0 // indirect
-	golang.org/x/text v0.16.0 // indirect
+	golang.org/x/sys v0.24.0 // indirect
+	golang.org/x/term v0.23.0 // indirect
+	golang.org/x/text v0.17.0 // indirect
 	golang.org/x/time v0.3.0 // indirect
-	google.golang.org/genproto/googleapis/rpc v0.0.0-20240318140521-94a12d6c2237 // indirect
+	google.golang.org/genproto/googleapis/rpc v0.0.0-20240822170219-fc7c04adadcd // indirect
 	gopkg.in/inf.v0 v0.9.1 // indirect
 	gopkg.in/yaml.v2 v2.4.0 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect
+	gotest.tools/v3 v3.5.1 // indirect
 	k8s.io/klog/v2 v2.130.1 // indirect
 	k8s.io/kube-openapi v0.0.0-20240228011516-70dd3763d340 // indirect
 	k8s.io/utils v0.0.0-20240711033017-18e509b52bc8 // indirect