func()

in collector/collector.go [63:75]


func (ms messageStore) target(target string, QosDSCPIndex uint8) *srcPortScopedMessageStore {
	// TODO: validate dscp is in range or create a dscp type alias
	if _, exists := ms[target]; !exists {
		ms[target] = new([defines.NumQOSDCSPValues]srcPortScopedMessageStore)
	}
	if ms[target][QosDSCPIndex].sent == nil {
		ms[target][QosDSCPIndex].sent = make(srcPortScopedMessages)
	}
	if ms[target][QosDSCPIndex].rcvd == nil {
		ms[target][QosDSCPIndex].rcvd = make(srcPortScopedMessages)
	}
	return &ms[target][QosDSCPIndex]
}