hstream
HStreamDB is an open-source, cloud-native streaming database for IoT and beyond. Modernize your data stack for real-time applications.
File Explorer
Download Latest Version (.zip)- bug_report.md
- feature_request.md
- ci.yml
- publish.yml
- publish_latest.yml
- CODEOWNERS
- CONTRIBUTING.md
- pull_request_template.md
- fake_server.cpp
- Makefile
- AdminClient.cpp
- AdminClient.h
- hstream-client-cpp.cabal
- hstream-api-cpp.cabal
- Protobuf.hs
- ProtoTypes.proto
- HStreamGossip.proto
- HStreamApi.proto
- HStreamInternal.proto
- hstream-api-hs.cabal
- Setup.hs
- fatalsignal.cpp
- hs_struct.cpp
- hs_utils.cpp
- Ansi.hs
- Bytes.hs
- Concurrent.hs
- Growing.hs
- Table.hs
- Time.hs
- Timer.hs
- Base.hs
- Foreign.hs
- Logger.hs
- LoggerOld.hs
- hs_common.h
- hs_cpp_lib.h
- BaseSpec.hs
- LoggerSpec.hs
- Spec.hs
- hstream-common-base.cabal
- LICENSE
- Bench.hs
- CodecBench.hs
- CompresstionBench.hs
- Util.hs
- AdminCommandTable.cpp
- AdminCommandTable.h
- Table.h
- checks.h
- hash.cpp
- hs_zookeeper_client.cpp
- query.cpp
- CliParsers.hs
- ConsistentHashing.hs
- GrpcHaskell.hs
- Query.hs
- Types.hs
- ZookeeperClient.hs
- ZookeeperSlotAlloc.hs
- FileUtils.hs
- RqliteUtils.hs
- Types.hs
- ZookeeperUtils.hs
- Aeson.hs
- BuildRecord.hs
- Codec.hs
- Common.hs
- Compression.hs
- Converter.hs
- Format.hs
- JSON.hs
- RPC.hs
- Time.hs
- Validation.hs
- Exception.hs
- Instances.hs
- Utils.hs
- hs_common.h
- hs_cpp_lib.h
- CodecSpec.hs
- ConsistentHashingSpec.hs
- ExceptionSpec.hs
- MetaStoreSpec.hs
- RqliteUtilsSpec.hs
- TestUtils.hs
- UtilsSpec.hs
- ValidationSpec.hs
- ZookeeperSlotAllocSpec.hs
- Spec.hs
- hstream-common.cabal
- LICENSE
- Setup.hs
- Values.hs
- HashRing.hs
- Lookup.hs
- MetaData.hs
- Shard.hs
- TaskManager.hs
- Types.hs
- ShardSpec.hs
- Spec.hs
- hstream-common-server.cabal
- LICENSE
- stats.hs
- ServerHistograms.h
- Stats.cpp
- Stats.h
- hs_stats.cpp
- Internal.hs
- Stats.hs
- hs_stats.h
- per_cache_store_stats.inc
- per_connector_stats.inc
- per_handle_time_series.inc
- per_query_stats.inc
- per_stream_stats.inc
- per_stream_time_series.inc
- per_subscription_stats.inc
- per_subscription_time_series.inc
- per_view_stats.inc
- StatsSpec.hs
- StatsSpecUtils.hs
- Spec.hs
- hstream-common-stats.cabal
- LICENSE
- Setup.hs
- hstream.yaml
- openssl.cnf
- _helpers.tpl
- hstream.yaml
- jobs.yaml
- logdevice-admin.yaml
- logdevice-config.yaml
- logdevice.yaml
- NOTES.txt
- .helmignore
- Chart.lock
- Chart.yaml
- README.md
- values.yaml
- hstream-server.yaml
- jobs.yaml
- kustomization.yaml
- config.json
- jobs.yaml
- kustomization.yaml
- logdevice-admin-server.yaml
- logdevice-service.yaml
- logdevice-statefulset.yaml
- kustomization.yaml
- docker-compose.yaml
- Dockerfile
- logdevice.json
- quick-start.yaml
- gRPC-haskell
- gsasl-hs
- haskell-rocksdb-bindings
- hs-grpc
- hsthrift
- proto3-suite
- proto3-wire
- protocol
- KafkaServer.hs
- client.hs
- kafka-client.hs
- server.hs
- Action.hs
- Execute.hs
- Internal.hs
- SQL.hs
- SQLNew.hs
- Types.hs
- Utils.hs
- Cli.hs
- Cluster.hs
- Common.hs
- Query.hs
- QueryNew.hs
- ShardReader.hs
- Stream.hs
- Subscription.hs
- View.hs
- ViewNew.hs
- StreamV2.hs
- Admin.hs
- Cluster.hs
- Common.hs
- Connector.hs
- Extra.hs
- Query.hs
- Schema.hs
- ShardReader.hs
- Stats.hs
- Stream.hs
- Subscription.hs
- View.hs
- Exception.hs
- Types.hs
- Utils.hs
- Value.hs
- CacheStore.hs
- Config.hs
- ConnectorTypes.hs
- Exception.hs
- Experimental.hs
- Handler.hs
- HealthMonitor.hs
- HsGrpcHandler.hs
- HStore.hs
- Initialization.hs
- MetaData.hs
- QueryWorker.hs
- Types.hs
- Validation.hs
- RawString.hs
- AckSpec.hs
- AdminCommandSpec.hs
- ConfigSpec.hs
- HandlerSpec.hs
- RegressionNewSpec.hs
- RegressionSpec.hs
- RunQuerySpec.hs
- RunSQLNewSpec.hs
- RunSQLSpec.hs
- SpecUtils.hs
- StatsIntegrationSpec.hs
- Spec.hs
- hstream.cabal
- LICENSE
- Setup.hs
- admin.hs
- examples.sql
- AppendFailedCounter.h
- AppendThroughput.h
- AppendTotalCounter.h
- ReadThroughput.h
- ServerAppendLatency.h
- ServerAppendRequestLatency.h
- Streams.h
- SubscriptionThroughput.h
- Query.cpp
- Query.h
- hs_query.cpp
- ServerSql.hs
- Command.hs
- Types.hs
- hstream-admin-server.cabal
- LICENSE
- hadmin-store.hs
- AdminCommand.hs
- CheckImpact.hs
- Config.hs
- Connect.hs
- Logs.hs
- Maintenance.hs
- NodesConfig.hs
- SQL.hs
- Status.hs
- API.hs
- Cli.hs
- Command.hs
- Types.hs
- fb303.thrift
- admin.thrift
- admin_commands.thrift
- cluster_membership.thrift
- exceptions.thrift
- logtree.thrift
- maintenance.thrift
- nodes.thrift
- safety.thrift
- settings.thrift
- common.thrift
- Membership.thrift
- hstream-admin-store.cabal
- LICENSE
- hstream-admin.cabal
- benchmark.hs
- throughout-join.hs
- throughout-map.hs
- throughout-reduce.hs
- Distinct.hs
- Loop.hs
- Main.hs
- Reduce.hs
- Error.hs
- Graph.hs
- Shard.hs
- Types.hs
- Weird.hs
- LoopSpec.hs
- TypesSpec.hs
- Spec.hs
- CHANGELOG.md
- diff-flow.cabal
- LICENSE
- Types.hs
- Handlers.hs
- Gossip.hs
- Handlers.hs
- Probe.hs
- Reconnect.hs
- Start.hs
- Types.hs
- Utils.hs
- Worker.hs
- Gossip.hs
- CHANGELOG.md
- hstream-gossip.cabal
- IOTask.hs
- LineReader.hs
- Messages.hs
- Meta.hs
- Types.hs
- Worker.hs
- hstream-io.cabal
- LICENSE
- Setup.hs
- hs_kafka_client.cpp
- hs_kafka_server.cpp
- asio
- Api.hs
- Cli.hs
- Class.hs
- ConsumeStats.hs
- ProduceStats.hs
- ServerStats.hs
- Acl.hs
- AclEntry.hs
- AclStore.hs
- AdminCli.hs
- Authorizer.hs
- FetchManager.hs
- KafkaException.hs
- Metrics.hs
- OffsetManager.hs
- Read.hs
- RecordFormat.hs
- Resource.hs
- Security.hs
- Utils.hs
- Group.hs
- GroupCoordinator.hs
- GroupOffsetManager.hs
- Member.hs
- OffsetsStore.hs
- Cxx.hsc
- IO.hs
- Security.hs
- FromCli.hs
- FromJson.hs
- KafkaConfig.hs
- KafkaConfigManager.hs
- Types.hs
- Topic.hs
- Consume.hs
- Offset.hs
- Produce.hs
- AdminCommand.hs
- Basic.hs
- Consume.hs
- Group.hs
- Offset.hs
- Produce.hs
- Security.hs
- Topic.hs
- SASL.hs
- Config.hs
- Handler.hsc
- MetaData.hs
- Types.hs
- Network.hs
- hs_kafka_server.h
- HadminCommandRequest.json
- HadminCommandResponse.json
- ApiVersionsRequest.json
- ApiVersionsResponse.json
- CreateAclsRequest.json
- CreateAclsResponse.json
- CreatePartitionsRequest.json
- CreatePartitionsResponse.json
- CreateTopicsRequest.json
- CreateTopicsResponse.json
- DeleteAclsRequest.json
- DeleteAclsResponse.json
- DeleteTopicsRequest.json
- DeleteTopicsResponse.json
- DescribeAclsRequest.json
- DescribeAclsResponse.json
- DescribeConfigsRequest.json
- DescribeConfigsResponse.json
- DescribeGroupsRequest.json
- DescribeGroupsResponse.json
- FetchRequest.json
- FetchResponse.json
- FindCoordinatorRequest.json
- FindCoordinatorResponse.json
- HeartbeatRequest.json
- HeartbeatResponse.json
- InitProducerIdRequest.json
- InitProducerIdResponse.json
- JoinGroupRequest.json
- JoinGroupResponse.json
- LeaveGroupRequest.json
- LeaveGroupResponse.json
- ListGroupsRequest.json
- ListGroupsResponse.json
- ListOffsetsRequest.json
- ListOffsetsResponse.json
- MetadataRequest.json
- MetadataResponse.json
- OffsetCommitRequest.json
- OffsetCommitResponse.json
- OffsetFetchRequest.json
- OffsetFetchResponse.json
- ProduceRequest.json
- ProduceResponse.json
- README.md
- SaslAuthenticateRequest.json
- SaslAuthenticateResponse.json
- SaslHandshakeRequest.json
- SaslHandshakeResponse.json
- SyncGroupRequest.json
- SyncGroupResponse.json
- Encoding.hs
- gen_data.py
- Encode.hs
- Internal.hs
- Parser.hs
- Types.hs
- Struct.hs
- Total.hs
- Encoding.hs
- Error.hs
- Message.hs
- Service.hs
- Protocol.hs
- EncodingSpec.hs
- Instances.hs
- Spec.hs
- README.md
- Logdevice.hs
- Storage.hs
- docker-compose.yaml
- requirements.txt
- common.py
- conftest.py
- test_basic.py
- test_consumer.py
- AclEntrySpec.hs
- AclSpec.hs
- AuthorizerSpec.hs
- ConfigSpec.hs
- OffsetManagerSpec.hs
- TestUtils.hs
- Spec.hs
- hstream-kafka.cabal
- LICENSE
- README.md
- ProcessorExample0.hs
- ProcessorExample1.hs
- StreamExample0.hs
- StreamExample1.hs
- StreamExample2.hs
- StreamExample3.hs
- StreamExample4.hs
- StreamExample5.hs
- ChangeLog.hs
- Internal.hs
- Snapshot.hs
- GroupedStream.hs
- Internal.hs
- JoinWindows.hs
- SessionWindowedStream.hs
- SessionWindows.hs
- TimeWindowedStream.hs
- TimeWindows.hs
- Connector.hs
- Encoding.hs
- Error.hs
- MockStreamStore.hs
- Processor.hs
- Store.hs
- Stream.hs
- Table.hs
- Type.hs
- Util.hs
- .stylish-haskell.yaml
- hstream-processing.cabal
- LICENSE
- README.md
- Setup.hs
- stack.yaml
- Lib.hs
- PlanTestRunner.hs
- SyntaxTestRunner.hs
- eitherResIdent
- plan-test-cases.yaml
- SQL-v1.cf
- SQL-v2.cf
- syntax-test-cases.yaml
- Basic.hs
- Common.hs
- DDL.hs
- DML.hs
- Operator.hs
- Select.hs
- SQL.hs
- ValueExpr.hs
- Boilerplate.hs
- Boilerplate.hs
- AggOp.hs
- BinOp.hs
- Cast.hs
- ColumnCatalog.hs
- ColumnCatalogNew.hs
- Common.hs
- CommonNew.hs
- JsonOp.hs
- TerOp.hs
- UnaryOp.hs
- Utils.hs
- V1.hs
- V1New.hs
- V2.hs
- Check.hs
- Validate.hs
- Pretty.hs
- Expr.hs
- Extra.hs
- Pretty.hs
- Types.hs
- New.hs
- Old.hs
- Utils.hs
- AST.hs
- Binder.hs
- Exception.hs
- Extra.hs
- Parse.hs
- ParseNew.hs
- Planner.hs
- PlannerNew.hs
- Preprocess.hs
- Rts.hs
- SQL.hs
- ArraySpec.hs
- MathSpec.hs
- ParseRefineSpec.hs
- ValidateSpec.hs
- Spec.hs
- ChangeLog.md
- hstream-sql.cabal
- LICENSE
- README.md
- writeBench.hs
- AppendBatchBench.hs
- AppendBench.hs
- checkpoint_store.cpp
- create_log_config_types.cpp
- LogExtraAttrs.hs
- SortBench.hs
- StreamBench.hs
- hs_checkpoint.cpp
- hs_ldquery.cpp
- hs_log_attributes.cpp
- hs_logconfigtypes.cpp
- hs_reader.cpp
- hs_versioned_config_store.cpp
- hs_writer.cpp
- ld_configuration.cpp
- ld_health_checker.cpp
- hs_logdevice.cpp
- utils.cpp
- Checkpoint.hs
- Configuration.hs
- HealthCheck.hs
- LDQuery.hs
- LogAttributes.hs
- LogConfigTypes.hs
- Reader.hs
- VersionedConfigStore.hs
- Writer.hs
- Foreign.hs
- LogDevice.hs
- Types.hsc
- Exception.hs
- Logger.hs
- Stream.hs
- Store.hs
- ghc_ext.h
- hs_logdevice.h
- CheckpointStoreSpec.hs
- LogDeviceSpec.hs
- ReaderSpec.hs
- SettingsSpec.hs
- SpecUtils.hs
- StreamSpec.hs
- WriterSpec.hs
- StoreSpec.hs
- Spec.hs
- ChangeLog.md
- hstream-store.cabal
- LICENSE
- README.md
- Setup.hs
- dashboard.yml
- hstream_simple.json
- datasource.yml
- cluster.yml
- disks.yml
- memory_cpus.yml
- net.yml
- prometheus.yml
- zk.yml
- dev-deploy
- dev-tools
- dev_deploy_conf_example.json
- format.sh
- kafka_gen.py
- start-server.sh
- wait-for-storage.sh
- .clang-format
- .dockerignore
- .gitignore
- .gitmodules
- .hlint.yaml
- .stylish-haskell.yaml
- cabal.project
- cabal.project.hadmin.store
- ChangeLog.md
- CODE_OF_CONDUCT
- LICENSE
- LICENSE.logdevice
- Makefile
- README.md
π Installation Guide
1. Get the code
git clone https://github.com/hstreamdb/hstream
Downloads the entire project code from GitHub to your computer.
cd hstream
Moves into the project folder you just downloaded.
2. Docker
Easy RecommendedPrerequisites
- Git Needed to download the project code from GitHub.
- Docker Desktop Needed to build and run containers. Install it and keep it running in the background.
docker compose -f docker/docker-compose.yaml up -d --build
Runs the command against the services defined in the compose file.
Run docker compose ps to check the containers are Up. If the README mentions a port, open http://localhost:PORT in your browser.
3. Make
MediumPrerequisites
- Git Needed to download the project code from GitHub.
- Make Usually pre-installed on Linux/macOS. On Windows, install separately (e.g. via MSYS2 or WSL).
make
Compiles the code based on the generated build configuration to produce an executable.
If it finishes without errors, it worked. Try running the generated executable directly.
// repository documentation
Was this content helpful?
(0 ratings)