Skip to content

Commit

Permalink
added getter for vars
Browse files Browse the repository at this point in the history
  • Loading branch information
hellt committed Jul 9, 2021
1 parent 57e1cb4 commit d2f7473
Show file tree
Hide file tree
Showing 3 changed files with 12 additions and 5 deletions.
4 changes: 2 additions & 2 deletions types/node_definition.go
Original file line number Diff line number Diff line change
Expand Up @@ -65,8 +65,8 @@ func (n *NodeDefinition) GetStartupConfig() string {
}

func (n *NodeDefinition) GetConfigDispatcher() *ConfigDispatcher {
if n == nil || n.Config == nil {
return &ConfigDispatcher{}
if n == nil {
return nil
}
return n.Config
}
Expand Down
6 changes: 3 additions & 3 deletions types/topology.go
Original file line number Diff line number Diff line change
Expand Up @@ -138,9 +138,9 @@ func (t *Topology) GetNodeLabels(name string) map[string]string {
func (t *Topology) GetNodeConfigDispatcher(name string) *ConfigDispatcher {
if ndef, ok := t.Nodes[name]; ok {
vars := utils.MergeStringMaps(
utils.MergeStringMaps(t.Defaults.GetConfigDispatcher().Vars,
t.GetKind(t.GetNodeKind(name)).GetConfigDispatcher().Vars),
ndef.GetConfigDispatcher().Vars)
utils.MergeStringMaps(t.Defaults.GetConfigDispatcher().GetVars(),
t.GetKind(t.GetNodeKind(name)).GetConfigDispatcher().GetVars()),
ndef.GetConfigDispatcher().GetVars())

return &ConfigDispatcher{
Vars: vars,
Expand Down
7 changes: 7 additions & 0 deletions types/types.go
Original file line number Diff line number Diff line change
Expand Up @@ -211,3 +211,10 @@ func FilterFromLabelStrings(labels []string) []*GenericFilter {
type ConfigDispatcher struct {
Vars map[string]string `yaml:"vars,omitempty"`
}

func (cd *ConfigDispatcher) GetVars() map[string]string {
if cd == nil {
return nil
}
return cd.Vars
}

0 comments on commit d2f7473

Please sign in to comment.