Clean up repo (#4)

README.md

@@ -1 +1,23 @@
 # Tilebox Go Library
+
+This repository contains the Go library for Tilebox.
+
+## Getting Started
+
+### Installation
+
+Run the following command to add the library to your project:
+
+```bash
+go get github.com/tilebox/tilebox-go
+```
+
+### Usage
+
+Here is a minimal usage example where we create a JobClient and submit a task:
+
+```go
+package main
+
+// TODO
+```

task-runner/buf.gen.yaml → buf.gen.yaml

@@ -2,7 +2,7 @@ version: v1
 managed:
   enabled: true
   go_package_prefix:
-    default: github.com/tilebox/tilebox-go/task-runner/protogen/go
+    default: github.com/tilebox/tilebox-go/protogen/go
     except:
       - buf.build/googleapis/googleapis
 plugins:

workflows-service/buf.work.yaml → buf.work.yaml

@@ -1,4 +1,3 @@
 version: v1
 directories:
   - apis
-#  - apis-internal

workflows-service/generate.go → generate.go

@@ -1,3 +1,3 @@
-package task_runner
+package tilebox_go
 
 //go:generate go run -mod=mod github.com/bufbuild/buf/cmd/buf generate

go.mod

@@ -8,8 +8,6 @@ require (
 	github.com/axiomhq/axiom-go v0.17.5
 	github.com/google/uuid v1.6.0
 	github.com/hashicorp/go-retryablehttp v0.7.5
-	github.com/integrii/flaggy v1.5.2
-	github.com/remychantenay/slog-otel v1.3.0
 	go.opentelemetry.io/otel v1.24.0
 	go.opentelemetry.io/otel/sdk v1.24.0
 	go.opentelemetry.io/otel/trace v1.24.0

go.sum

@@ -58,7 +58,6 @@ github.com/gogo/protobuf v1.3.2/go.mod h1:P1XiOD3dCwIKUDQYPy72D8LYyHL2YPYrpS2s69
 github.com/google/cel-go v0.20.1 h1:nDx9r8S3L4pE61eDdt8igGj8rf5kjYR3ILxWIpWNi84=
 github.com/google/cel-go v0.20.1/go.mod h1:kWcIzTsPX0zmQ+H3TirHstLLf9ep5QTsZBN9u4dOYLg=
 github.com/google/go-cmp v0.5.2/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
-github.com/google/go-cmp v0.5.6/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
 github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI=
 github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
 github.com/google/go-containerregistry v0.19.1 h1:yMQ62Al6/V0Z7CqIrrS1iYoA5/oQCm88DeNujc7C1KY=
@@ -77,8 +76,6 @@ github.com/hashicorp/go-hclog v0.9.2 h1:CG6TE5H9/JXsFWJCfoIVpKFIkFe6ysEuHirp4DxC
 github.com/hashicorp/go-hclog v0.9.2/go.mod h1:5CU+agLiy3J7N7QjHK5d05KxGsuXiQLrjA0H7acj2lQ=
 github.com/hashicorp/go-retryablehttp v0.7.5 h1:bJj+Pj19UZMIweq/iie+1u5YCdGrnxCT9yvm0e+Nd5M=
 github.com/hashicorp/go-retryablehttp v0.7.5/go.mod h1:Jy/gPYAdjqffZ/yFGCFV2doI5wjtH1ewM9u8iYVjtX8=
-github.com/integrii/flaggy v1.5.2 h1:bWV20MQEngo4hWhno3i5Z9ISPxLPKj9NOGNwTWb/8IQ=
-github.com/integrii/flaggy v1.5.2/go.mod h1:dO13u7SYuhk910nayCJ+s1DeAAGC1THCMj1uSFmwtQ8=
 github.com/jdx/go-netrc v1.0.0 h1:QbLMLyCZGj0NA8glAhxUpf1zDg6cxnWgMBbjq40W0gQ=
 github.com/jdx/go-netrc v1.0.0/go.mod h1:Gh9eFQJnoTNIRHXl2j5bJXA1u84hQWJWgGh569zF3v8=
 github.com/klauspost/compress v1.17.7 h1:ehO88t2UGzQK66LMdE8tibEd1ErmzZjNEqWkjLAKQQg=
@@ -105,8 +102,6 @@ github.com/pkg/profile v1.7.0 h1:hnbDkaNWPCLMO9wGLdBFTIZvzDrDfBM2072E1S9gJkA=
 github.com/pkg/profile v1.7.0/go.mod h1:8Uer0jas47ZQMJ7VD+OHknK4YDY07LPUC6dEvqDjvNo=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
-github.com/remychantenay/slog-otel v1.3.0 h1:mppL97agkmwR416lKzltRQ9QRhrPdxwVidt0AnI3Ts4=
-github.com/remychantenay/slog-otel v1.3.0/go.mod h1:L2VAe6WOMAk/kRzzuv2B/rWe/IDXAhUNae0919b4kHU=
 github.com/rs/cors v1.10.1 h1:L0uuZVXIKlI1SShY2nhFfo44TYvDPQ1w4oFkUJNfhyo=
 github.com/rs/cors v1.10.1/go.mod h1:XyqrcTp5zjWr1wsJ8PIRZssZ8b/WMcMf71DJnit4EMU=
 github.com/russross/blackfriday/v2 v2.1.0 h1:JIOH55/0cWyOuilr9/qlrm0BSXldqnqwMsf35Ld67mk=

task-runner/services/grpc_connect.go → grpc/grpc_connect.go

@@ -1,4 +1,4 @@
-package services
+package grpc
 
 import (
 	"connectrpc.com/connect"

task-runner/services/observability.go → observability/observability.go

@@ -1,11 +1,11 @@
-package services
+package observability
 
 import (
 	"context"
 	adapter "github.com/axiomhq/axiom-go/adapters/slog"
 	"github.com/axiomhq/axiom-go/axiom"
 	axiotel "github.com/axiomhq/axiom-go/axiom/otel"
-	workflowsv1 "github.com/tilebox/tilebox-go/workflows-service/protogen/go/workflows/v1"
+	workflowsv1 "github.com/tilebox/tilebox-go/protogen/go/workflows/v1"
 	"go.opentelemetry.io/otel"
 	"go.opentelemetry.io/otel/codes"
 	"go.opentelemetry.io/otel/propagation"
@@ -67,15 +67,15 @@ func tracerProvider(serviceName, serviceVersion string, exporters []trace.SpanEx
 	return trace.NewTracerProvider(opts...)
 }
 
-func getTraceParentOfCurrentSpan(ctx context.Context) string {
+func GetTraceParentOfCurrentSpan(ctx context.Context) string {
 	carrier := propagation.MapCarrier{}
 
 	propagator.Inject(ctx, carrier)
 
 	return carrier.Get("traceparent")
 }
 
-func startJobSpan[Result any](tracer oteltrace.Tracer, ctx context.Context, spanName string, job *workflowsv1.Job, f func(ctx context.Context) (Result, error)) (Result, error) {
+func StartJobSpan[Result any](tracer oteltrace.Tracer, ctx context.Context, spanName string, job *workflowsv1.Job, f func(ctx context.Context) (Result, error)) (Result, error) {
 	carrier := propagation.MapCarrier{"traceparent": job.TraceParent}
 	ctx = propagator.Extract(ctx, carrier)