Ecosyste.ms: OpenCollective
An open API service for software projects hosted on Open Collective.
github.com/commanded/eventstore
Event store using PostgreSQL for persistence
https://github.com/commanded/eventstore
368af27e3c2676e60da13c1214bf300d7b869000 authored over 6 years ago
792a4a19ea255eaeebeea864729c75239a227bfd authored over 6 years ago
By using Postgres' anonymous code blocks to execute multiple migration statements in one query.
18c2d8b4e79cd2392715f431dce4686042f83bd4 authored over 6 years agoAdd Ole Michaelis to contributors section in README.
44cf448484018246fbb86ac495e416025bd17433 authored over 6 years ago8a4709676940ed74c771cb89eef1c8633634c0de authored over 6 years ago
This removes the run_with_psql completely.
0cee173e8083b9cea423a887fd0bcc0538c729b5 authored over 6 years agoAdd Ole Michaelis to contributors section in README.
7f06796aa2412c8a021fcbb2ac7b12fe6bb7149d authored over 6 years agoAllow callers to omit `event_type` when event data is a struct
ad6bc17f8d94476deeda8f149f7d90a1d6e0ba23 authored over 6 years ago1f9e386d0fcb7553dc7a963d268f3447439c98f1 authored over 6 years ago
This is a first commit to lower the dependency on psql. It shamelessly
uses code from Ecto Postg...
2aadc34d0dfc86b113074dc0fd25fdfde9bc418c authored over 6 years ago
Support system environment variables for all config
8c744e8ddc77ab5c01bda044b3822fedf0eaaece authored over 6 years agoSubscripton event filtering
4ea018573f5e140282cc010470c72c7e04ccad74 authored over 6 years ago33179a455ad990f79f69c0e68c55f0a2f8d03d8c authored over 6 years ago
Add failing test for subscription selector function. Subscriptions will wait until the last even...
ca762bd22a7c5bd2d05e3395e057149edcee48d5 authored over 6 years agoSubscriptions will wait until the last event sent to the subscriber has been successfully acknow...
8f5b0958afe6e84eaab86f8d2afde1968ca81a9e authored almost 7 years agoInitial proposal for event filtering
7d367663a90edb3b4fe99efdde31478507554917 authored almost 7 years agob1d61450001b9e5b86ac72af64659ef7a82ffa9b authored almost 7 years ago
b569028c5364ef956e79df792db4fd1516eada0c authored almost 7 years ago
fa4ab8ae500fb0e53e59275bf02cbcbb65a36c91 authored almost 7 years ago
5e64f429d91c35d315315b142bf62d7bdd06fa35 authored almost 7 years ago
9de37f785382404723aebfbe51cd6d566ba5589e authored almost 7 years ago
e99d5d0699b8b9bf4bfec274e2e969a43018ff59 authored almost 7 years ago
Turn EventStore mix tasks into generic tasks for use with Distillery
9696dba7f29b0f0f54a1e739667e5b6b61c5e55c authored almost 7 years ago
Intentionally did not try and address using Ecto for migrations, as I
did not want to introduce ...
0055eebf388dc5e84fa797506584d65c8b87bd6f authored almost 7 years ago
e8f4775620adaf80816fae388f0f0637292a5501 authored almost 7 years ago
7703cf68e80ff795df46c3472f9c2aba83094344 authored almost 7 years ago
9b2afc1592aa3f6f45ed4ebd06a6fe4d615146ff authored almost 7 years ago
d96e0172053343105fb599ae3c265b1b645c08d4 authored almost 7 years ago
Advisory locks use single database connection
2bbb0fd3c7472f85d17e8350756e80ed50a66c59 authored almost 7 years agoRevert subscriptions to use Postgrex connection pool for all storage access.
Add a short delay ...
ee90f2a2c595e8700e35f50883e186e8328403c2 authored almost 7 years ago4e6296bf93a844a5d8d722a44d333ac6a4fb6014 authored almost 7 years ago
Immediately subscribe to stream events once subscription successfully created.
39cade62be0aa80664f570b1138e9e4c82d3def5 authored almost 7 years ago85d8d90ff11b1997df530ae2083824de10ef6095 authored almost 7 years ago
8a6169a115e0a6a835eca195be2a2700bad08e85 authored almost 7 years ago
Use default Postgrex config to reset storage for benchmark suite.
6bfa698e1cbf4e2fda6a63f23ec05e879070ba1f authored almost 7 years agoTransient subscription event mapping function
0715ede18874dab14ab0f38978ec72c2fe9ea77e authored almost 7 years ago5de99ce2c0b153b00f1a5bd243da46f487edd9c3 authored almost 7 years ago
Use a single Postgres connection for all subscriptions
5a73f7cc58a48d120491ed5fc66126852b275df9 authored almost 7 years ago6e7ee3f3a024adb5ae13ff7078829808a6acbb73 authored almost 7 years ago
f0d420353201150f6d521bfd79202b1eb6da0ec3 authored almost 7 years ago
361eefcd25649075bbdac1cf15f14230219833b9 authored almost 7 years ago
969b6127add346a1cc9db02b5aff2a0034533913 authored almost 7 years ago
Monitor Postgrex connection used for subscriptions. Attempt to reconnect on error and force any ...
7fe6de312cdd0c6749f06b8b8615c0b3e199d235 authored almost 7 years ago4b5d4dcf1059dac80643cf16f71216d8094339a8 authored almost 7 years ago
ec57ddf80bd6dc341a3c4450f020069926868a1f authored almost 7 years ago
f7780536c6e5f1ca63c05863a57c1ddd00f7635f authored almost 7 years ago
A single connection, with no pooling, is used by subscriptions to allow session based Postgres a...
571ab7ba6348ae2174972acd9d90bb2ee84737e4 authored almost 7 years agoFixes #107.
f5056b4ba7070a20958bdb02aef77f33ae881965 authored almost 7 years agoe01036c523b59de636f42880d93f0502587a342f authored almost 7 years ago
Transient subscriptions
5bfd50416d50456ea783ccf7d2afc7a8d7e30f37 authored almost 7 years agoAdd `EventStore.subscribe/1` to create a transient subscription to events appended to a given st...
ae6037b2120c1ca70ae31de03c8cb81ff21a3274 authored almost 7 years agoTest usage of PostgreSQL's `LISTEN` / `NOTIFY` for long running subscription processes.
Starts ...
3434ce6b810bded944737db32fa78aaeb188d298 authored almost 7 years ago11220c8f96de2eb693e124fdf2d19d2de90cbad0 authored almost 7 years ago
Subscription notification message once successfully subscribed
97ea424d19775cbf523b9818203aec7296bd8b10 authored about 7 years agoConnection will be opened for each subscribe request. This reduces the number of permanently ope...
456bb6bbb8fc270ccda538a2ee3e2a1ebcfb4fb4 authored about 7 years ago1bba621de510a9088522293e3ae9199786426c6c authored about 7 years ago
Once the subscription has successfully subscribed to the stream it will send the subscriber a `{...
a99f9fc3713f8730864e4253663873fd9e691406 authored about 7 years agoLink existing events to another stream
14ffdf31681cd6bd5b855f9d7c1190d5508a94a7 authored about 7 years ago7d4755d95a89c69284a8c9123c1005ef49b033e0 authored about 7 years ago
261bc3264cafd437c24b8fb8979acdd0fb904470 authored about 7 years ago
09be5a2a4de06eb1b774209405e03b15c68ac2eb authored about 7 years ago
46ef2910f16f8a47a457b725375f20e6efad03d0 authored about 7 years ago
04e5322fc2368b9970233bea032774e9b4b9bab5 authored about 7 years ago
2eae7355a90130202488d6df31d13c1bd0b2687a authored about 7 years ago
8879c5ff9a9f826dc0f4425afdc6b7aae70fab24 authored about 7 years ago
014129f32324084750dfe3e5a4e81ee494cc41f0 authored about 7 years ago
Use event linking to populate `$all` stream. This removes the need to special case all stream op...
60f328b6cd6250e0e2c040f4d0b32c5d00976cd4 authored about 7 years agofa91c50d59d412bb52ce8e7e8cde9466fef600b2 authored about 7 years ago
35b0f1a6b258fc709ff78e8bf122ac50622ba5ac authored about 7 years ago
825b777008f4cc5e66266cceb41819d975764ce8 authored about 7 years ago
a648c44cbb070c70a8fe801992d7fcfac45492dd authored about 7 years ago
359c96e1dd3d6dac1627c8591b08dae2645aeac2 authored about 7 years ago
ecd3bbf5a1f08583220e469e7dfad93b19130c75 authored about 7 years ago
6afbaa0b710791dd14df2b3ccb59545e13d2045c authored about 7 years ago
72b5f3928950d8fe25891450aa5b63127e06b43c authored about 7 years ago
d8d7972607b2f11f19c9ae5977745c1530230bff authored about 7 years ago
Use PostgreSQL's NOTIFY/LISTEN for event pub/sub
8e6665a28c4036f02930e0ba66fd7712143b2184 authored about 7 years agoListener module is now a cluster singleton so only one PostgreSQL `LISTEN` connection is used pe...
e004b7a3e5fb221d6f9be16ba68c38c13f6d5870 authored about 7 years ago89169e1063d250f0060228cc89cac4b0b8a9f226 authored about 7 years ago
879db190ed321b38c7534e702cc97bfb07833215 authored about 7 years ago
5dd62f8ea9685c75edd949727743efd2f150b97b authored about 7 years ago
Create PostgreSQL connection for notify test.
Allow short delay for distributed subscription tes...
ab58814365238a16733653eb05ff78aab2391fee authored about 7 years ago
Using PostgreSQL for pub/sub removes need for EventStore to form a cluster of nodes. It can be u...
15e2e7c6f1789a6814307be53b22a987952dadf0 authored about 7 years agoInclude #100 in CHANGELOG
f2932ecd7a4a19f0a63e83e9740d1de2a3b77f08 authored about 7 years ago247c90d31cafeb7546262fcccd4665d44b7ce7a2 authored about 7 years ago
0543f0a6d1755f1afac1714f2bbdd96430d95e7e authored about 7 years ago
Remove stream process
ae5d24ba4796806d826367fa32dd087c1d8f2ae0 authored about 7 years agoLookup column data type in statement module
1a5fc66da1c0fa2be0e0470f1e2d4eea36e3a7c9 authored about 7 years ago7b3b488c446384e7fe0a5afe1352b01f2e6028cc authored about 7 years ago
Query storage for stream info before each operation (append, read, events stream events).
c7a6d5c0b3639623bff6bac3883eee892060a81e authored about 7 years ago5d6b6482cae705bab59a3ed6f359d1144aa44b7f authored about 7 years ago
Use PostgreSQL advisory locks to enforce only one subscription instance
76bd6f124c1012f3f8ee8c548ffb90c0ffb28980 authored about 7 years agoe46a9904f568306c34933884ee3bb5946975d172 authored about 7 years ago
4b8584d4e1ff621d72e0ac712e79504a73ddc400 authored about 7 years ago
a66b59584b35be1b8d65aa582a51c4ebd533c4fd authored about 7 years ago
9a0c4ad4bcdb289b8af8c1e760bdec74d7518cf1 authored about 7 years ago
PostgreSQL's `pg_try_advisory_lock` function is used to acquire a session lock on the subscripti...
347e04219a85b331cda3535229cde13c2b36abc1 authored about 7 years ago