server/net/cluster/nats_cluster/const.go

package mhayaNatsCluster

import (
	"fmt"
)

const (
	remoteSubjectFormat = "mhaya.%s.remote.%s.%s" // nodeType.nodeId
	localSubjectFormat  = "mhaya.%s.local.%s.%s"  // nodeType.nodeId
)

// getLocalSubject local message nats chan
func getLocalSubject(prefix, nodeType, nodeId string) string {
	return fmt.Sprintf(localSubjectFormat, prefix, nodeType, nodeId)
}

// getRemoteSubject remote message nats chan
func getRemoteSubject(prefix, nodeType, nodeId string) string {
	return fmt.Sprintf(remoteSubjectFormat, prefix, nodeType, nodeId)
}