| .gitignore | |
|
|
| .rubocop.yml | |
|
|
| .ruby-version | |
|
|
| .travis.yml | |
|
|
| CODE_OF_CONDUCT.md | |
|
|
| Dockerfile | |
|
|
| Gemfile | |
|
|
| Gemfile.lock | |
|
|
| Guardfile | |
|
|
| LICENSE.txt | |
|
|
| README.md | |
|
|
| Rakefile | |
|
|
| bin/console | |
|
|
| bin/setup | |
|
|
| docker-compose.yml | |
|
|
| examples/example1/data.csv | |
|
|
| examples/example1/example.rb | 18 | A 0 mins |
|
| examples/example1/sb_config.yml | |
|
|
| lib/streamer.rb | 8 | A 0 mins |
|
| lib/streamer/fact_providers.rb | 11 | A 0 mins |
|
| lib/streamer/fact_providers/csv_provider.rb | 41 | A 0 mins |
|
| lib/streamer/fact_providers/hash_provider.rb | 15 | A 0 mins |
|
| lib/streamer/fact_providers/yaml_provider.rb | 23 | A 0 mins |
|
| lib/streamer/finder.rb | 11 | A 0 mins |
|
| lib/streamer/functors.rb | 21 | A 0 mins |
|
| lib/streamer/functors/average.rb | 22 | A 0 mins |
|
| lib/streamer/functors/count.rb | 9 | A 0 mins |
|
| lib/streamer/functors/divide.rb | 15 | A 0 mins |
|
| lib/streamer/functors/eq.rb | 9 | A 0 mins |
|
| lib/streamer/functors/functor.rb | 86 | A 2 hrs |
|
| lib/streamer/functors/group.rb | 24 | A 0 mins |
|
| lib/streamer/functors/gt.rb | 9 | A 0 mins |
|
| lib/streamer/functors/gte.rb | 9 | A 0 mins |
|
| lib/streamer/functors/least.rb | 12 | A 0 mins |
|
| lib/streamer/functors/list_filter.rb | 22 | A 0 mins |
|
| lib/streamer/functors/lookup.rb | 14 | A 0 mins |
|
| lib/streamer/functors/lt.rb | 9 | A 0 mins |
|
| lib/streamer/functors/lte.rb | 9 | A 0 mins |
|
| lib/streamer/functors/member.rb | 15 | A 0 mins |
|
| lib/streamer/functors/multiply.rb | 19 | A 55 mins |
|
| lib/streamer/functors/subtract.rb | 16 | A 0 mins |
|
| lib/streamer/functors/sum.rb | 11 | A 0 mins |
|
| lib/streamer/stream.rb | 54 | A 1 hr |
|
| lib/streamer/stream_builder.rb | 30 | A 0 mins |
|
| lib/streamer/version.rb | 3 | A 0 mins |
|
| streamer.gemspec | |
|
|