Skip to content

Commit e10d53d

Browse files
authored
Merge pull request #359 from devtron-labs/gpu-topic
chore: gpu installation topic
2 parents c734a68 + b4a32fc commit e10d53d

1 file changed

Lines changed: 5 additions & 0 deletions

File tree

common-lib/pubsub-lib/JetStreamUtil.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -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

132135
type 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

188192
var 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

Comments
 (0)