Skip to content

Commit

Permalink
refactoring code
Browse files Browse the repository at this point in the history
Signed-off-by: Victor Login <[email protected]>
  • Loading branch information
batazor committed Oct 25, 2023
1 parent 5c61e82 commit 113c56f
Show file tree
Hide file tree
Showing 6 changed files with 1,047 additions and 5,250 deletions.
1 change: 1 addition & 0 deletions internal/di/default.go
Original file line number Diff line number Diff line change
Expand Up @@ -102,6 +102,7 @@ func NewFullService(
pprofHTTP profiling.PprofEndpoint,
autoMaxProcsOption autoMaxPro.AutoMaxPro,
) (*Service, error) {

return &Service{
// Common
Ctx: ctx,
Expand Down
1 change: 0 additions & 1 deletion internal/pkg/rpc/middleware/logger/client_interceptors.go
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,6 @@ func StreamClientInterceptor(log logger.Logger) grpc.StreamClientInterceptor {
streamer grpc.Streamer,
opts ...grpc.CallOption,
) (grpc.ClientStream, error) {

clientStream, err := streamer(ctx, desc, cc, method, opts...)
fields := field.Fields{
"grpc.service": path.Dir(method)[1:],
Expand Down
2 changes: 0 additions & 2 deletions internal/pkg/rpc/middleware/session/client_interceptors.go
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,6 @@ func SessionUnaryInterceptor() grpc.UnaryClientInterceptor {
invoker grpc.UnaryInvoker,
opts ...grpc.CallOption,
) (err error) {

sess := session.GetSession(ctx)

ctx = metadata.AppendToOutgoingContext(ctx, "user-id", sess.GetId())
Expand All @@ -39,7 +38,6 @@ func SessionStreamInterceptor() grpc.StreamClientInterceptor {
streamer grpc.Streamer,
opts ...grpc.CallOption,
) (grpc.ClientStream, error) {

sess := session.GetSession(ctx)

ctx = metadata.AppendToOutgoingContext(ctx, "user-id", sess.GetId())
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -43,6 +43,7 @@ func (api *API) Run(
paymentService *payment_application.PaymentService,
tariffService *tariff_application.TariffService,
) error {

api.ctx = ctx
api.jsonpb = protojson.MarshalOptions{
UseProtoNames: true,
Expand Down
9 changes: 7 additions & 2 deletions ops/Helm/addons/security/kubescape/values.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -5,8 +5,10 @@
kubescape:
enabled: true

labels:
release: prometheus-operator
global:
networkPolicy:
enabled: true
createEgressRules: true

capabilities:
networkGenerator: enable
Expand All @@ -17,6 +19,9 @@ kubescape:
clusterName: shortlink

kubescape:
labels:
release: prometheus-operator

serviceMonitor:
enabled: true

Expand Down
Loading

0 comments on commit 113c56f

Please sign in to comment.