input.proto
input_service.proto
source/
stream/