pass extraPodAnnotations everywhere

ytsaurus · Apr 2, 2024 · 374c322 · 374c322
1 parent 85b310e
commit 374c322
Show file tree

Hide file tree

Showing 8 changed files with 8 additions and 8 deletions.
diff --git a/pkg/components/controller_agent.go b/pkg/components/controller_agent.go
@@ -26,7 +26,7 @@ func NewControllerAgent(cfgen *ytconfig.Generator, ytsaurus *apiproxy.Ytsaurus,
 		&resource.ObjectMeta,
 		consts.ControllerAgentType,
 		consts.YTComponentLabelControllerAgent,
-		map[string]string{},
+		ytsaurus.GetCommonSpec().ExtraPodAnnotations,
 	)
 
 	if resource.Spec.ControllerAgents.InstanceSpec.MonitoringPort == nil {

diff --git a/pkg/components/data_node.go b/pkg/components/data_node.go
@@ -32,7 +32,7 @@ func NewDataNode(
 		consts.DataNodeType,
 		consts.YTComponentLabelDataNode,
 		spec.Name,
-		map[string]string{},
+		ytsaurus.GetCommonSpec().ExtraPodAnnotations,
 	)
 
 	if spec.InstanceSpec.MonitoringPort == nil {

diff --git a/pkg/components/discovery.go b/pkg/components/discovery.go
@@ -25,7 +25,7 @@ func NewDiscovery(cfgen *ytconfig.Generator, ytsaurus *apiproxy.Ytsaurus) *Disco
 		&resource.ObjectMeta,
 		consts.DiscoveryType,
 		consts.YTComponentLabelDiscovery,
-		map[string]string{},
+		ytsaurus.GetCommonSpec().ExtraPodAnnotations,
 	)
 
 	if resource.Spec.Discovery.InstanceSpec.MonitoringPort == nil {

diff --git a/pkg/components/exec_node.go b/pkg/components/exec_node.go
@@ -31,7 +31,7 @@ func NewExecNode(
 		consts.ExecNodeType,
 		consts.YTComponentLabelExecNode,
 		spec.Name,
-		map[string]string{},
+		ytsaurus.GetCommonSpec().ExtraPodAnnotations,
 	)
 
 	if spec.InstanceSpec.MonitoringPort == nil {

diff --git a/pkg/components/exec_node_remote.go b/pkg/components/exec_node_remote.go
@@ -29,7 +29,7 @@ func NewRemoteExecNodes(
 		consts.ExecNodeType,
 		consts.YTComponentLabelExecNode,
 		spec.Name,
-		map[string]string{},
+		commonSpec.ExtraPodAnnotations,
 	)
 	if spec.InstanceSpec.MonitoringPort == nil {
 		spec.InstanceSpec.MonitoringPort = ptr.Int32(consts.ExecNodeMonitoringPort)

diff --git a/pkg/components/httpproxy.go b/pkg/components/httpproxy.go
@@ -40,7 +40,7 @@ func NewHTTPProxy(
 		consts.HttpProxyType,
 		consts.YTComponentLabelHTTPProxy,
 		spec.Role,
-		map[string]string{},
+		ytsaurus.GetCommonSpec().ExtraPodAnnotations,
 	)
 
 	if spec.InstanceSpec.MonitoringPort == nil {

diff --git a/pkg/components/rpcproxy.go b/pkg/components/rpcproxy.go
@@ -37,7 +37,7 @@ func NewRPCProxy(
 		consts.RpcProxyType,
 		consts.YTComponentLabelRPCProxy,
 		spec.Role,
-		map[string]string{},
+		ytsaurus.GetCommonSpec().ExtraPodAnnotations,
 	)
 
 	if spec.InstanceSpec.MonitoringPort == nil {

diff --git a/pkg/components/tcpproxy.go b/pkg/components/tcpproxy.go
@@ -36,7 +36,7 @@ func NewTCPProxy(
 		consts.TcpProxyType,
 		consts.YTComponentLabelTCPProxy,
 		spec.Role,
-		map[string]string{},
+		ytsaurus.GetCommonSpec().ExtraPodAnnotations,
 	)
 
 	if spec.InstanceSpec.MonitoringPort == nil {