Skip to content

Commit 3a6e80a

Browse files
committed
feat(catalog): catalog run logging
1 parent feab1e8 commit 3a6e80a

File tree

15 files changed

+2693
-204
lines changed

15 files changed

+2693
-204
lines changed

.gitignore

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -121,3 +121,4 @@ tmp
121121
.DS_Store
122122
cmd/main/__debug_bin*
123123
/test_files/
124+
.idea

cmd/main/main.go

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -15,8 +15,6 @@ import (
1515
"time"
1616

1717
"github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
18-
influxdb2 "github.com/influxdata/influxdb-client-go/v2"
19-
openfga "github.com/openfga/api/proto/openfga/v1"
2018
"github.com/redis/go-redis/v9"
2119
"go.opentelemetry.io/contrib/propagators/b3"
2220
"go.opentelemetry.io/otel"
@@ -34,6 +32,8 @@ import (
3432
grpcMiddleware "github.com/grpc-ecosystem/go-grpc-middleware"
3533
grpcZap "github.com/grpc-ecosystem/go-grpc-middleware/logging/zap"
3634
grpcRecovery "github.com/grpc-ecosystem/go-grpc-middleware/recovery"
35+
influxdb2 "github.com/influxdata/influxdb-client-go/v2"
36+
openfga "github.com/openfga/api/proto/openfga/v1"
3737

3838
"github.com/instill-ai/artifact-backend/config"
3939
"github.com/instill-ai/artifact-backend/pkg/acl"
@@ -42,8 +42,8 @@ import (
4242
"github.com/instill-ai/artifact-backend/pkg/logger"
4343
"github.com/instill-ai/artifact-backend/pkg/middleware"
4444
"github.com/instill-ai/artifact-backend/pkg/milvus"
45+
"github.com/instill-ai/artifact-backend/pkg/minio"
4546
"github.com/instill-ai/artifact-backend/pkg/repository"
46-
servicePkg "github.com/instill-ai/artifact-backend/pkg/service"
4747
"github.com/instill-ai/artifact-backend/pkg/usage"
4848
"github.com/instill-ai/artifact-backend/pkg/utils"
4949
"github.com/instill-ai/artifact-backend/pkg/worker"
@@ -52,7 +52,8 @@ import (
5252
httpClient "github.com/instill-ai/artifact-backend/pkg/client/http"
5353
database "github.com/instill-ai/artifact-backend/pkg/db"
5454
customOtel "github.com/instill-ai/artifact-backend/pkg/logger/otel"
55-
minio "github.com/instill-ai/artifact-backend/pkg/minio"
55+
servicePkg "github.com/instill-ai/artifact-backend/pkg/service"
56+
5657
artifactPB "github.com/instill-ai/protogen-go/artifact/artifact/v1alpha"
5758
mgmtPB "github.com/instill-ai/protogen-go/core/mgmt/v1beta"
5859
pipelinePB "github.com/instill-ai/protogen-go/vdp/pipeline/v1beta"

go.mod

Lines changed: 26 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -6,20 +6,21 @@ require (
66
github.com/frankban/quicktest v1.14.6
77
github.com/go-resty/resty/v2 v2.12.0
88
github.com/gofrs/uuid v4.4.0+incompatible
9-
github.com/gojuno/minimock/v3 v3.3.6
9+
github.com/gojuno/minimock/v3 v3.4.0
1010
github.com/golang-migrate/migrate/v4 v4.17.0
1111
github.com/google/go-cmp v0.6.0
1212
github.com/grpc-ecosystem/go-grpc-middleware v1.3.0
1313
github.com/grpc-ecosystem/grpc-gateway/v2 v2.19.1
1414
github.com/influxdata/influxdb-client-go/v2 v2.12.3
15-
github.com/instill-ai/protogen-go v0.3.3-alpha.0.20240923163607-406de8626033
15+
github.com/instill-ai/protogen-go v0.3.3-alpha.0.20240926030437-7a1e3a9e0c46
1616
github.com/instill-ai/usage-client v0.3.0-alpha.0.20240319060111-4a3a39f2fd61
17-
github.com/instill-ai/x v0.3.0-alpha.0.20231219052200-6230a89e386c
17+
github.com/instill-ai/x v0.4.0-alpha.0.20240923052503-fd243919e005
1818
github.com/knadh/koanf v1.5.0
1919
github.com/milvus-io/milvus-sdk-go/v2 v2.4.1
2020
github.com/minio/minio-go v6.0.14+incompatible
2121
github.com/openfga/api/proto v0.0.0-20240723155248-7e5be7b65c27
2222
github.com/redis/go-redis/v9 v9.5.3
23+
go.einride.tech/aip v0.68.0
2324
go.opentelemetry.io/contrib/propagators/b3 v1.17.0
2425
go.opentelemetry.io/otel v1.16.0
2526
go.opentelemetry.io/otel/exporters/otlp/otlpmetric/otlpmetricgrpc v0.39.0
@@ -30,34 +31,43 @@ require (
3031
go.opentelemetry.io/otel/sdk/metric v0.39.0
3132
go.opentelemetry.io/otel/trace v1.16.0
3233
go.uber.org/zap v1.26.0
33-
golang.org/x/net v0.26.0
34-
google.golang.org/genproto/googleapis/rpc v0.0.0-20240528184218-531527333157
35-
google.golang.org/grpc v1.64.1
36-
google.golang.org/protobuf v1.34.1
37-
gorm.io/driver/postgres v1.4.5
38-
gorm.io/gorm v1.24.7-0.20230306060331-85eaf9eeda11
34+
golang.org/x/net v0.28.0
35+
google.golang.org/genproto/googleapis/rpc v0.0.0-20240711142825-46eb208f015d
36+
google.golang.org/grpc v1.65.0
37+
google.golang.org/protobuf v1.34.2
38+
gopkg.in/guregu/null.v4 v4.0.0
39+
gorm.io/datatypes v1.2.2
40+
gorm.io/driver/postgres v1.5.0
41+
gorm.io/gorm v1.25.11
3942
)
4043

4144
require (
4245
cloud.google.com/go/longrunning v0.5.4 // indirect
46+
filippo.io/edwards25519 v1.1.0 // indirect
4347
github.com/cockroachdb/errors v1.9.1 // indirect
4448
github.com/cockroachdb/logtags v0.0.0-20211118104740-dabe8e521a4f // indirect
4549
github.com/cockroachdb/redact v1.1.3 // indirect
4650
github.com/envoyproxy/protoc-gen-validate v1.0.4 // indirect
4751
github.com/getsentry/sentry-go v0.12.0 // indirect
4852
github.com/go-ini/ini v1.67.0 // indirect
53+
github.com/go-sql-driver/mysql v1.8.1 // indirect
4954
github.com/gogo/protobuf v1.3.2 // indirect
55+
github.com/google/uuid v1.6.0 // indirect
56+
github.com/jackc/pgx/v5 v5.5.5 // indirect
57+
github.com/jackc/puddle/v2 v2.2.1 // indirect
5058
github.com/milvus-io/milvus-proto/go-api/v2 v2.4.3 // indirect
5159
github.com/mitchellh/go-homedir v1.1.0 // indirect
5260
github.com/tidwall/gjson v1.14.4 // indirect
5361
github.com/tidwall/match v1.1.1 // indirect
5462
github.com/tidwall/pretty v1.2.0 // indirect
63+
golang.org/x/sync v0.8.0 // indirect
64+
gorm.io/driver/mysql v1.5.6 // indirect
5565
)
5666

5767
require (
5868
github.com/catalinc/hashcash v0.0.0-20220723060415-5e3ec3e24f67 // indirect
5969
github.com/cenkalti/backoff/v4 v4.2.1 // indirect
60-
github.com/cespare/xxhash/v2 v2.2.0 // indirect
70+
github.com/cespare/xxhash/v2 v2.3.0 // indirect
6171
github.com/davecgh/go-spew v1.1.1 // indirect
6272
github.com/deepmap/oapi-codegen v1.8.2 // indirect
6373
github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect
@@ -73,9 +83,7 @@ require (
7383
github.com/jackc/pgio v1.0.0 // indirect
7484
github.com/jackc/pgpassfile v1.0.0 // indirect
7585
github.com/jackc/pgproto3/v2 v2.3.3 // indirect
76-
github.com/jackc/pgservicefile v0.0.0-20221227161230-091c0ba34f0a // indirect
77-
github.com/jackc/pgtype v1.14.0 // indirect
78-
github.com/jackc/pgx/v4 v4.18.2 // indirect
86+
github.com/jackc/pgservicefile v0.0.0-20231201235250-de7065d80cb9 // indirect
7987
github.com/jinzhu/inflection v1.0.0 // indirect
8088
github.com/jinzhu/now v1.1.5 // indirect
8189
github.com/kr/pretty v0.3.1 // indirect
@@ -88,17 +96,17 @@ require (
8896
github.com/pkg/errors v0.9.1 // indirect
8997
github.com/pmezard/go-difflib v1.0.0 // indirect
9098
github.com/rogpeppe/go-internal v1.10.0 // indirect
91-
github.com/stretchr/testify v1.8.4 // indirect
99+
github.com/stretchr/testify v1.9.0
92100
go.opentelemetry.io/otel/exporters/otlp/internal/retry v1.16.0 // indirect
93101
go.opentelemetry.io/otel/exporters/otlp/otlpmetric v0.39.0 // indirect
94102
go.opentelemetry.io/otel/exporters/otlp/otlptrace v1.16.0 // indirect
95103
go.opentelemetry.io/otel/metric v1.16.0 // indirect
96104
go.opentelemetry.io/proto/otlp v0.19.0 // indirect
97105
go.uber.org/atomic v1.10.0 // indirect
98106
go.uber.org/multierr v1.10.0 // indirect
99-
golang.org/x/crypto v0.24.0
100-
golang.org/x/sys v0.21.0 // indirect
101-
golang.org/x/text v0.16.0 // indirect
102-
google.golang.org/genproto/googleapis/api v0.0.0-20240528184218-531527333157 // indirect
107+
golang.org/x/crypto v0.26.0
108+
golang.org/x/sys v0.24.0 // indirect
109+
golang.org/x/text v0.17.0 // indirect
110+
google.golang.org/genproto/googleapis/api v0.0.0-20240711142825-46eb208f015d // indirect
103111
gopkg.in/yaml.v3 v3.0.1 // indirect
104112
)

0 commit comments

Comments
 (0)