From 0993ff4e4cfab85ee448f6d27e9eab4a67662b24 Mon Sep 17 00:00:00 2001 From: hlts2 Date: Wed, 24 Jul 2024 15:51:18 +0900 Subject: [PATCH] fix: make format Signed-off-by: hlts2 --- apis/grpc/v1/agent/core/agent_vtproto.pb.go | 15 ++----- .../v1/discoverer/discoverer_vtproto.pb.go | 15 ++----- .../filter/egress/egress_filter_vtproto.pb.go | 10 +---- .../ingress/ingress_filter_vtproto.pb.go | 10 +---- apis/grpc/v1/mirror/mirror_vtproto.pb.go | 5 +-- apis/grpc/v1/vald/filter_vtproto.pb.go | 40 ++++--------------- apis/grpc/v1/vald/flush_vtproto.pb.go | 5 +-- apis/grpc/v1/vald/index_vtproto.pb.go | 10 +---- apis/grpc/v1/vald/insert_vtproto.pb.go | 10 +---- apis/grpc/v1/vald/object_vtproto.pb.go | 15 ++----- apis/grpc/v1/vald/remove_vtproto.pb.go | 15 ++----- apis/grpc/v1/vald/search_vtproto.pb.go | 40 ++++--------------- apis/grpc/v1/vald/update_vtproto.pb.go | 10 +---- apis/grpc/v1/vald/upsert_vtproto.pb.go | 10 +---- dockers/agent/core/agent/Dockerfile | 2 +- dockers/ci/base/Dockerfile | 2 +- dockers/dev/Dockerfile | 2 +- 17 files changed, 45 insertions(+), 171 deletions(-) diff --git a/apis/grpc/v1/agent/core/agent_vtproto.pb.go b/apis/grpc/v1/agent/core/agent_vtproto.pb.go index 42c060279e..9c2a729b4f 100644 --- a/apis/grpc/v1/agent/core/agent_vtproto.pb.go +++ b/apis/grpc/v1/agent/core/agent_vtproto.pb.go @@ -135,10 +135,7 @@ func RegisterAgentServer(s grpc.ServiceRegistrar, srv AgentServer) { } func _Agent_CreateIndex_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Control_CreateIndexRequest) if err := dec(in); err != nil { @@ -158,10 +155,7 @@ func _Agent_CreateIndex_Handler( } func _Agent_SaveIndex_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Empty) if err := dec(in); err != nil { @@ -181,10 +175,7 @@ func _Agent_SaveIndex_Handler( } func _Agent_CreateAndSaveIndex_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Control_CreateIndexRequest) if err := dec(in); err != nil { diff --git a/apis/grpc/v1/discoverer/discoverer_vtproto.pb.go b/apis/grpc/v1/discoverer/discoverer_vtproto.pb.go index 0f401fb0cc..6fc5d237ef 100644 --- a/apis/grpc/v1/discoverer/discoverer_vtproto.pb.go +++ b/apis/grpc/v1/discoverer/discoverer_vtproto.pb.go @@ -137,10 +137,7 @@ func RegisterDiscovererServer(s grpc.ServiceRegistrar, srv DiscovererServer) { } func _Discoverer_Pods_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Discoverer_Request) if err := dec(in); err != nil { @@ -160,10 +157,7 @@ func _Discoverer_Pods_Handler( } func _Discoverer_Nodes_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Discoverer_Request) if err := dec(in); err != nil { @@ -183,10 +177,7 @@ func _Discoverer_Nodes_Handler( } func _Discoverer_Services_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Discoverer_Request) if err := dec(in); err != nil { diff --git a/apis/grpc/v1/filter/egress/egress_filter_vtproto.pb.go b/apis/grpc/v1/filter/egress/egress_filter_vtproto.pb.go index 6912789d95..ffe26943c8 100644 --- a/apis/grpc/v1/filter/egress/egress_filter_vtproto.pb.go +++ b/apis/grpc/v1/filter/egress/egress_filter_vtproto.pb.go @@ -117,10 +117,7 @@ func RegisterFilterServer(s grpc.ServiceRegistrar, srv FilterServer) { } func _Filter_FilterDistance_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Object_Distance) if err := dec(in); err != nil { @@ -140,10 +137,7 @@ func _Filter_FilterDistance_Handler( } func _Filter_FilterVector_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Object_Vector) if err := dec(in); err != nil { diff --git a/apis/grpc/v1/filter/ingress/ingress_filter_vtproto.pb.go b/apis/grpc/v1/filter/ingress/ingress_filter_vtproto.pb.go index 7c015bc199..8b13821505 100644 --- a/apis/grpc/v1/filter/ingress/ingress_filter_vtproto.pb.go +++ b/apis/grpc/v1/filter/ingress/ingress_filter_vtproto.pb.go @@ -117,10 +117,7 @@ func RegisterFilterServer(s grpc.ServiceRegistrar, srv FilterServer) { } func _Filter_GenVector_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Object_Blob) if err := dec(in); err != nil { @@ -140,10 +137,7 @@ func _Filter_GenVector_Handler( } func _Filter_FilterVector_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Object_Vector) if err := dec(in); err != nil { diff --git a/apis/grpc/v1/mirror/mirror_vtproto.pb.go b/apis/grpc/v1/mirror/mirror_vtproto.pb.go index a6a0d6b6b0..4fd44fcf1b 100644 --- a/apis/grpc/v1/mirror/mirror_vtproto.pb.go +++ b/apis/grpc/v1/mirror/mirror_vtproto.pb.go @@ -97,10 +97,7 @@ func RegisterMirrorServer(s grpc.ServiceRegistrar, srv MirrorServer) { } func _Mirror_Register_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Mirror_Targets) if err := dec(in); err != nil { diff --git a/apis/grpc/v1/vald/filter_vtproto.pb.go b/apis/grpc/v1/vald/filter_vtproto.pb.go index c72529c391..a73d2576fd 100644 --- a/apis/grpc/v1/vald/filter_vtproto.pb.go +++ b/apis/grpc/v1/vald/filter_vtproto.pb.go @@ -397,10 +397,7 @@ func RegisterFilterServer(s grpc.ServiceRegistrar, srv FilterServer) { } func _Filter_SearchObject_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Search_ObjectRequest) if err := dec(in); err != nil { @@ -420,10 +417,7 @@ func _Filter_SearchObject_Handler( } func _Filter_MultiSearchObject_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Search_MultiObjectRequest) if err := dec(in); err != nil { @@ -469,10 +463,7 @@ func (x *filterStreamSearchObjectServer) Recv() (*payload.Search_ObjectRequest, } func _Filter_InsertObject_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Insert_ObjectRequest) if err := dec(in); err != nil { @@ -518,10 +509,7 @@ func (x *filterStreamInsertObjectServer) Recv() (*payload.Insert_ObjectRequest, } func _Filter_MultiInsertObject_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Insert_MultiObjectRequest) if err := dec(in); err != nil { @@ -541,10 +529,7 @@ func _Filter_MultiInsertObject_Handler( } func _Filter_UpdateObject_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Update_ObjectRequest) if err := dec(in); err != nil { @@ -590,10 +575,7 @@ func (x *filterStreamUpdateObjectServer) Recv() (*payload.Update_ObjectRequest, } func _Filter_MultiUpdateObject_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Update_MultiObjectRequest) if err := dec(in); err != nil { @@ -613,10 +595,7 @@ func _Filter_MultiUpdateObject_Handler( } func _Filter_UpsertObject_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Upsert_ObjectRequest) if err := dec(in); err != nil { @@ -662,10 +641,7 @@ func (x *filterStreamUpsertObjectServer) Recv() (*payload.Upsert_ObjectRequest, } func _Filter_MultiUpsertObject_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Upsert_MultiObjectRequest) if err := dec(in); err != nil { diff --git a/apis/grpc/v1/vald/flush_vtproto.pb.go b/apis/grpc/v1/vald/flush_vtproto.pb.go index 8d1e3abd52..29a8ac2a90 100644 --- a/apis/grpc/v1/vald/flush_vtproto.pb.go +++ b/apis/grpc/v1/vald/flush_vtproto.pb.go @@ -97,10 +97,7 @@ func RegisterFlushServer(s grpc.ServiceRegistrar, srv FlushServer) { } func _Flush_Flush_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Flush_Request) if err := dec(in); err != nil { diff --git a/apis/grpc/v1/vald/index_vtproto.pb.go b/apis/grpc/v1/vald/index_vtproto.pb.go index af982a7869..ae10c65015 100644 --- a/apis/grpc/v1/vald/index_vtproto.pb.go +++ b/apis/grpc/v1/vald/index_vtproto.pb.go @@ -117,10 +117,7 @@ func RegisterIndexServer(s grpc.ServiceRegistrar, srv IndexServer) { } func _Index_IndexInfo_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Empty) if err := dec(in); err != nil { @@ -140,10 +137,7 @@ func _Index_IndexInfo_Handler( } func _Index_IndexDetail_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Empty) if err := dec(in); err != nil { diff --git a/apis/grpc/v1/vald/insert_vtproto.pb.go b/apis/grpc/v1/vald/insert_vtproto.pb.go index 5c6880d481..4274c79f0a 100644 --- a/apis/grpc/v1/vald/insert_vtproto.pb.go +++ b/apis/grpc/v1/vald/insert_vtproto.pb.go @@ -157,10 +157,7 @@ func RegisterInsertServer(s grpc.ServiceRegistrar, srv InsertServer) { } func _Insert_Insert_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Insert_Request) if err := dec(in); err != nil { @@ -206,10 +203,7 @@ func (x *insertStreamInsertServer) Recv() (*payload.Insert_Request, error) { } func _Insert_MultiInsert_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Insert_MultiRequest) if err := dec(in); err != nil { diff --git a/apis/grpc/v1/vald/object_vtproto.pb.go b/apis/grpc/v1/vald/object_vtproto.pb.go index 9a5fb40c8c..d3beaa6dcd 100644 --- a/apis/grpc/v1/vald/object_vtproto.pb.go +++ b/apis/grpc/v1/vald/object_vtproto.pb.go @@ -220,10 +220,7 @@ func RegisterObjectServer(s grpc.ServiceRegistrar, srv ObjectServer) { } func _Object_Exists_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Object_ID) if err := dec(in); err != nil { @@ -243,10 +240,7 @@ func _Object_Exists_Handler( } func _Object_GetObject_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Object_VectorRequest) if err := dec(in); err != nil { @@ -313,10 +307,7 @@ func (x *objectStreamListObjectServer) Send(m *payload.Object_List_Response) err } func _Object_GetTimestamp_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Object_TimestampRequest) if err := dec(in); err != nil { diff --git a/apis/grpc/v1/vald/remove_vtproto.pb.go b/apis/grpc/v1/vald/remove_vtproto.pb.go index ac8c79e2e3..7a41f97a34 100644 --- a/apis/grpc/v1/vald/remove_vtproto.pb.go +++ b/apis/grpc/v1/vald/remove_vtproto.pb.go @@ -177,10 +177,7 @@ func RegisterRemoveServer(s grpc.ServiceRegistrar, srv RemoveServer) { } func _Remove_Remove_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Remove_Request) if err := dec(in); err != nil { @@ -200,10 +197,7 @@ func _Remove_Remove_Handler( } func _Remove_RemoveByTimestamp_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Remove_TimestampRequest) if err := dec(in); err != nil { @@ -249,10 +243,7 @@ func (x *removeStreamRemoveServer) Recv() (*payload.Remove_Request, error) { } func _Remove_MultiRemove_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Remove_MultiRequest) if err := dec(in); err != nil { diff --git a/apis/grpc/v1/vald/search_vtproto.pb.go b/apis/grpc/v1/vald/search_vtproto.pb.go index 5199716492..d161a299bc 100644 --- a/apis/grpc/v1/vald/search_vtproto.pb.go +++ b/apis/grpc/v1/vald/search_vtproto.pb.go @@ -401,10 +401,7 @@ func RegisterSearchServer(s grpc.ServiceRegistrar, srv SearchServer) { } func _Search_Search_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Search_Request) if err := dec(in); err != nil { @@ -424,10 +421,7 @@ func _Search_Search_Handler( } func _Search_SearchByID_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Search_IDRequest) if err := dec(in); err != nil { @@ -499,10 +493,7 @@ func (x *searchStreamSearchByIDServer) Recv() (*payload.Search_IDRequest, error) } func _Search_MultiSearch_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Search_MultiRequest) if err := dec(in); err != nil { @@ -522,10 +513,7 @@ func _Search_MultiSearch_Handler( } func _Search_MultiSearchByID_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Search_MultiIDRequest) if err := dec(in); err != nil { @@ -545,10 +533,7 @@ func _Search_MultiSearchByID_Handler( } func _Search_LinearSearch_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Search_Request) if err := dec(in); err != nil { @@ -568,10 +553,7 @@ func _Search_LinearSearch_Handler( } func _Search_LinearSearchByID_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Search_IDRequest) if err := dec(in); err != nil { @@ -643,10 +625,7 @@ func (x *searchStreamLinearSearchByIDServer) Recv() (*payload.Search_IDRequest, } func _Search_MultiLinearSearch_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Search_MultiRequest) if err := dec(in); err != nil { @@ -666,10 +645,7 @@ func _Search_MultiLinearSearch_Handler( } func _Search_MultiLinearSearchByID_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Search_MultiIDRequest) if err := dec(in); err != nil { diff --git a/apis/grpc/v1/vald/update_vtproto.pb.go b/apis/grpc/v1/vald/update_vtproto.pb.go index 7f8f6cae70..d29106eb95 100644 --- a/apis/grpc/v1/vald/update_vtproto.pb.go +++ b/apis/grpc/v1/vald/update_vtproto.pb.go @@ -157,10 +157,7 @@ func RegisterUpdateServer(s grpc.ServiceRegistrar, srv UpdateServer) { } func _Update_Update_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Update_Request) if err := dec(in); err != nil { @@ -206,10 +203,7 @@ func (x *updateStreamUpdateServer) Recv() (*payload.Update_Request, error) { } func _Update_MultiUpdate_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Update_MultiRequest) if err := dec(in); err != nil { diff --git a/apis/grpc/v1/vald/upsert_vtproto.pb.go b/apis/grpc/v1/vald/upsert_vtproto.pb.go index 0350e4520e..b5e846f1f3 100644 --- a/apis/grpc/v1/vald/upsert_vtproto.pb.go +++ b/apis/grpc/v1/vald/upsert_vtproto.pb.go @@ -157,10 +157,7 @@ func RegisterUpsertServer(s grpc.ServiceRegistrar, srv UpsertServer) { } func _Upsert_Upsert_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Upsert_Request) if err := dec(in); err != nil { @@ -206,10 +203,7 @@ func (x *upsertStreamUpsertServer) Recv() (*payload.Upsert_Request, error) { } func _Upsert_MultiUpsert_Handler( - srv any, - ctx context.Context, - dec func(any) error, - interceptor grpc.UnaryServerInterceptor, + srv any, ctx context.Context, dec func(any) error, interceptor grpc.UnaryServerInterceptor, ) (any, error) { in := new(payload.Upsert_MultiRequest) if err := dec(in); err != nil { diff --git a/dockers/agent/core/agent/Dockerfile b/dockers/agent/core/agent/Dockerfile index c13f258679..d3833ad073 100644 --- a/dockers/agent/core/agent/Dockerfile +++ b/dockers/agent/core/agent/Dockerfile @@ -36,8 +36,8 @@ ENV ORG=vdaas ENV PKG=agent/core/agent ENV REPO=vald ENV RUST_HOME=/usr/loacl/lib/rust -ENV RUSTUP_HOME=${RUST_HOME}/rustup ENV CARGO_HOME=${RUST_HOME}/cargo +ENV RUSTUP_HOME=${RUST_HOME}/rustup ENV PATH=${CARGO_HOME}/bin:${RUSTUP_HOME}/bin:/usr/local/bin:${PATH} SHELL ["/bin/bash", "-o", "pipefail", "-c"] diff --git a/dockers/ci/base/Dockerfile b/dockers/ci/base/Dockerfile index f85eb74fb6..f6e4aae0c6 100644 --- a/dockers/ci/base/Dockerfile +++ b/dockers/ci/base/Dockerfile @@ -39,8 +39,8 @@ ENV ORG=vdaas ENV PKG=ci/base ENV REPO=vald ENV RUST_HOME=/usr/loacl/lib/rust -ENV CARGO_HOME=${RUST_HOME}/cargo ENV RUSTUP_HOME=${RUST_HOME}/rustup +ENV CARGO_HOME=${RUST_HOME}/cargo ENV PATH=${CARGO_HOME}/bin:${GOPATH}/bin:${GOROOT}/bin:${RUSTUP_HOME}/bin:/usr/local/bin:${PATH} SHELL ["/bin/bash", "-o", "pipefail", "-c"] diff --git a/dockers/dev/Dockerfile b/dockers/dev/Dockerfile index 51daea42e8..d7409e637e 100644 --- a/dockers/dev/Dockerfile +++ b/dockers/dev/Dockerfile @@ -39,8 +39,8 @@ ENV ORG=vdaas ENV PKG=dev ENV REPO=vald ENV RUST_HOME=/usr/loacl/lib/rust -ENV CARGO_HOME=${RUST_HOME}/cargo ENV RUSTUP_HOME=${RUST_HOME}/rustup +ENV CARGO_HOME=${RUST_HOME}/cargo ENV PATH=${CARGO_HOME}/bin:${GOPATH}/bin:${GOROOT}/bin:${RUSTUP_HOME}/bin:/usr/local/bin:${PATH} SHELL ["/bin/bash", "-o", "pipefail", "-c"]