From 63b27b63564ddb6ff18b0df41673c30eea1a2780 Mon Sep 17 00:00:00 2001 From: Yusuke Kato Date: Mon, 19 Feb 2024 13:55:22 +0900 Subject: [PATCH] update deps & re-generate k8s templates (#2376) Signed-off-by: kpango --- Makefile | 4 +- Makefile.d/functions.mk | 25 +++- charts/vald/README.md | 10 ++ example/client/go.mod | 5 +- example/client/go.sum | 10 +- go.mod | 24 ++-- go.sum | 24 ++-- k8s/agent/clusterrole.yaml | 0 k8s/agent/clusterrolebinding.yaml | 0 k8s/agent/ngt/configmap.yaml | 4 + k8s/agent/serviceaccount.yaml | 0 k8s/operator/helm/crds/valdrelease.yaml | 29 ++++ rust/Cargo.lock | 4 +- rust/libs/proto/src/core.v1.rs | 0 rust/libs/proto/src/core.v1.tonic.rs | 14 +- rust/libs/proto/src/discoverer.v1.rs | 0 rust/libs/proto/src/discoverer.v1.tonic.rs | 12 +- rust/libs/proto/src/filter.egress.v1.rs | 0 rust/libs/proto/src/filter.egress.v1.tonic.rs | 4 +- rust/libs/proto/src/filter.ingress.v1.rs | 0 .../libs/proto/src/filter.ingress.v1.tonic.rs | 6 +- rust/libs/proto/src/manager.index.v1.rs | 0 rust/libs/proto/src/manager.index.v1.tonic.rs | 4 +- rust/libs/proto/src/mirror.v1.rs | 0 rust/libs/proto/src/mirror.v1.tonic.rs | 4 +- rust/libs/proto/src/rpc.v1.rs | 8 +- rust/libs/proto/src/sidecar.v1.rs | 0 rust/libs/proto/src/vald.v1.rs | 0 rust/libs/proto/src/vald.v1.tonic.rs | 126 ++++++++++-------- tests/chaos/chart/README.md | 4 + versions/GOLANGCILINT_VERSION | 2 +- versions/PROMETHEUS_STACK_VERSION | 2 +- versions/PROTOBUF_VERSION | 2 +- versions/VALDCLI_VERSION | 2 +- versions/YQ_VERSION | 2 +- 35 files changed, 214 insertions(+), 117 deletions(-) create mode 100644 k8s/agent/clusterrole.yaml create mode 100644 k8s/agent/clusterrolebinding.yaml create mode 100644 k8s/agent/serviceaccount.yaml create mode 100644 rust/libs/proto/src/core.v1.rs create mode 100644 rust/libs/proto/src/discoverer.v1.rs create mode 100644 rust/libs/proto/src/filter.egress.v1.rs create mode 100644 rust/libs/proto/src/filter.ingress.v1.rs create mode 100644 rust/libs/proto/src/manager.index.v1.rs create mode 100644 rust/libs/proto/src/mirror.v1.rs create mode 100644 rust/libs/proto/src/sidecar.v1.rs create mode 100644 rust/libs/proto/src/vald.v1.rs diff --git a/Makefile b/Makefile index d255ced9c2..fd999e9086 100644 --- a/Makefile +++ b/Makefile @@ -424,11 +424,11 @@ update: \ ## format go codes format: \ license \ + format/proto \ format/go \ format/json \ format/md \ - format/yaml \ - format/proto + format/yaml .PHONY: format/go ## run golines, gofumpt, goimports for all go files diff --git a/Makefile.d/functions.mk b/Makefile.d/functions.mk index cedeab447c..b47ff7a597 100644 --- a/Makefile.d/functions.mk +++ b/Makefile.d/functions.mk @@ -285,7 +285,12 @@ define gen-license GOPRIVATE=$(GOPRIVATE) \ GOARCH=$(GOARCH) \ GOOS=$(GOOS) \ - go build -mod=readonly -a -o $$BIN_PATH $(ROOTDIR)/hack/license/gen/main.go; \ + go build -modcacherw \ + -mod=readonly \ + -a \ + -tags "osusergo netgo static_build" \ + -trimpath \ + -o $$BIN_PATH $(ROOTDIR)/hack/license/gen/main.go; \ $$BIN_PATH $1; \ rm -rf $$BIN_PATH endef @@ -296,7 +301,12 @@ define gen-vald-helm-schema GOPRIVATE=$(GOPRIVATE) \ GOARCH=$(GOARCH) \ GOOS=$(GOOS) \ - go build -mod=readonly -a -o $$BIN_PATH $(ROOTDIR)/hack/helm/schema/gen/main.go; \ + go build -modcacherw \ + -mod=readonly \ + -a \ + -tags "osusergo netgo static_build" \ + -trimpath \ + -o $$BIN_PATH $(ROOTDIR)/hack/helm/schema/gen/main.go; \ $$BIN_PATH charts/$1.yaml > charts/$1.schema.json; \ rm -rf $$BIN_PATH endef @@ -308,9 +318,14 @@ define gen-vald-crd BIN_PATH="$(TEMP_DIR)/vald-helm-crd-schema-gen"; \ rm -rf $$BIN_PATH; \ GOPRIVATE=$(GOPRIVATE) \ - GOARCH=$(GOARCH) \ - GOOS=$(GOOS) \ - go build -mod=readonly -a -o $$BIN_PATH $(ROOTDIR)/hack/helm/schema/crd/main.go; \ + GOARCH=$(GOARCH) \ + GOOS=$(GOOS) \ + go build -modcacherw \ + -mod=readonly \ + -a \ + -tags "osusergo netgo static_build" \ + -trimpath \ + -o $$BIN_PATH $(ROOTDIR)/hack/helm/schema/crd/main.go; \ $$BIN_PATH $(ROOTDIR)/charts/$3.yaml > $(TEMP_DIR)/$2-spec.yaml; \ rm -rf $$BIN_PATH; \ $(BINDIR)/yq eval-all 'select(fileIndex==0).spec.versions[0].schema.openAPIV3Schema.properties.spec = select(fileIndex==1).spec | select(fileIndex==0)' \ diff --git a/charts/vald/README.md b/charts/vald/README.md index 228a880ab8..d15f2f38a8 100644 --- a/charts/vald/README.md +++ b/charts/vald/README.md @@ -54,6 +54,10 @@ Run the following command to install the chart, | agent.affinity.podAntiAffinity.requiredDuringSchedulingIgnoredDuringExecution | list | `[]` | pod anti-affinity required scheduling terms | | agent.algorithm | string | `"ngt"` | agent algorithm type. it should be `ngt` or `faiss`. | | agent.annotations | object | `{}` | deployment annotations | +| agent.clusterRole.enabled | bool | `true` | creates clusterRole resource | +| agent.clusterRole.name | string | `"agent"` | name of clusterRole | +| agent.clusterRoleBinding.enabled | bool | `true` | creates clusterRoleBinding resource | +| agent.clusterRoleBinding.name | string | `"agent"` | name of clusterRoleBinding | | agent.enabled | bool | `true` | agent enabled | | agent.env | list | `[{"name":"MY_NODE_NAME","valueFrom":{"fieldRef":{"fieldPath":"spec.nodeName"}}},{"name":"MY_POD_NAME","valueFrom":{"fieldRef":{"fieldPath":"metadata.name"}}},{"name":"MY_POD_NAMESPACE","valueFrom":{"fieldRef":{"fieldPath":"metadata.namespace"}}}]` | environment variables | | agent.externalTrafficPolicy | string | `""` | external traffic policy (can be specified when service type is LoadBalancer or NodePort) : Cluster or Local | @@ -83,16 +87,20 @@ Run the following command to install the chart, | agent.ngt.dimension | int | `4096` | vector dimension | | agent.ngt.distance_type | string | `"l2"` | distance type. it should be `l1`, `l2`, `angle`, `hamming`, `cosine`,`poincare`, `lorentz`, `jaccard`, `sparsejaccard`, `normalizedangle` or `normalizedcosine`. for further details about NGT libraries supported distance is https://github.com/yahoojapan/NGT/wiki/Command-Quick-Reference and vald agent's supported NGT distance type is https://pkg.go.dev/github.com/vdaas/vald/internal/core/algorithm/ngt#pkg-constants | | agent.ngt.enable_copy_on_write | bool | `false` | enable copy on write saving for more stable backup | +| agent.ngt.enable_export_index_info_to_k8s | bool | `false` | enable export index info to k8s | | agent.ngt.enable_in_memory_mode | bool | `true` | in-memory mode enabled | | agent.ngt.enable_proactive_gc | bool | `false` | enable proactive GC call for reducing heap memory allocation | | agent.ngt.error_buffer_limit | int | `10` | maximum number of core ngt error buffer pool size limit | +| agent.ngt.export_index_info_duration | string | `"1m"` | duration of exporting index info | | agent.ngt.index_path | string | `""` | path to index data | | agent.ngt.initial_delay_max_duration | string | `"3m"` | maximum duration for initial delay | | agent.ngt.kvsdb.concurrency | int | `6` | kvsdb processing concurrency | | agent.ngt.load_index_timeout_factor | string | `"1ms"` | a factor of load index timeout. timeout duration will be calculated by (index count to be loaded) \* (factor). | | agent.ngt.max_load_index_timeout | string | `"10m"` | maximum duration of load index timeout | | agent.ngt.min_load_index_timeout | string | `"3m"` | minimum duration of load index timeout | +| agent.ngt.namespace | string | `"_MY_POD_NAMESPACE_"` | namespace of myself | | agent.ngt.object_type | string | `"float"` | object type. it should be `float` or `uint8` or `float16`. for further details: https://github.com/yahoojapan/NGT/wiki/Command-Quick-Reference | +| agent.ngt.pod_name | string | `"_MY_POD_NAME_"` | pod name of myself | | agent.ngt.search_edge_size | int | `50` | search edge size | | agent.ngt.vqueue.delete_buffer_pool_size | int | `5000` | delete slice pool buffer size | | agent.ngt.vqueue.insert_buffer_pool_size | int | `10000` | insert slice pool buffer size | @@ -132,6 +140,8 @@ Run the following command to install the chart, | agent.server_config | object | `{"healths":{"liveness":{},"readiness":{},"startup":{"startupProbe":{"failureThreshold":200,"periodSeconds":5}}},"metrics":{"pprof":{}},"servers":{"grpc":{},"rest":{}}}` | server config (overrides defaults.server_config) | | agent.service.annotations | object | `{}` | service annotations | | agent.service.labels | object | `{}` | service labels | +| agent.serviceAccount.enabled | bool | `true` | creates service account | +| agent.serviceAccount.name | string | `"agent-ngt"` | name of service account | | agent.serviceType | string | `"ClusterIP"` | service type: ClusterIP, LoadBalancer or NodePort | | agent.sidecar.config.auto_backup_duration | string | `"24h"` | auto backup duration | | agent.sidecar.config.auto_backup_enabled | bool | `true` | auto backup triggered by timer is enabled | diff --git a/example/client/go.mod b/example/client/go.mod index a67a1a8f01..9d618e2c98 100644 --- a/example/client/go.mod +++ b/example/client/go.mod @@ -23,16 +23,17 @@ replace ( require ( github.com/kpango/fuid v0.0.0-20221203053508-503b5ad89aa1 github.com/kpango/glg v1.6.14 - github.com/vdaas/vald-client-go v1.7.10 + github.com/vdaas/vald-client-go v1.7.11 gonum.org/v1/hdf5 v0.0.0-20210714002203-8c5d23bc6946 google.golang.org/grpc v1.61.0 ) require ( - buf.build/gen/go/bufbuild/protovalidate/protocolbuffers/go v1.31.0-20231115204500-e097f827e652.2 // indirect + buf.build/gen/go/bufbuild/protovalidate/protocolbuffers/go v1.32.0-20240212200630-3014d81c3a48.1 // indirect github.com/goccy/go-json v0.10.2 // indirect github.com/golang/protobuf v1.5.3 // indirect github.com/kpango/fastime v1.1.9 // indirect + github.com/planetscale/vtprotobuf v0.6.0 // indirect golang.org/x/net v0.20.0 // indirect golang.org/x/sys v0.17.0 // indirect golang.org/x/text v0.14.0 // indirect diff --git a/example/client/go.sum b/example/client/go.sum index 5e127874f4..1413a867a6 100644 --- a/example/client/go.sum +++ b/example/client/go.sum @@ -1,5 +1,5 @@ -buf.build/gen/go/bufbuild/protovalidate/protocolbuffers/go v1.31.0-20231115204500-e097f827e652.2 h1:iEPA5SBtdLJNwQis/SrcCuDWJh5E1V0mVO4Ih7/mRbg= -buf.build/gen/go/bufbuild/protovalidate/protocolbuffers/go v1.31.0-20231115204500-e097f827e652.2/go.mod h1:xafc+XIsTxTy76GJQ1TKgvJWsSugFBqMaN27WhUblew= +buf.build/gen/go/bufbuild/protovalidate/protocolbuffers/go v1.32.0-20240212200630-3014d81c3a48.1 h1:rOe/itdO7+9cWOnKqvpn1K7VmTDwp3vI4juPz6aNQbc= +buf.build/gen/go/bufbuild/protovalidate/protocolbuffers/go v1.32.0-20240212200630-3014d81c3a48.1/go.mod h1:tiTMKD8j6Pd/D2WzREoweufjzaJKHZg35f/VGcZ2v3I= github.com/goccy/go-json v0.10.2 h1:CrxCmQqYDkv1z7lO7Wbh2HN93uovUHgrECaO5ZrCXAU= github.com/goccy/go-json v0.10.2/go.mod h1:6MelG93GURQebXPDq3khkgXZkazVtN9CRI+MGFi0w8I= github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg= @@ -13,10 +13,12 @@ github.com/kpango/fuid v0.0.0-20221203053508-503b5ad89aa1 h1:rxyM+7uaZQ35P9fbixd github.com/kpango/fuid v0.0.0-20221203053508-503b5ad89aa1/go.mod h1:CAYeq6us9NfnRkSz67/xKVIR6/vaY5ZQZRe6IVcaIKg= github.com/kpango/glg v1.6.15 h1:nw0xSxpSyrDIWHeb3dvnE08PW+SCbK+aYFETT75IeLA= github.com/kpango/glg v1.6.15/go.mod h1:cmsc7Yeu8AS3wHLmN7bhwENXOpxfq+QoqxCIk2FneRk= +github.com/planetscale/vtprotobuf v0.6.0 h1:nBeETjudeJ5ZgBHUz1fVHvbqUKnYOXNhsIEabROxmNA= +github.com/planetscale/vtprotobuf v0.6.0/go.mod h1:t/avpk3KcrXxUnYOhZhMXJlSEyie6gQbtLq5NM3loB8= github.com/sirupsen/logrus v1.9.0 h1:trlNQbNUG3OdDrDil03MCb1H2o9nJ1x4/5LYw7byDE0= github.com/sirupsen/logrus v1.9.0/go.mod h1:naHLuLoDiP4jHNo9R0sCBMtWGeIprob74mVsIT4qYEQ= -github.com/vdaas/vald-client-go v1.7.10 h1:hsvAXDJPs+KSdx6pUE66ZLz39uKcqFaNm1li7Ij8HG4= -github.com/vdaas/vald-client-go v1.7.10/go.mod h1:Q1FkJWDwDVM/64xLcQCBmA5mR2vaGxB7rrFSqsxq93E= +github.com/vdaas/vald-client-go v1.7.11 h1:3CVTJStzH4DDRZIB/fGh3kuhJggNrdUOaHf+JnbG4zg= +github.com/vdaas/vald-client-go v1.7.11/go.mod h1:4lIIWe+enh6LDIZEqvU/ryzFcfjWH0LCxta3ECSD0I0= go.uber.org/atomic v1.7.0 h1:ADUqmZGgLDDfbSL9ZmPxKTybcoEYHgpYfELNoN+7hsw= go.uber.org/atomic v1.7.0/go.mod h1:fEN4uk6kAWBTFdckzkM89CLk9XfWZrxpCo0nPH17wJc= go.uber.org/multierr v1.6.0 h1:y6IPFStTAIT5Ytl7/XYmHvzXQ7S3g/IeZW9hyZ5thw4= diff --git a/go.mod b/go.mod index d1d8706bb3..2c6aefe78c 100644 --- a/go.mod +++ b/go.mod @@ -38,19 +38,19 @@ replace ( github.com/DATA-DOG/go-sqlmock => github.com/DATA-DOG/go-sqlmock v1.5.2 github.com/GoogleCloudPlatform/cloudsql-proxy => github.com/GoogleCloudPlatform/cloudsql-proxy v1.33.16 github.com/Masterminds/semver/v3 => github.com/Masterminds/semver/v3 v3.2.1 - github.com/ajstarks/deck => github.com/ajstarks/deck v0.0.0-20231012031509-f833e437b68a - github.com/ajstarks/deck/generate => github.com/ajstarks/deck/generate v0.0.0-20231012031509-f833e437b68a + github.com/ajstarks/deck => github.com/ajstarks/deck v0.0.0-20240215023147-77e8381c6641 + github.com/ajstarks/deck/generate => github.com/ajstarks/deck/generate v0.0.0-20240215023147-77e8381c6641 github.com/ajstarks/svgo => github.com/ajstarks/svgo v0.0.0-20211024235047-1546f124cd8b github.com/akrylysov/pogreb => github.com/akrylysov/pogreb v0.10.2 github.com/antihax/optional => github.com/antihax/optional v1.0.0 github.com/armon/go-socks5 => github.com/armon/go-socks5 v0.0.0-20160902184237-e75332964ef5 - github.com/aws/aws-sdk-go => github.com/aws/aws-sdk-go v1.50.18 + github.com/aws/aws-sdk-go => github.com/aws/aws-sdk-go v1.50.20 github.com/aws/aws-sdk-go-v2 => github.com/aws/aws-sdk-go-v2 v1.25.0 github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream => github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.0 github.com/aws/aws-sdk-go-v2/config => github.com/aws/aws-sdk-go-v2/config v1.27.0 github.com/aws/aws-sdk-go-v2/credentials => github.com/aws/aws-sdk-go-v2/credentials v1.17.0 github.com/aws/aws-sdk-go-v2/feature/ec2/imds => github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.15.0 - github.com/aws/aws-sdk-go-v2/feature/s3/manager => github.com/aws/aws-sdk-go-v2/feature/s3/manager v1.16.0 + github.com/aws/aws-sdk-go-v2/feature/s3/manager => github.com/aws/aws-sdk-go-v2/feature/s3/manager v1.16.1 github.com/aws/aws-sdk-go-v2/internal/configsources => github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.0 github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 => github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.0 github.com/aws/aws-sdk-go-v2/internal/ini => github.com/aws/aws-sdk-go-v2/internal/ini v1.8.0 @@ -58,12 +58,12 @@ replace ( github.com/aws/aws-sdk-go-v2/service/internal/checksum => github.com/aws/aws-sdk-go-v2/service/internal/checksum v1.3.0 github.com/aws/aws-sdk-go-v2/service/internal/presigned-url => github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.11.0 github.com/aws/aws-sdk-go-v2/service/internal/s3shared => github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.17.0 - github.com/aws/aws-sdk-go-v2/service/kms => github.com/aws/aws-sdk-go-v2/service/kms v1.28.0 - github.com/aws/aws-sdk-go-v2/service/s3 => github.com/aws/aws-sdk-go-v2/service/s3 v1.49.0 - github.com/aws/aws-sdk-go-v2/service/secretsmanager => github.com/aws/aws-sdk-go-v2/service/secretsmanager v1.27.0 - github.com/aws/aws-sdk-go-v2/service/sns => github.com/aws/aws-sdk-go-v2/service/sns v1.27.0 - github.com/aws/aws-sdk-go-v2/service/sqs => github.com/aws/aws-sdk-go-v2/service/sqs v1.30.0 - github.com/aws/aws-sdk-go-v2/service/ssm => github.com/aws/aws-sdk-go-v2/service/ssm v1.46.0 + github.com/aws/aws-sdk-go-v2/service/kms => github.com/aws/aws-sdk-go-v2/service/kms v1.28.1 + github.com/aws/aws-sdk-go-v2/service/s3 => github.com/aws/aws-sdk-go-v2/service/s3 v1.50.0 + github.com/aws/aws-sdk-go-v2/service/secretsmanager => github.com/aws/aws-sdk-go-v2/service/secretsmanager v1.27.1 + github.com/aws/aws-sdk-go-v2/service/sns => github.com/aws/aws-sdk-go-v2/service/sns v1.28.0 + github.com/aws/aws-sdk-go-v2/service/sqs => github.com/aws/aws-sdk-go-v2/service/sqs v1.30.1 + github.com/aws/aws-sdk-go-v2/service/ssm => github.com/aws/aws-sdk-go-v2/service/ssm v1.47.0 github.com/aws/aws-sdk-go-v2/service/sso => github.com/aws/aws-sdk-go-v2/service/sso v1.19.0 github.com/aws/aws-sdk-go-v2/service/sts => github.com/aws/aws-sdk-go-v2/service/sts v1.27.0 github.com/aws/smithy-go => github.com/aws/smithy-go v1.20.0 @@ -237,8 +237,8 @@ replace ( github.com/pmezard/go-difflib => github.com/pmezard/go-difflib v1.0.0 github.com/prashantv/gostub => github.com/prashantv/gostub v1.1.0 github.com/prometheus/client_golang => github.com/prometheus/client_golang v1.18.0 - github.com/prometheus/client_model => github.com/prometheus/client_model v0.5.0 - github.com/prometheus/common => github.com/prometheus/common v0.46.0 + github.com/prometheus/client_model => github.com/prometheus/client_model v0.6.0 + github.com/prometheus/common => github.com/prometheus/common v0.47.0 github.com/prometheus/procfs => github.com/prometheus/procfs v0.12.0 github.com/prometheus/prometheus => github.com/prometheus/prometheus v1.99.0 github.com/quasilyte/go-ruleguard => github.com/quasilyte/go-ruleguard v0.4.0 diff --git a/go.sum b/go.sum index 7c2db2f07d..cfa743f25e 100644 --- a/go.sum +++ b/go.sum @@ -163,8 +163,8 @@ github.com/Masterminds/goutils v1.1.1 h1:5nUrii3FMTL5diU80unEVvNevw1nH4+ZV4DSLVJ github.com/Masterminds/goutils v1.1.1/go.mod h1:8cTjp+g8YejhMuvIA5y2vz3BpJxksy863GQaJW2MFNU= github.com/Masterminds/semver v1.5.0 h1:H65muMkzWKEuNDnfl9d70GUjFniHKHRbFPGBuZ3QEww= github.com/Masterminds/semver v1.5.0/go.mod h1:MB6lktGJrhw8PrUyiEoblNEGEQ+RzHPF078ddwwvV3Y= -github.com/ajstarks/deck v0.0.0-20231012031509-f833e437b68a/go.mod h1:CsIRRFEUjsvutRrtCL20i8EdMLo6JPw/F2XUmF+X694= -github.com/ajstarks/deck/generate v0.0.0-20231012031509-f833e437b68a/go.mod h1:u04DhpZIpzaPnAUmhhjibCj450/2ITtLTEnvhaM49as= +github.com/ajstarks/deck v0.0.0-20240215023147-77e8381c6641/go.mod h1:CsIRRFEUjsvutRrtCL20i8EdMLo6JPw/F2XUmF+X694= +github.com/ajstarks/deck/generate v0.0.0-20240215023147-77e8381c6641/go.mod h1:u04DhpZIpzaPnAUmhhjibCj450/2ITtLTEnvhaM49as= github.com/ajstarks/fc v0.0.0-20230606144319-ef5d5cb73a3d/go.mod h1:Qp3TfzbBiIjHwDxIpu+g9nYfNw+xXF2Yqp4WmMlTtwM= github.com/ajstarks/openvg v0.0.0-20191008131700-c6885d824eb8/go.mod h1:jpZHIkd4sQEgrzshrUQrRfv5OUMMq0w/Q1yK6ZYhUlk= github.com/ajstarks/svgo v0.0.0-20211024235047-1546f124cd8b h1:slYM766cy2nI3BwyRiyQj/Ud48djTMtMebDqepE95rw= @@ -185,8 +185,8 @@ github.com/apache/arrow/go/v14 v14.0.2/go.mod h1:u3fgh3EdgN/YQ8cVQRguVW3R+seMybF github.com/apache/thrift v0.17.0/go.mod h1:OLxhMRJxomX+1I/KUw03qoV3mMz16BwaKI+d4fPBx7Q= github.com/armon/go-socks5 v0.0.0-20160902184237-e75332964ef5 h1:0CwZNZbxp69SHPdPJAN/hZIm0C4OItdklCFmMRWYpio= github.com/armon/go-socks5 v0.0.0-20160902184237-e75332964ef5/go.mod h1:wHh0iHkYZB8zMSxRWpUBQtwG5a7fFgvEO+odwuTv2gs= -github.com/aws/aws-sdk-go v1.50.18 h1:h+FQjxp5sSDqFKScTUXHVahBlqduKtiR0qM18evcvag= -github.com/aws/aws-sdk-go v1.50.18/go.mod h1:LF8svs817+Nz+DmiMQKTO3ubZ/6IaTpq3TjupRn3Eqk= +github.com/aws/aws-sdk-go v1.50.20 h1:xfAnSDVf/azIWTVQXQODp89bubvCS85r70O3nuQ4dnE= +github.com/aws/aws-sdk-go v1.50.20/go.mod h1:LF8svs817+Nz+DmiMQKTO3ubZ/6IaTpq3TjupRn3Eqk= github.com/aws/aws-sdk-go-v2 v1.25.0 h1:sv7+1JVJxOu/dD/sz/csHX7jFqmP001TIY7aytBWDSQ= github.com/aws/aws-sdk-go-v2 v1.25.0/go.mod h1:G104G1Aho5WqF+SR3mDIobTABQzpYV0WxMsKxlMggOA= github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.6.0 h1:2UO6/nT1lCZq1LqM67Oa4tdgP1CvL1sLSxvuD+VrOeE= @@ -197,8 +197,8 @@ github.com/aws/aws-sdk-go-v2/credentials v1.17.0 h1:lMW2x6sKBsiAJrpi1doOXqWFyEPo github.com/aws/aws-sdk-go-v2/credentials v1.17.0/go.mod h1:uT41FIH8cCIxOdUYIL0PYyHlL1NoneDuDSCwg5VE/5o= github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.15.0 h1:xWCwjjvVz2ojYTP4kBKUuUh9ZrXfcAXpflhOUUeXg1k= github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.15.0/go.mod h1:j3fACuqXg4oMTQOR2yY7m0NmJY0yBK4L4sLsRXq1Ins= -github.com/aws/aws-sdk-go-v2/feature/s3/manager v1.16.0 h1:FHVyVIJpOeQZCnYj9EVKTWahb4WDNFEUOKCx/dOUPcM= -github.com/aws/aws-sdk-go-v2/feature/s3/manager v1.16.0/go.mod h1:SL/aJzGL0LsQPQ1y2HMNbJGrm/Xh6aVCGq6ki+DLGEw= +github.com/aws/aws-sdk-go-v2/feature/s3/manager v1.16.1 h1:FqtJUSBgT2yfZ8kZhTi9AO131qMLOzb4MiH4riAM8XM= +github.com/aws/aws-sdk-go-v2/feature/s3/manager v1.16.1/go.mod h1:G3V4qNUPMHKrXW/l149QXmHjf1vlMWBO4UuGPCK4a/c= github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.0 h1:NPs/EqVO+ajwOoq56EfcGKa3L3ruWuazkIw1BqxwOPw= github.com/aws/aws-sdk-go-v2/internal/configsources v1.3.0/go.mod h1:D+duLy2ylgatV+yTlQ8JTuLfDD0BnFvnQRc+o6tbZ4M= github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.6.0 h1:ks7KGMVUMoDzcxNWUlEdI+/lokMFD136EL6DWmUOV80= @@ -215,8 +215,8 @@ github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.11.0 h1:SHN/umDLT github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.11.0/go.mod h1:l8gPU5RYGOFHJqWEpPMoRTP0VoaWQSkJdKo+hwWnnDA= github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.17.0 h1:l5puwOHr7IxECuPMIuZG7UKOzAnF24v6t4l+Z5Moay4= github.com/aws/aws-sdk-go-v2/service/internal/s3shared v1.17.0/go.mod h1:Oov79flWa/n7Ni+lQC3z+VM7PoRM47omRqbJU9B5Y7E= -github.com/aws/aws-sdk-go-v2/service/s3 v1.49.0 h1:VfU15izXQjz4m9y1DkbY79iylIiuPwWtrram4cSpWEI= -github.com/aws/aws-sdk-go-v2/service/s3 v1.49.0/go.mod h1:1o/W6JFUuREj2ExoQ21vHJgO7wakvjhol91M9eknFgs= +github.com/aws/aws-sdk-go-v2/service/s3 v1.50.0 h1:jZAdMD1ioZdqirzzVVRhpHHWJmcGGCn8JqDYBs5nmYA= +github.com/aws/aws-sdk-go-v2/service/s3 v1.50.0/go.mod h1:1o/W6JFUuREj2ExoQ21vHJgO7wakvjhol91M9eknFgs= github.com/aws/aws-sdk-go-v2/service/sso v1.19.0 h1:u6OkVDxtBPnxPkZ9/63ynEe+8kHbtS5IfaC4PzVxzWM= github.com/aws/aws-sdk-go-v2/service/sso v1.19.0/go.mod h1:YqbU3RS/pkDVu+v+Nwxvn0i1WB0HkNWEePWbmODEbbs= github.com/aws/aws-sdk-go-v2/service/ssooidc v1.21.5 h1:2k9KmFawS63euAkY4/ixVNsYYwrwnd5fIvgEKkfZFNM= @@ -540,10 +540,10 @@ github.com/prashantv/gostub v1.1.0 h1:BTyx3RfQjRHnUWaGF9oQos79AlQ5k8WNktv7VGvVH4 github.com/prashantv/gostub v1.1.0/go.mod h1:A5zLQHz7ieHGG7is6LLXLz7I8+3LZzsrV0P1IAHhP5U= github.com/prometheus/client_golang v1.18.0 h1:HzFfmkOzH5Q8L8G+kSJKUx5dtG87sewO+FoDDqP5Tbk= github.com/prometheus/client_golang v1.18.0/go.mod h1:T+GXkCk5wSJyOqMIzVgvvjFDlkOQntgjkJWKrN5txjA= -github.com/prometheus/client_model v0.5.0 h1:VQw1hfvPvk3Uv6Qf29VrPF32JB6rtbgI6cYPYQjL0Qw= -github.com/prometheus/client_model v0.5.0/go.mod h1:dTiFglRmd66nLR9Pv9f0mZi7B7fk5Pm3gvsjB5tr+kI= -github.com/prometheus/common v0.46.0 h1:doXzt5ybi1HBKpsZOL0sSkaNHJJqkyfEWZGGqqScV0Y= -github.com/prometheus/common v0.46.0/go.mod h1:Tp0qkxpb9Jsg54QMe+EAmqXkSV7Evdy1BTn+g2pa/hQ= +github.com/prometheus/client_model v0.6.0 h1:k1v3CzpSRUTrKMppY35TLwPvxHqBu0bYgxZzqGIgaos= +github.com/prometheus/client_model v0.6.0/go.mod h1:NTQHnmxFpouOD0DpvP4XujX3CdOAGQPoaGhyTchlyt8= +github.com/prometheus/common v0.47.0 h1:p5Cz0FNHo7SnWOmWmoRozVcjEp0bIVU8cV7OShpjL1k= +github.com/prometheus/common v0.47.0/go.mod h1:0/KsvlIEfPQCQ5I2iNSAWKPZziNCvRs5EC6ILDTlAPc= github.com/prometheus/procfs v0.12.0 h1:jluTpSng7V9hY0O2R9DzzJHYb2xULk9VTR1V1R/k6Bo= github.com/prometheus/procfs v0.12.0/go.mod h1:pcuDEFsWDnvcgNzo4EEweacyhjeA9Zk3cnaOZAZEfOo= github.com/quasilyte/go-ruleguard v0.4.0 h1:DyM6r+TKL+xbKB4Nm7Afd1IQh9kEUKQs2pboWGKtvQo= diff --git a/k8s/agent/clusterrole.yaml b/k8s/agent/clusterrole.yaml new file mode 100644 index 0000000000..e69de29bb2 diff --git a/k8s/agent/clusterrolebinding.yaml b/k8s/agent/clusterrolebinding.yaml new file mode 100644 index 0000000000..e69de29bb2 diff --git a/k8s/agent/ngt/configmap.yaml b/k8s/agent/ngt/configmap.yaml index 0cc3743581..35eadceb86 100644 --- a/k8s/agent/ngt/configmap.yaml +++ b/k8s/agent/ngt/configmap.yaml @@ -213,9 +213,11 @@ data: dimension: 784 distance_type: l2 enable_copy_on_write: false + enable_export_index_info_to_k8s: false enable_in_memory_mode: true enable_proactive_gc: false error_buffer_limit: 10 + export_index_info_duration: 1m index_path: "" initial_delay_max_duration: 3m kvsdb: @@ -223,7 +225,9 @@ data: load_index_timeout_factor: 1ms max_load_index_timeout: 10m min_load_index_timeout: 3m + namespace: _MY_POD_NAMESPACE_ object_type: float + pod_name: _MY_POD_NAME_ search_edge_size: 50 vqueue: delete_buffer_pool_size: 5000 diff --git a/k8s/agent/serviceaccount.yaml b/k8s/agent/serviceaccount.yaml new file mode 100644 index 0000000000..e69de29bb2 diff --git a/k8s/operator/helm/crds/valdrelease.yaml b/k8s/operator/helm/crds/valdrelease.yaml index fa8d749b29..6e7776f91d 100644 --- a/k8s/operator/helm/crds/valdrelease.yaml +++ b/k8s/operator/helm/crds/valdrelease.yaml @@ -124,6 +124,20 @@ spec: annotations: type: object x-kubernetes-preserve-unknown-fields: true + clusterRole: + type: object + properties: + enabled: + type: boolean + name: + type: string + clusterRoleBinding: + type: object + properties: + enabled: + type: boolean + name: + type: string enabled: type: boolean env: @@ -251,6 +265,8 @@ spec: - normalizedcosine enable_copy_on_write: type: boolean + enable_export_index_info_to_k8s: + type: boolean enable_in_memory_mode: type: boolean enable_proactive_gc: @@ -258,6 +274,8 @@ spec: error_buffer_limit: type: integer minimum: 1 + export_index_info_duration: + type: string index_path: type: string initial_delay_max_duration: @@ -273,12 +291,16 @@ spec: type: string min_load_index_timeout: type: string + namespace: + type: string object_type: type: string enum: - float - float16 - uint8 + pod_name: + type: string search_edge_size: type: integer vqueue: @@ -959,6 +981,13 @@ spec: labels: type: object x-kubernetes-preserve-unknown-fields: true + serviceAccount: + type: object + properties: + enabled: + type: boolean + name: + type: string serviceType: type: string enum: diff --git a/rust/Cargo.lock b/rust/Cargo.lock index 9c97873377..3a16f74f08 100644 --- a/rust/Cargo.lock +++ b/rust/Cargo.lock @@ -616,9 +616,9 @@ dependencies = [ [[package]] name = "syn" -version = "2.0.48" +version = "2.0.49" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "0f3531638e407dfc0814761abb7c00a5b54992b849452a0646b7f65c9f770f3f" +checksum = "915aea9e586f80826ee59f8453c1101f9d1c4b3964cd2460185ee8e299ada496" dependencies = [ "proc-macro2", "quote", diff --git a/rust/libs/proto/src/core.v1.rs b/rust/libs/proto/src/core.v1.rs new file mode 100644 index 0000000000..e69de29bb2 diff --git a/rust/libs/proto/src/core.v1.tonic.rs b/rust/libs/proto/src/core.v1.tonic.rs index 7540a3508c..ba50ab8380 100644 --- a/rust/libs/proto/src/core.v1.tonic.rs +++ b/rust/libs/proto/src/core.v1.tonic.rs @@ -384,7 +384,7 @@ pub mod agent_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).create_index(request).await + ::create_index(&inner, request).await }; Box::pin(fut) } @@ -432,7 +432,9 @@ pub mod agent_server { >, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).save_index(request).await }; + let fut = async move { + ::save_index(&inner, request).await + }; Box::pin(fut) } } @@ -480,7 +482,7 @@ pub mod agent_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).create_and_save_index(request).await + ::create_and_save_index(&inner, request).await }; Box::pin(fut) } @@ -528,7 +530,9 @@ pub mod agent_server { >, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).index_info(request).await }; + let fut = async move { + ::index_info(&inner, request).await + }; Box::pin(fut) } } @@ -576,7 +580,7 @@ pub mod agent_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).get_timestamp(request).await + ::get_timestamp(&inner, request).await }; Box::pin(fut) } diff --git a/rust/libs/proto/src/discoverer.v1.rs b/rust/libs/proto/src/discoverer.v1.rs new file mode 100644 index 0000000000..e69de29bb2 diff --git a/rust/libs/proto/src/discoverer.v1.tonic.rs b/rust/libs/proto/src/discoverer.v1.tonic.rs index 23729bc1c6..41bdf757ee 100644 --- a/rust/libs/proto/src/discoverer.v1.tonic.rs +++ b/rust/libs/proto/src/discoverer.v1.tonic.rs @@ -322,7 +322,9 @@ pub mod discoverer_server { >, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).pods(request).await }; + let fut = async move { + ::pods(&inner, request).await + }; Box::pin(fut) } } @@ -369,7 +371,9 @@ pub mod discoverer_server { >, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).nodes(request).await }; + let fut = async move { + ::nodes(&inner, request).await + }; Box::pin(fut) } } @@ -416,7 +420,9 @@ pub mod discoverer_server { >, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).services(request).await }; + let fut = async move { + ::services(&inner, request).await + }; Box::pin(fut) } } diff --git a/rust/libs/proto/src/filter.egress.v1.rs b/rust/libs/proto/src/filter.egress.v1.rs new file mode 100644 index 0000000000..e69de29bb2 diff --git a/rust/libs/proto/src/filter.egress.v1.tonic.rs b/rust/libs/proto/src/filter.egress.v1.tonic.rs index 87ea20f66c..902dc5f5d2 100644 --- a/rust/libs/proto/src/filter.egress.v1.tonic.rs +++ b/rust/libs/proto/src/filter.egress.v1.tonic.rs @@ -291,7 +291,7 @@ pub mod filter_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).filter_distance(request).await + ::filter_distance(&inner, request).await }; Box::pin(fut) } @@ -340,7 +340,7 @@ pub mod filter_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).filter_vector(request).await + ::filter_vector(&inner, request).await }; Box::pin(fut) } diff --git a/rust/libs/proto/src/filter.ingress.v1.rs b/rust/libs/proto/src/filter.ingress.v1.rs new file mode 100644 index 0000000000..e69de29bb2 diff --git a/rust/libs/proto/src/filter.ingress.v1.tonic.rs b/rust/libs/proto/src/filter.ingress.v1.tonic.rs index 0b47f10258..f5f9efd4f2 100644 --- a/rust/libs/proto/src/filter.ingress.v1.tonic.rs +++ b/rust/libs/proto/src/filter.ingress.v1.tonic.rs @@ -290,7 +290,9 @@ pub mod filter_server { >, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).gen_vector(request).await }; + let fut = async move { + ::gen_vector(&inner, request).await + }; Box::pin(fut) } } @@ -338,7 +340,7 @@ pub mod filter_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).filter_vector(request).await + ::filter_vector(&inner, request).await }; Box::pin(fut) } diff --git a/rust/libs/proto/src/manager.index.v1.rs b/rust/libs/proto/src/manager.index.v1.rs new file mode 100644 index 0000000000..e69de29bb2 diff --git a/rust/libs/proto/src/manager.index.v1.tonic.rs b/rust/libs/proto/src/manager.index.v1.tonic.rs index 8dae1cc3f0..84255cb3a5 100644 --- a/rust/libs/proto/src/manager.index.v1.tonic.rs +++ b/rust/libs/proto/src/manager.index.v1.tonic.rs @@ -240,7 +240,9 @@ pub mod index_server { >, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).index_info(request).await }; + let fut = async move { + ::index_info(&inner, request).await + }; Box::pin(fut) } } diff --git a/rust/libs/proto/src/mirror.v1.rs b/rust/libs/proto/src/mirror.v1.rs new file mode 100644 index 0000000000..e69de29bb2 diff --git a/rust/libs/proto/src/mirror.v1.tonic.rs b/rust/libs/proto/src/mirror.v1.tonic.rs index 7a76438644..443b46e2ee 100644 --- a/rust/libs/proto/src/mirror.v1.tonic.rs +++ b/rust/libs/proto/src/mirror.v1.tonic.rs @@ -239,7 +239,9 @@ pub mod mirror_server { >, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).register(request).await }; + let fut = async move { + ::register(&inner, request).await + }; Box::pin(fut) } } diff --git a/rust/libs/proto/src/rpc.v1.rs b/rust/libs/proto/src/rpc.v1.rs index 7e546ee43e..11e53490a2 100644 --- a/rust/libs/proto/src/rpc.v1.rs +++ b/rust/libs/proto/src/rpc.v1.rs @@ -19,7 +19,7 @@ pub struct ErrorInfo { /// The reason of the error. This is a constant value that identifies the /// proximate cause of the error. Error reasons are unique within a particular /// domain of errors. This should be at most 63 characters and match a - /// regular expression of `\[A-Z][A-Z0-9_]+[A-Z0-9\]`, which represents + /// regular expression of `[A-Z][A-Z0-9_]+\[A-Z0-9\]`, which represents /// UPPER_SNAKE_CASE. #[prost(string, tag="1")] pub reason: ::prost::alloc::string::String, @@ -192,7 +192,7 @@ pub mod bad_request { /// * `full_name` for a violation in the `full_name` value /// * `email_addresses\[1\].email` for a violation in the `email` field of the /// first `email_addresses` message - /// * `email_addresses\[3].type[2\]` for a violation in the second `type` + /// * `email_addresses\[3\].type\[2\]` for a violation in the second `type` /// value in the third `email_addresses` message. /// /// In JSON, the same values are represented as: @@ -200,7 +200,7 @@ pub mod bad_request { /// * `fullName` for a violation in the `fullName` value /// * `emailAddresses\[1\].email` for a violation in the `email` field of the /// first `emailAddresses` message - /// * `emailAddresses\[3].type[2\]` for a violation in the second `type` + /// * `emailAddresses\[3\].type\[2\]` for a violation in the second `type` /// value in the third `emailAddresses` message. #[prost(string, tag="1")] pub field: ::prost::alloc::string::String, @@ -235,7 +235,7 @@ pub struct ResourceInfo { /// The name of the resource being accessed. For example, a shared calendar /// name: "example.com_4fghdhgsrgh@group.calendar.google.com", if the current /// error is - /// \[google.rpc.Code.PERMISSION_DENIED][google.rpc.Code.PERMISSION_DENIED\]. + /// [google.rpc.Code.PERMISSION_DENIED][google.rpc.Code.PERMISSION_DENIED]. #[prost(string, tag="2")] pub resource_name: ::prost::alloc::string::String, /// The owner of the resource (optional). diff --git a/rust/libs/proto/src/sidecar.v1.rs b/rust/libs/proto/src/sidecar.v1.rs new file mode 100644 index 0000000000..e69de29bb2 diff --git a/rust/libs/proto/src/vald.v1.rs b/rust/libs/proto/src/vald.v1.rs new file mode 100644 index 0000000000..e69de29bb2 diff --git a/rust/libs/proto/src/vald.v1.tonic.rs b/rust/libs/proto/src/vald.v1.tonic.rs index 481ee81ea8..3b9caf242e 100644 --- a/rust/libs/proto/src/vald.v1.tonic.rs +++ b/rust/libs/proto/src/vald.v1.tonic.rs @@ -489,7 +489,7 @@ pub mod filter_server { tonic::Status, >; /// Server streaming response type for the StreamSearchObject method. - type StreamSearchObjectStream: futures_core::Stream< + type StreamSearchObjectStream: tonic::codegen::tokio_stream::Stream< Item = std::result::Result< super::super::super::payload::v1::search::StreamResponse, tonic::Status, @@ -520,7 +520,7 @@ pub mod filter_server { tonic::Status, >; /// Server streaming response type for the StreamInsertObject method. - type StreamInsertObjectStream: futures_core::Stream< + type StreamInsertObjectStream: tonic::codegen::tokio_stream::Stream< Item = std::result::Result< super::super::super::payload::v1::object::StreamLocation, tonic::Status, @@ -562,7 +562,7 @@ pub mod filter_server { tonic::Status, >; /// Server streaming response type for the StreamUpdateObject method. - type StreamUpdateObjectStream: futures_core::Stream< + type StreamUpdateObjectStream: tonic::codegen::tokio_stream::Stream< Item = std::result::Result< super::super::super::payload::v1::object::StreamLocation, tonic::Status, @@ -604,7 +604,7 @@ pub mod filter_server { tonic::Status, >; /// Server streaming response type for the StreamUpsertObject method. - type StreamUpsertObjectStream: futures_core::Stream< + type StreamUpsertObjectStream: tonic::codegen::tokio_stream::Stream< Item = std::result::Result< super::super::super::payload::v1::object::StreamLocation, tonic::Status, @@ -735,7 +735,7 @@ pub mod filter_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).search_object(request).await + ::search_object(&inner, request).await }; Box::pin(fut) } @@ -784,7 +784,7 @@ pub mod filter_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).multi_search_object(request).await + ::multi_search_object(&inner, request).await }; Box::pin(fut) } @@ -836,7 +836,7 @@ pub mod filter_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).stream_search_object(request).await + ::stream_search_object(&inner, request).await }; Box::pin(fut) } @@ -885,7 +885,7 @@ pub mod filter_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).insert_object(request).await + ::insert_object(&inner, request).await }; Box::pin(fut) } @@ -937,7 +937,7 @@ pub mod filter_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).stream_insert_object(request).await + ::stream_insert_object(&inner, request).await }; Box::pin(fut) } @@ -986,7 +986,7 @@ pub mod filter_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).multi_insert_object(request).await + ::multi_insert_object(&inner, request).await }; Box::pin(fut) } @@ -1035,7 +1035,7 @@ pub mod filter_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).update_object(request).await + ::update_object(&inner, request).await }; Box::pin(fut) } @@ -1087,7 +1087,7 @@ pub mod filter_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).stream_update_object(request).await + ::stream_update_object(&inner, request).await }; Box::pin(fut) } @@ -1136,7 +1136,7 @@ pub mod filter_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).multi_update_object(request).await + ::multi_update_object(&inner, request).await }; Box::pin(fut) } @@ -1185,7 +1185,7 @@ pub mod filter_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).upsert_object(request).await + ::upsert_object(&inner, request).await }; Box::pin(fut) } @@ -1237,7 +1237,7 @@ pub mod filter_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).stream_upsert_object(request).await + ::stream_upsert_object(&inner, request).await }; Box::pin(fut) } @@ -1286,7 +1286,7 @@ pub mod filter_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).multi_upsert_object(request).await + ::multi_upsert_object(&inner, request).await }; Box::pin(fut) } @@ -1543,7 +1543,7 @@ pub mod insert_server { tonic::Status, >; /// Server streaming response type for the StreamInsert method. - type StreamInsertStream: futures_core::Stream< + type StreamInsertStream: tonic::codegen::tokio_stream::Stream< Item = std::result::Result< super::super::super::payload::v1::object::StreamLocation, tonic::Status, @@ -1673,7 +1673,9 @@ pub mod insert_server { >, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).insert(request).await }; + let fut = async move { + ::insert(&inner, request).await + }; Box::pin(fut) } } @@ -1724,7 +1726,7 @@ pub mod insert_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).stream_insert(request).await + ::stream_insert(&inner, request).await }; Box::pin(fut) } @@ -1773,7 +1775,7 @@ pub mod insert_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).multi_insert(request).await + ::multi_insert(&inner, request).await }; Box::pin(fut) } @@ -2071,7 +2073,7 @@ pub mod object_server { tonic::Status, >; /// Server streaming response type for the StreamGetObject method. - type StreamGetObjectStream: futures_core::Stream< + type StreamGetObjectStream: tonic::codegen::tokio_stream::Stream< Item = std::result::Result< super::super::super::payload::v1::object::StreamVector, tonic::Status, @@ -2091,7 +2093,7 @@ pub mod object_server { tonic::Status, >; /// Server streaming response type for the StreamListObject method. - type StreamListObjectStream: futures_core::Stream< + type StreamListObjectStream: tonic::codegen::tokio_stream::Stream< Item = std::result::Result< super::super::super::payload::v1::object::list::Response, tonic::Status, @@ -2210,7 +2212,9 @@ pub mod object_server { >, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).exists(request).await }; + let fut = async move { + ::exists(&inner, request).await + }; Box::pin(fut) } } @@ -2257,7 +2261,9 @@ pub mod object_server { >, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).get_object(request).await }; + let fut = async move { + ::get_object(&inner, request).await + }; Box::pin(fut) } } @@ -2308,7 +2314,7 @@ pub mod object_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).stream_get_object(request).await + ::stream_get_object(&inner, request).await }; Box::pin(fut) } @@ -2358,7 +2364,7 @@ pub mod object_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).stream_list_object(request).await + ::stream_list_object(&inner, request).await }; Box::pin(fut) } @@ -2655,7 +2661,7 @@ pub mod remove_server { tonic::Status, >; /// Server streaming response type for the StreamRemove method. - type StreamRemoveStream: futures_core::Stream< + type StreamRemoveStream: tonic::codegen::tokio_stream::Stream< Item = std::result::Result< super::super::super::payload::v1::object::StreamLocation, tonic::Status, @@ -2785,7 +2791,9 @@ pub mod remove_server { >, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).remove(request).await }; + let fut = async move { + ::remove(&inner, request).await + }; Box::pin(fut) } } @@ -2833,7 +2841,7 @@ pub mod remove_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).remove_by_timestamp(request).await + ::remove_by_timestamp(&inner, request).await }; Box::pin(fut) } @@ -2885,7 +2893,7 @@ pub mod remove_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).stream_remove(request).await + ::stream_remove(&inner, request).await }; Box::pin(fut) } @@ -2934,7 +2942,7 @@ pub mod remove_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).multi_remove(request).await + ::multi_remove(&inner, request).await }; Box::pin(fut) } @@ -3474,7 +3482,7 @@ pub mod search_server { tonic::Status, >; /// Server streaming response type for the StreamSearch method. - type StreamSearchStream: futures_core::Stream< + type StreamSearchStream: tonic::codegen::tokio_stream::Stream< Item = std::result::Result< super::super::super::payload::v1::search::StreamResponse, tonic::Status, @@ -3494,7 +3502,7 @@ pub mod search_server { tonic::Status, >; /// Server streaming response type for the StreamSearchByID method. - type StreamSearchByIDStream: futures_core::Stream< + type StreamSearchByIDStream: tonic::codegen::tokio_stream::Stream< Item = std::result::Result< super::super::super::payload::v1::search::StreamResponse, tonic::Status, @@ -3554,7 +3562,7 @@ pub mod search_server { tonic::Status, >; /// Server streaming response type for the StreamLinearSearch method. - type StreamLinearSearchStream: futures_core::Stream< + type StreamLinearSearchStream: tonic::codegen::tokio_stream::Stream< Item = std::result::Result< super::super::super::payload::v1::search::StreamResponse, tonic::Status, @@ -3574,7 +3582,7 @@ pub mod search_server { tonic::Status, >; /// Server streaming response type for the StreamLinearSearchByID method. - type StreamLinearSearchByIDStream: futures_core::Stream< + type StreamLinearSearchByIDStream: tonic::codegen::tokio_stream::Stream< Item = std::result::Result< super::super::super::payload::v1::search::StreamResponse, tonic::Status, @@ -3717,7 +3725,9 @@ pub mod search_server { >, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).search(request).await }; + let fut = async move { + ::search(&inner, request).await + }; Box::pin(fut) } } @@ -3765,7 +3775,7 @@ pub mod search_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).search_by_id(request).await + ::search_by_id(&inner, request).await }; Box::pin(fut) } @@ -3817,7 +3827,7 @@ pub mod search_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).stream_search(request).await + ::stream_search(&inner, request).await }; Box::pin(fut) } @@ -3869,7 +3879,7 @@ pub mod search_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).stream_search_by_id(request).await + ::stream_search_by_id(&inner, request).await }; Box::pin(fut) } @@ -3918,7 +3928,7 @@ pub mod search_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).multi_search(request).await + ::multi_search(&inner, request).await }; Box::pin(fut) } @@ -3967,7 +3977,7 @@ pub mod search_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).multi_search_by_id(request).await + ::multi_search_by_id(&inner, request).await }; Box::pin(fut) } @@ -4016,7 +4026,7 @@ pub mod search_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).linear_search(request).await + ::linear_search(&inner, request).await }; Box::pin(fut) } @@ -4065,7 +4075,7 @@ pub mod search_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).linear_search_by_id(request).await + ::linear_search_by_id(&inner, request).await }; Box::pin(fut) } @@ -4117,7 +4127,7 @@ pub mod search_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).stream_linear_search(request).await + ::stream_linear_search(&inner, request).await }; Box::pin(fut) } @@ -4169,7 +4179,8 @@ pub mod search_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).stream_linear_search_by_id(request).await + ::stream_linear_search_by_id(&inner, request) + .await }; Box::pin(fut) } @@ -4218,7 +4229,7 @@ pub mod search_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).multi_linear_search(request).await + ::multi_linear_search(&inner, request).await }; Box::pin(fut) } @@ -4267,7 +4278,8 @@ pub mod search_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).multi_linear_search_by_id(request).await + ::multi_linear_search_by_id(&inner, request) + .await }; Box::pin(fut) } @@ -4524,7 +4536,7 @@ pub mod update_server { tonic::Status, >; /// Server streaming response type for the StreamUpdate method. - type StreamUpdateStream: futures_core::Stream< + type StreamUpdateStream: tonic::codegen::tokio_stream::Stream< Item = std::result::Result< super::super::super::payload::v1::object::StreamLocation, tonic::Status, @@ -4654,7 +4666,9 @@ pub mod update_server { >, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).update(request).await }; + let fut = async move { + ::update(&inner, request).await + }; Box::pin(fut) } } @@ -4705,7 +4719,7 @@ pub mod update_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).stream_update(request).await + ::stream_update(&inner, request).await }; Box::pin(fut) } @@ -4754,7 +4768,7 @@ pub mod update_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).multi_update(request).await + ::multi_update(&inner, request).await }; Box::pin(fut) } @@ -5011,7 +5025,7 @@ pub mod upsert_server { tonic::Status, >; /// Server streaming response type for the StreamUpsert method. - type StreamUpsertStream: futures_core::Stream< + type StreamUpsertStream: tonic::codegen::tokio_stream::Stream< Item = std::result::Result< super::super::super::payload::v1::object::StreamLocation, tonic::Status, @@ -5141,7 +5155,9 @@ pub mod upsert_server { >, ) -> Self::Future { let inner = Arc::clone(&self.0); - let fut = async move { (*inner).upsert(request).await }; + let fut = async move { + ::upsert(&inner, request).await + }; Box::pin(fut) } } @@ -5192,7 +5208,7 @@ pub mod upsert_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).stream_upsert(request).await + ::stream_upsert(&inner, request).await }; Box::pin(fut) } @@ -5241,7 +5257,7 @@ pub mod upsert_server { ) -> Self::Future { let inner = Arc::clone(&self.0); let fut = async move { - (*inner).multi_upsert(request).await + ::multi_upsert(&inner, request).await }; Box::pin(fut) } diff --git a/tests/chaos/chart/README.md b/tests/chaos/chart/README.md index 3860102505..594dee6331 100644 --- a/tests/chaos/chart/README.md +++ b/tests/chaos/chart/README.md @@ -38,3 +38,7 @@ A Helm chart for testing Vald using Chaos Mesh. | podChaos.kill.schedule | string | `"*/2 * * * *"` | | | podChaos.kill.selector.labelSelectors."app.kubernetes.io/name" | string | `"vald"` | | | podChaos.kill.selector.namespaces[0] | string | `"default"` | | + +--- + +Autogenerated from chart metadata using [helm-docs v1.12.0](https://github.com/norwoodj/helm-docs/releases/v1.12.0) diff --git a/versions/GOLANGCILINT_VERSION b/versions/GOLANGCILINT_VERSION index a003b19750..fe1df057f3 100644 --- a/versions/GOLANGCILINT_VERSION +++ b/versions/GOLANGCILINT_VERSION @@ -1 +1 @@ -v1.56.1 +v1.56.2 diff --git a/versions/PROMETHEUS_STACK_VERSION b/versions/PROMETHEUS_STACK_VERSION index df31b5b43e..13f01c3f71 100644 --- a/versions/PROMETHEUS_STACK_VERSION +++ b/versions/PROMETHEUS_STACK_VERSION @@ -1 +1 @@ -56.6.2 +56.7.0 diff --git a/versions/PROTOBUF_VERSION b/versions/PROTOBUF_VERSION index a5615e1308..51fc50a418 100644 --- a/versions/PROTOBUF_VERSION +++ b/versions/PROTOBUF_VERSION @@ -1 +1 @@ -25.2 +25.3 diff --git a/versions/VALDCLI_VERSION b/versions/VALDCLI_VERSION index ac38ea0789..e20d08587b 100644 --- a/versions/VALDCLI_VERSION +++ b/versions/VALDCLI_VERSION @@ -1 +1 @@ -v1.7.10 +v1.7.10.Rev1 diff --git a/versions/YQ_VERSION b/versions/YQ_VERSION index 37babf1804..56b1fa960d 100644 --- a/versions/YQ_VERSION +++ b/versions/YQ_VERSION @@ -1 +1 @@ -v4.40.7 +v4.41.1