Fix import errors in cluster package.
Add input observer and collector implementations.