@@ -127,6 +127,9 @@ const (
127127 COST_MODULE_INSTALLATION_TOPIC string = "COST_MODULE_INSTALLATION_TOPIC"
128128 COST_MODULE_INSTALLATION_GROUP string = "COST_MODULE_INSTALLATION_GROUP"
129129 COST_MODULE_INSTALLATION_DURABLE string = "COST_MODULE_INSTALLATION_DURABLE"
130+ COST_MODULE_GPU_INSTALLATION_TOPIC string = "COST_MODULE_GPU_INSTALLATION_TOPIC"
131+ COST_MODULE_GPU_INSTALLATION_GROUP string = "COST_MODULE_GPU_INSTALLATION_GROUP"
132+ COST_MODULE_GPU_INSTALLATION_DURABLE string = "COST_MODULE_GPU_INSTALLATION_DURABLE"
130133)
131134
132135type NatsTopic struct {
@@ -183,6 +186,7 @@ var natsTopicMapping = map[string]NatsTopic{
183186 INFRASTRACTURE_INSTALLATION_DELETE_SUCCESS_TOPIC : {topicName : INFRASTRACTURE_INSTALLATION_DELETE_SUCCESS_TOPIC , streamName : ORCHESTRATOR_STREAM , queueName : INFRASTRACTURE_INSTALLATION_DELETE_SUCCESS_GROUP , consumerName : INFRASTRACTURE_INSTALLATION_DELETE_SUCCESS_DURABLE },
184187 INFRA_HELM_RELEASE_ACTION_TOPIC : {topicName : INFRA_HELM_RELEASE_ACTION_TOPIC , streamName : ORCHESTRATOR_STREAM , queueName : INFRA_HELM_RELEASE_ACTION_GROUP , consumerName : INFRA_HELM_RELEASE_ACTION_DURABLE },
185188 COST_MODULE_INSTALLATION_TOPIC : {topicName : COST_MODULE_INSTALLATION_TOPIC , streamName : ORCHESTRATOR_STREAM , queueName : COST_MODULE_INSTALLATION_GROUP , consumerName : COST_MODULE_INSTALLATION_DURABLE },
189+ COST_MODULE_GPU_INSTALLATION_TOPIC : {topicName : COST_MODULE_GPU_INSTALLATION_TOPIC , streamName : ORCHESTRATOR_STREAM , queueName : COST_MODULE_GPU_INSTALLATION_GROUP , consumerName : COST_MODULE_GPU_INSTALLATION_DURABLE },
186190}
187191
188192var NatsStreamWiseConfigMapping = map [string ]NatsStreamConfig {
@@ -226,6 +230,7 @@ var NatsConsumerWiseConfigMapping = map[string]NatsConsumerConfig{
226230 INFRASTRACTURE_INSTALLATION_DELETE_SUCCESS_DURABLE : {},
227231 INFRA_HELM_RELEASE_ACTION_DURABLE : {},
228232 COST_MODULE_INSTALLATION_DURABLE : {},
233+ COST_MODULE_GPU_INSTALLATION_DURABLE : {},
229234}
230235
231236// getConsumerConfigMap will fetch the consumer wise config from the json string
0 commit comments