Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
5059892bc0 | ||
|
|
aa07b04dd3 | ||
|
|
05e716e563 |
10
README.md
10
README.md
@ -27,14 +27,14 @@ Install using `npm install node-eventstore-client`
|
||||
Versions to install to match EventStore versions:
|
||||
|
||||
- 0.1.x for ES prior to 3.9.4
|
||||
- 0.2.x for ES from 3.9.4 to 5.x
|
||||
- 20.10.x for ES 20.10 LTS
|
||||
- 21.10.x for ES 21.10 LTS
|
||||
- 22.10.x for ES 22.10 LTS
|
||||
- 0.2.x for ES from 3.9.4 to 20.10
|
||||
- 21.10.x for ES 21.10
|
||||
|
||||
*I am working on making version match LTS and latest release of EventStore so that TCP protocol matches*
|
||||
|
||||
### Dependencies
|
||||
|
||||
- Node.js >= 14
|
||||
- Node.js >= 12
|
||||
- Modules: [long](https://www.npmjs.org/package/long), [protobufjs](https://www.npmjs.org/package/protobufjs), [uuid](https://www.npmjs.org/package/uuid), [strict-event-emitter-types](https://www.npmjs.com/package/strict-event-emitter-types) (installed via `npm install`)
|
||||
|
||||
### Install and run an Eventstore on localhost
|
||||
|
||||
@ -1,11 +0,0 @@
|
||||
#!/usr/bin/env bash
|
||||
|
||||
set -e
|
||||
|
||||
if [[ -d /var/code/src ]]; then
|
||||
cp -R /var/code/{src,test,*.js,*.json} .
|
||||
fi
|
||||
|
||||
npm i
|
||||
npm run build
|
||||
npm run test-debug
|
||||
@ -1,24 +1,23 @@
|
||||
-----BEGIN CERTIFICATE-----
|
||||
MIIECDCCAvCgAwIBAgIQI83qjs8Vn2iLbeUZbTPRcTANBgkqhkiG9w0BAQsFADBi
|
||||
MQswCQYDVQQGEwJVSzEYMBYGA1UEChMPRXZlbnQgU3RvcmUgTHRkMTkwNwYDVQQD
|
||||
EzBFdmVudFN0b3JlREIgQ0EgOTBmNDczY2NmYzIxM2IyYzZjNDkzMzhmMWUxOTk5
|
||||
MWEwHhcNMjMwMTMwMTUyMzM0WhcNMjQwMTMwMTUyMzM0WjAcMRowGAYDVQQDExFl
|
||||
dmVudHN0b3JlZGItbm9kZTCCASIwDQYJKoZIhvcNAQEBBQADggEPADCCAQoCggEB
|
||||
AL3CBeNLxZDvUA4WMRACrM+kxvrlD8ahs9MOFfAJHCNLoNR4mWAvh+BUDHsG7E56
|
||||
4I5Y7XbC0cCIIER3/QB6Jz80kcJ4y745d9RCbYSqTeUnptrLdcXDNiwbI3bAjyuJ
|
||||
tEqg+iPjrz2E6bSlZ4GSxKSTC95Dm80UUU/CG6+H1FesN8JP+ruYey4S5bYASy6o
|
||||
z1NtYaPDGqSqDGvLhuWQNKoJAAc4g1R/UcVFbuI2asnCkFGjDF7gcRKkHpw0DNhN
|
||||
TMQWMdQ2+I8it5UwNzYpsCZj/le5a54mNZqNYj52nEpURDsdJy4BXJy5dUwADZHz
|
||||
ffN+ciWEToQz2hZmnliIG98CAwEAAaOB/zCB/DAOBgNVHQ8BAf8EBAMCBaAwHQYD
|
||||
VR0lBBYwFAYIKwYBBQUHAwIGCCsGAQUFBwMBMAwGA1UdEwEB/wQCMAAwKQYDVR0O
|
||||
BCIEIFRmt7SsPXFStSAcZDS9OCP03JyevPMV6/1R0Utg8UA3MCsGA1UdIwQkMCKA
|
||||
IP975meSb3EpXKsmjV4K0GeRTl5WfR72K/cfk267NzMeMGUGA1UdEQReMFyCKmNs
|
||||
dXN0ZXIudGVzdHMubm9kZS1ldmVudHN0b3JlLWNsaWVudC5sb2NhbIIobm9kZTEu
|
||||
dGVzdHMubm9kZS1ldmVudHN0b3JlLWNsaWVudC5sb2NhbIcEwKghCjANBgkqhkiG
|
||||
9w0BAQsFAAOCAQEATHxhyf27pPFJRegPB9ozm4P06MkvZMm4syxmoR1jJohm+7Xp
|
||||
7jd9ENATFApZNxV+/MYGgryML9Y+Md/Bd1fttP8j0MUR5euJX8zehrnCufaIw2If
|
||||
/a9YalJ2/a+WElAgTHM1sCpdvL+WwsQ6IjWPVfGIu7VIotQXIqllZUjMd3rFI4Ip
|
||||
9CkMgXbZzls8OhWH1FnPkFFjolqITwcgSmn3NWbQkl6qFYFjAZ8pFcjhdNay7yZx
|
||||
+Pe9gEPbi6iyP50xb0LQtJXQQvFhwmDQbR5v0xiBI6ONK8mha3fQkxmV1wMPJdvQ
|
||||
TOva/iFP4qmjyewyzOd752DN6r4qFlpb39Hpmw==
|
||||
MIID0zCCArugAwIBAgIRAICyIvDoMRsOp8HOeD9x6k0wDQYJKoZIhvcNAQELBQAw
|
||||
YjELMAkGA1UEBhMCVUsxGDAWBgNVBAoTD0V2ZW50IFN0b3JlIEx0ZDE5MDcGA1UE
|
||||
AxMwRXZlbnRTdG9yZURCIENBIDkwZjQ3M2NjZmMyMTNiMmM2YzQ5MzM4ZjFlMTk5
|
||||
OTFhMB4XDTIyMTAyMjEzNTIwMloXDTIzMTAyMjEzNTIwMlowHDEaMBgGA1UEAxMR
|
||||
ZXZlbnRzdG9yZWRiLW5vZGUwggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIB
|
||||
AQC5EvroAGtYYso6BHH1Ik9IeTV7fQZfpKqolGKtDyw8UBdJiss5OfQYB35I0lbw
|
||||
QOYU5oC4kto1ku4Y+kEuv/4RHPNEykurjYtGAcBRMT8JB96dW6rrKtGkISJlmtfa
|
||||
0OoAcPySKHnjrgsT3FYpvD5Sm8aP7YuZlaZbUIyg66h0Nd932bAZN8i7UoiAKxse
|
||||
3m1a/rJvHCcMma9tJwuzfc7GU8yyRhl9a9doUtwh0uGU7sfiXR0yQB7xYKroXl3R
|
||||
YBvqoteZ3beTSBM5mAxfRKK3JS3NlK4ys4DXp2YVWTUkoEv9oDqLr7DJSnPA1ZQk
|
||||
MwZGByQohPDF6vz9ok2rX6W3AgMBAAGjgckwgcYwDgYDVR0PAQH/BAQDAgWgMB0G
|
||||
A1UdJQQWMBQGCCsGAQUFBwMCBggrBgEFBQcDATAMBgNVHRMBAf8EAjAAMCkGA1Ud
|
||||
DgQiBCBAtQuI/026tsHlRnIi4NJRD6gZWAb/lf7D2zow/ACgkjArBgNVHSMEJDAi
|
||||
gCD/e+Znkm9xKVyrJo1eCtBnkU5eVn0e9iv3H5NuuzczHjAvBgNVHREEKDAmgiQq
|
||||
LnRlc3RzLm5vZGUtZXZlbnRzdG9yZS1jbGllbnQubG9jYWwwDQYJKoZIhvcNAQEL
|
||||
BQADggEBAMDQE0GqALLeMixp7ZbKepN+BvqLvQYF22U0wr+rBdo4UvEKTAtZ1Jku
|
||||
vwhPy6fmlq8vwf9YGrwJHwQHRIbg/H0gFV3M+Xk4LNg7anptBQ+K0Q1tSo997uoS
|
||||
jNKZTD9szy2dLfJK3xaJT5tU2qcTxPFr7/ztDhc1qXX094rqcVJc6GIQXZdvh9FD
|
||||
kNjRpCVnHNWX8CWRYdod+Lq9IUDwTsWi8BVPIxJUB2qbiK40tX77+NGV6MFmhGFE
|
||||
aLdso5mwegpqOQXM8m/JRDrJNVAZAbDT4Myy1+UcDu/91jw/xuPmCLZMXEbsFIGu
|
||||
IKF8Kr6IXObMJpr7M8t/vb1eb6BQufk=
|
||||
-----END CERTIFICATE-----
|
||||
|
||||
@ -1,27 +1,27 @@
|
||||
-----BEGIN RSA PRIVATE KEY-----
|
||||
MIIEpAIBAAKCAQEAvcIF40vFkO9QDhYxEAKsz6TG+uUPxqGz0w4V8AkcI0ug1HiZ
|
||||
YC+H4FQMewbsTnrgjljtdsLRwIggRHf9AHonPzSRwnjLvjl31EJthKpN5Sem2st1
|
||||
xcM2LBsjdsCPK4m0SqD6I+OvPYTptKVngZLEpJML3kObzRRRT8Ibr4fUV6w3wk/6
|
||||
u5h7LhLltgBLLqjPU21ho8MapKoMa8uG5ZA0qgkABziDVH9RxUVu4jZqycKQUaMM
|
||||
XuBxEqQenDQM2E1MxBYx1Db4jyK3lTA3NimwJmP+V7lrniY1mo1iPnacSlREOx0n
|
||||
LgFcnLl1TAANkfN9835yJYROhDPaFmaeWIgb3wIDAQABAoIBAFO5a8eiAwWz0Wql
|
||||
t/gMdhsX5QOGVbOaXTFeIafLHTMlh0y3+VRLJHSCIQ+XOmRWKwYjjoK76rg8V6Be
|
||||
IK85Nl/Y3gckLSE9UfXBaXkDe2MEX8ZhxxD+1MQZJUicJY9cLsROyo9TQlqubj9a
|
||||
S5UMIN9MUgw7YF7X/Bho2LZWBAa6Hz3LSyndwArvqZeUf8ovmJnWEUvJB8amVhwB
|
||||
DoYqyNjiqIEJYWRfCeGfLEOmotmwCfYeJFyr84r3wfS6qmaesKM8Nbz8eSSNg7n3
|
||||
5LcAL2Bv3hvsMmUEZQl3J41AtBVsU5DgbTf6/seuKvfVOcqVp9AtZp2rg3xY4pNI
|
||||
7gN4wiECgYEA1lBh13LdjM0rOg9096ee2hQKjFvwVki0xzZigmf94CXoAJ19qwOe
|
||||
J0WXfk1g5GP1bg5pdVhKdS+LEIqet9ipaall5hWotaYJdyOtWiQan9wRRa3sk6pl
|
||||
K29LBF+XzZWAKE7C2371rVyMXViHzv056wasw0RSgxd6HBi1mOpcveMCgYEA4qrj
|
||||
Ha24Qh+/b883FaMphYrl8H8nMgAdGmi7HiLnJx6jzPzalsBI5+qnDY8/oqeAie66
|
||||
k8c6uRKOsEFrsbK/w3+21rGuZb9t9PupDONFOW9D94744HDFu0Clnr5S2ABKM9D6
|
||||
hUL2qQedAqZx5CNWbpM/wdV0OBKhveIb9OyjytUCgYA21jCC0ThRK7owy/2w1Kn3
|
||||
wQMF8Qxo94eSJZ9FINi7/tcDOUkLdgyEnfDqd2AgcFc/Rt7DEMlUfMrHe8Cq5/xJ
|
||||
NfgFzGrzt71aR722f+B0IPomax9KlWH3oC2Au/j6uJMnPSfsw+qW5kRgKiPt2at1
|
||||
MKsJ97RpKJutDsGAlA8Q4wKBgQCUyjBD7yEg5s43iwJRxcUf0EmYUR9dhw2TpGQQ
|
||||
KEEsQMStbt3eT2KMOlBmaj4Pe3y5DmiTURiPHEtmD8ut3fRbVJ6k2AXu7HY1dm1F
|
||||
9HogdZVcEBH24pAplwog5jZja+1Jjkik6YwY8NJ0RuZEJ544/5e+mWus0y4xAxfu
|
||||
8teh8QKBgQDQm6vKAsldQStgj9gwRiTAUrMPTriVQTUd4/8lof+RoIJWM7CARLos
|
||||
9MYkAefv4MgjvwWNn8RbFjN91NBX4qpCjgm62P25npFSKQAK+JQlvj7MbSw54jyx
|
||||
2/uj4JEMM1rOocJr9tvYAeC2nnZMOuhesLVy+SHF9TJ2WtalDOTZ1A==
|
||||
MIIEpAIBAAKCAQEAuRL66ABrWGLKOgRx9SJPSHk1e30GX6SqqJRirQ8sPFAXSYrL
|
||||
OTn0GAd+SNJW8EDmFOaAuJLaNZLuGPpBLr/+ERzzRMpLq42LRgHAUTE/CQfenVuq
|
||||
6yrRpCEiZZrX2tDqAHD8kih5464LE9xWKbw+UpvGj+2LmZWmW1CMoOuodDXfd9mw
|
||||
GTfIu1KIgCsbHt5tWv6ybxwnDJmvbScLs33OxlPMskYZfWvXaFLcIdLhlO7H4l0d
|
||||
MkAe8WCq6F5d0WAb6qLXmd23k0gTOZgMX0SityUtzZSuMrOA16dmFVk1JKBL/aA6
|
||||
i6+wyUpzwNWUJDMGRgckKITwxer8/aJNq1+ltwIDAQABAoIBADGUkR0YB6ntBUoX
|
||||
qMPIBj9fIWHMs6lpvsJcxjagivQ5bJOqGBljmi3ZzA4MM3g3mqvcuH058jVKAHk2
|
||||
icHRc2n4PH+gRjdWOwptK61UqRNtRUkYpqhLl1AGBGX93nfjYdzuZ+tr5oOFO7h9
|
||||
XaPepz+QNdiXBcAGZEOwR4xQtZcz5l5Iioqq7r63Q2MBGhsVwYIWvBCfLwK/ANUz
|
||||
63LW/g9lRhS9MN9RPkJnIeobfz0s8qwTHoYvU16x4m9yvrjIzq0dPxSa+ZQY5G9y
|
||||
AXs3bGNVDTKiMjMhOsE/M/0i0qe0yunoSxJlrex36Z7D4ipWYAhjK9TYcUc/JUo3
|
||||
5LU75pkCgYEA7ywJp0aCBt+lITz+l2oKg47iBcou+cO2GAkYIQ1x48+izue1Bc8R
|
||||
Z+Dh3BrPIT0SqLqQbnxcR214fE+IQnrDG/j0Mi53+sGZQQskAHc3HRCNxtsZ4zgP
|
||||
jGk9NKwMmww8PMrcsvAyy7ec4L1D8IKLPr4Zok4HuYsEWUlUt+f1YiMCgYEAxhiI
|
||||
RNmv+iVtp0T5jVAEJ0X94H1G4pKCOZ3vJkYvIfF3axdCW/sxoR/dxTQuSzuVnB1v
|
||||
eLKgQ9o1aoU44GTWMdO72pHYzwtb2M+Y0jD5ZDDUBcTVy7uG++ATLyzr9irFZMOy
|
||||
Wn9+7nUFdAEzDYBfnL0sxXc3ltt55onmC7yrdV0CgYEAqcZP3+7b8/cjZ7G9Y0wB
|
||||
xJtTdBquN9umUe96slOx6a2Fe2vdAw+W4m8uxKg/KfAJY75zMgqTEpzxrwRhzBcK
|
||||
kruo1EpKHrT4jcRTvQTjGX2btnHnMXSlDN3TdaU/mXwY8mpqOZbp59QhxyJyrLJu
|
||||
F46n8Z+EOkAlSSAVxCoi9JMCgYEAtgundzZiTUyGJ7jwaRgGqRzeQaZ/NQqU2GQ2
|
||||
eYL4H4ZrSyQV3LfMlRjW0jqw7Hx2cgBvB4mIVLK8cga6DSU93o6JTUTI7QSwRGAL
|
||||
Pea52YQx5JdOLqtIUkJK/wiWVCRcQMzDI/2U5YjvGPtdMmQt+bmz4kg78swBi4Zg
|
||||
vZqGKxUCgYBdBMRd4nxwAk9aphiCB0/OS/WSfc0CqegcwFG9ireb8iD9xvayqsNt
|
||||
s4NI6cncnZXOTKm2mEd3E4yo8N9LieyNZV6kIhKxDMfgrRxLMBC17ur8R5z3uNzl
|
||||
F69As0W69+VqyoM/pS9hDJ72DiA4YblWkWiZuZzhqi0Jwh9VEY2Oew==
|
||||
-----END RSA PRIVATE KEY-----
|
||||
|
||||
@ -1,24 +1,23 @@
|
||||
-----BEGIN CERTIFICATE-----
|
||||
MIIECDCCAvCgAwIBAgIQdipz5iGZgwtJYjBK4mjFijANBgkqhkiG9w0BAQsFADBi
|
||||
MIID0jCCArqgAwIBAgIQb+tOqV1PR8uW4adXZE8bMjANBgkqhkiG9w0BAQsFADBi
|
||||
MQswCQYDVQQGEwJVSzEYMBYGA1UEChMPRXZlbnQgU3RvcmUgTHRkMTkwNwYDVQQD
|
||||
EzBFdmVudFN0b3JlREIgQ0EgOTBmNDczY2NmYzIxM2IyYzZjNDkzMzhmMWUxOTk5
|
||||
MWEwHhcNMjMwMTMwMTUyMzQwWhcNMjQwMTMwMTUyMzQwWjAcMRowGAYDVQQDExFl
|
||||
MWEwHhcNMjIxMDIyMTM1MjAzWhcNMjMxMDIyMTM1MjAzWjAcMRowGAYDVQQDExFl
|
||||
dmVudHN0b3JlZGItbm9kZTCCASIwDQYJKoZIhvcNAQEBBQADggEPADCCAQoCggEB
|
||||
AOJZaF5skFJeNOgkqG8B38lV6lhKwvrmspxZvw7tP8dhzV7R+EUdTXYS86ximW4c
|
||||
cdK5zqXRgZG6WaaFFN4BeCLqum+602l9Bw88K5Ww68v5R9VP8sgt7w4UsqvVjTJ4
|
||||
60R59PvfrwkIL1DFkKBM4B7CmdLR20VZiJQ9YghR03TBbjjvIhaDyprmxu0vDsF7
|
||||
f3zNmcnBF+14Z0b/exevtiVbyvNQ6nQENSo7Whz/kDV1a2i/BsVlsbFc43ywmsHL
|
||||
Ks1z2rSctTgfYmK/yUFaR4B1mkzhQf9/CfJxJQLekC9Zv85ah9tMGwl/pbDfZh7q
|
||||
NUJQHjJMm4I/HeeTQPd1CXcCAwEAAaOB/zCB/DAOBgNVHQ8BAf8EBAMCBaAwHQYD
|
||||
ANCHpO7KZQLnelCEa2QW12Eko39w3yCDdq12CINuRVIxZ9hDaXY0QXg2EjsKgnWe
|
||||
WNbhGT5kwDRZbR9/EFwP0TsujcLmF7JdiJ4oerXdrqp7uTZWZq70BDqhKZo/PnFB
|
||||
c/OHJwwZdhDd24b6Id13MAa3JM4I5bbc5o4jrwwxqimXaR0Iw7D7IchQ/QReN/jR
|
||||
JArZIkjHw/M5ljX8LdSMpT2Acy8f3hcfUja0OGgjWNOy37DLDX0GJCzwQa0NvdiG
|
||||
PfwRny7PQEyaRER2vPhuqKb1+8+C4rSBEixBUHm0rPImCCL8QAkQdfzHLeCAbtez
|
||||
z+/bvzqjzmRNQJ/A8isSgmECAwEAAaOByTCBxjAOBgNVHQ8BAf8EBAMCBaAwHQYD
|
||||
VR0lBBYwFAYIKwYBBQUHAwIGCCsGAQUFBwMBMAwGA1UdEwEB/wQCMAAwKQYDVR0O
|
||||
BCIEIDlz3IFnAja157ly4cFxgZTfYrwlqAhgtbEu4TVhO/yPMCsGA1UdIwQkMCKA
|
||||
IP975meSb3EpXKsmjV4K0GeRTl5WfR72K/cfk267NzMeMGUGA1UdEQReMFyCKmNs
|
||||
dXN0ZXIudGVzdHMubm9kZS1ldmVudHN0b3JlLWNsaWVudC5sb2NhbIIobm9kZTIu
|
||||
dGVzdHMubm9kZS1ldmVudHN0b3JlLWNsaWVudC5sb2NhbIcEwKghCzANBgkqhkiG
|
||||
9w0BAQsFAAOCAQEAvj0ZjZkKdqwVdfXJAhMPGZwMf8gfZRpSCJe95FL0yePUk/jm
|
||||
di2qk2sb2+W9prPR1Nbs1hfLnHHBw32yrxekvFSUC6Qc23X8S9QU01FOO7uEVtnM
|
||||
fdEzyuZcdPBK2SAL/CxN0WH/yUxNWkWnqQKegZxkvpMVxMAsA0l3twWwfkEQtjhA
|
||||
V/dcS5WwZxyyvCQ0qAVZ4+Zd/huvmsNIaXplvCs/P8yU6SR0TUdahJpfxJeKkKIf
|
||||
k2h2/G36i26lTTm2TyxO4A2v8PotRO0xhjJkVKVEs4ZuY+lK6JUoTaM9Z8FubDqE
|
||||
K2KH+YCBdER5jQK2YbmZDRh58aKMpCXtCx8RqQ==
|
||||
BCIEIAZeYK8mSU7E3tNmG5Xf4qDwU5i5Cdvm491RSMI0CsU2MCsGA1UdIwQkMCKA
|
||||
IP975meSb3EpXKsmjV4K0GeRTl5WfR72K/cfk267NzMeMC8GA1UdEQQoMCaCJCou
|
||||
dGVzdHMubm9kZS1ldmVudHN0b3JlLWNsaWVudC5sb2NhbDANBgkqhkiG9w0BAQsF
|
||||
AAOCAQEAi8ZoFfa143InqWLYsvPVVKCD++cVLv/kXO735m0kGex1Ri3KJChxLAkQ
|
||||
v1873PtB0eK6Xe7xhcMp08bg/jKM2CSJ4wyxhgbAybkJTjASvWzbzv7SJL1rslkl
|
||||
j+ZS3i3EEve48CLOZ8YqoZ5UPUF51SMlr/aXbZehHA8xOeVPL8ImtUZ94y7SgeP8
|
||||
VQFvGYQV6ysBahR/x/D6OHhIcl22RrRD44zz/t/5qgFNCwiR4l7Kd33gX3SJtFA1
|
||||
x3KCKSQl5j2j0ME9J0ro9QsJxhhAHk/YIW1+VfO4Q6TBmopscXea6uNq5wQBeIcQ
|
||||
8M4M9MYa3Xy4FUquonpnSYiYtLEdvQ==
|
||||
-----END CERTIFICATE-----
|
||||
|
||||
@ -1,27 +1,27 @@
|
||||
-----BEGIN RSA PRIVATE KEY-----
|
||||
MIIEpQIBAAKCAQEA4lloXmyQUl406CSobwHfyVXqWErC+uaynFm/Du0/x2HNXtH4
|
||||
RR1NdhLzrGKZbhxx0rnOpdGBkbpZpoUU3gF4Iuq6b7rTaX0HDzwrlbDry/lH1U/y
|
||||
yC3vDhSyq9WNMnjrRHn0+9+vCQgvUMWQoEzgHsKZ0tHbRVmIlD1iCFHTdMFuOO8i
|
||||
FoPKmubG7S8OwXt/fM2ZycEX7XhnRv97F6+2JVvK81DqdAQ1KjtaHP+QNXVraL8G
|
||||
xWWxsVzjfLCawcsqzXPatJy1OB9iYr/JQVpHgHWaTOFB/38J8nElAt6QL1m/zlqH
|
||||
20wbCX+lsN9mHuo1QlAeMkybgj8d55NA93UJdwIDAQABAoIBAQDR3UvjoIz/kdFE
|
||||
HBj/M6GmLz6ktkyqDRQ12xBGarrjxk6AR/YFPvH/M/syLglMCpuOYjCzldiooTtW
|
||||
JbX/USVuWmyaA4LZH89X1NYkaHF4IZz0rrfP2qb3S0GOCOZtkaexSdJXZkIIAcq8
|
||||
/TDnL9/tJUkyKtk/J5B2waMPS67fZGoZ6wx3sHZ7/CCcvdtHSvCT5+taVoHGUDPi
|
||||
kToGcJAIDKAOakZfv1bfzYFyln18NA55V+133tGfZYJrILmEwLcU2Y7BAaoD+yme
|
||||
+BWU3eKgYRCsvA+HzdgDetEaqp78Ax/G29OUK9NWdXk2hwhmkpZgSLV3g7OlfNve
|
||||
6pmuEpcBAoGBAOPIMM+uYQJmRIapXZADQOc7VkF55sSjh3h25tjS8iHIEGQ9gb8n
|
||||
h4iNUDC73NN9Yfw6/vKrwcpIq5nQKRRUQ+NJFxurtN6XBBlYNf336tg6S/65oe3W
|
||||
R3m35/w72qcct1aOASDafuxdoEV/kbflpao57PxRZAXGdMPJANDckujXAoGBAP5j
|
||||
x4NZvYI73oL2OI/2CJytA5uksfsh0ymusNKRaBhqLwFIE1Ud/CHj5eG1Bo9ox8Yl
|
||||
e5AdkMmSSYFIe3B/P1apFI22/GKc1on2mFXKRY8zAMVLGbsLJarQz4xIX36bafUh
|
||||
1O9JM1d6PWDITAzoptIJDF7U41jxbbGMic6gIbBhAoGAMOUkNTCFenJhe1aX0vYf
|
||||
1IMUPPHh64v+5IkBfMGrYD0F576cP2BI47MR56Qr/uoHQpGXcJgV/UokK9xXNRnx
|
||||
iLSD1VjCdpWMN7SLwnyZWNkKvx8x90/r/+DOV4KxqPWtFVNeQqMkY7ClWsXLjeIp
|
||||
8aSFjpQaGHNFVVGsbykqD/kCgYEA3BZ/eoidiJs7e5qCfSqjcMnPIU1wHpG5G4rj
|
||||
uInMwbK8UCOHdlCm3rtJG+l+b3x7ulabfKfXqE1EAvIuubmdluBZw/HYkYiXpG0Q
|
||||
hsilPasms4qyDD0srYhSyE+lLuhO16IZk5yFKt27VIx2H4T5LyZc6X7N4xmdicrJ
|
||||
P1cTToECgYEAlW2xWDl90suSAw1Tv23BVEX6ol/UColtGY8VDIHsXPDBYImtGiFt
|
||||
MibOuyzWsvPw0HZDzWw9otU0735clhK34v+E1WyPFvOAo18orcCS4A6Fi42tp5oG
|
||||
sNVxiYJFFUn+nnHUoGZNuKlB5PZR1Wxus6wXY2rZdoQ6QsBD0XjquCE=
|
||||
MIIEpQIBAAKCAQEA0Iek7splAud6UIRrZBbXYSSjf3DfIIN2rXYIg25FUjFn2ENp
|
||||
djRBeDYSOwqCdZ5Y1uEZPmTANFltH38QXA/ROy6NwuYXsl2Inih6td2uqnu5NlZm
|
||||
rvQEOqEpmj8+cUFz84cnDBl2EN3bhvoh3XcwBrckzgjlttzmjiOvDDGqKZdpHQjD
|
||||
sPshyFD9BF43+NEkCtkiSMfD8zmWNfwt1IylPYBzLx/eFx9SNrQ4aCNY07LfsMsN
|
||||
fQYkLPBBrQ292IY9/BGfLs9ATJpERHa8+G6opvX7z4LitIESLEFQebSs8iYIIvxA
|
||||
CRB1/Mct4IBu17PP79u/OqPOZE1An8DyKxKCYQIDAQABAoIBAQDPsjrxZ/9B7EJk
|
||||
je/UqfdtlyuNlGN4o9gBny2NkrhSzEitGz+gbx3CWMDBs48LDWNY6qzU+06BFYzd
|
||||
sRYfS9XPB2hE9h4mFokrVhAasij1PvPTji0KFptbtgeUzWcpMNMHfNbEc1uoIwEz
|
||||
KFGwnrTkC2gKGsyJ3O16J0qDb7gXYR4Ws566NGJDbjz14p7CTIoXhp3K/hvrowEx
|
||||
UHjnFsaSrcbWZ+CHT9fKkQFYUqh0ab0dFo9L293ikRxs+rsvcaKqX7h3XTHlnOEd
|
||||
89c25UPb8w7rQGWti0bRMMmS1knHEHQz2Bw6zby/JLw+9tmb5+/ooAtAoYKZmfM3
|
||||
XK+j2uSRAoGBAOk0Vo6WBIZwhvETa8htXk7Yf7FGmWWvgsZrytTFLPmzLKVQsLPb
|
||||
NEKHpvz0ysq9qAszpZgayi6ie0jsmMeAQi2ADO5faRiGKx2/axm1T0jWAlEE3BU7
|
||||
iF5HkGK9Ohjgy2WJWLk8L/l+jLdNwo+6xTTqZakm08qtUtxyWVTuMC1FAoGBAOTp
|
||||
2q3wVQgk5qm5sISyF+8hucjqMgMQ/SuxkpT55hjuZntlKtCdXAjClVlQdv1WZT8l
|
||||
DvoUGiNQsRULNgUCClWEY9b6OiiohuH8V049tF73325KqP7HTJsS63SkZSmeeUeT
|
||||
if6yM1JlbbJrDlCN1SpE8dtjTUs1whj3aapTsAxtAoGBAKloE9jQscjXxa8q5Ilc
|
||||
qb2tGFW3a4eqz91EQLv/4IQj3LLawwJkoroRwQTQ7uAIliJNCmZMT8NA1T5MYU/L
|
||||
pEdZVgtz0+y0ym15uFucklPe4x/n39isvot+gSy5OZMI+bhw5brqNg+QFriyDDxM
|
||||
+SVPgTo3snLxJdhuWOaRgP3hAoGAeTecpR7u6DEiNB4waxQjuG2Tg+EAOr90UP7n
|
||||
MBxkzC7x9cXMtkudwMXJcFI7sEtfseBd3e9nJ+xC2XHmWSCLeF1ywRQgWAdl5aVK
|
||||
VhQ2v1Ni7XR7qO7Akh2isVGcgD1623w1Rrn2k1tCi4hFPELe7lMz/4jGFV2SOsZJ
|
||||
HfjS8MECgYEAjyl5rJuFtAy7JewI6HgokgMAtmfyV6fRIbEIdb+rfn3uUDPleRFg
|
||||
WJIN6T6xywGOYJFx0j7hnywQ+d9zXph2KILFQO1vYMwWCMzLA0TfYGNHaoW9J5Ja
|
||||
3gqhj1DQKWaPTXP9Q9pKQOe8eO4AS1XJlNBY3Q28bZcAhOZq5KUHj1Y=
|
||||
-----END RSA PRIVATE KEY-----
|
||||
|
||||
@ -1,24 +1,23 @@
|
||||
-----BEGIN CERTIFICATE-----
|
||||
MIIECDCCAvCgAwIBAgIQecOoexYVeIUtLwNQp179vzANBgkqhkiG9w0BAQsFADBi
|
||||
MQswCQYDVQQGEwJVSzEYMBYGA1UEChMPRXZlbnQgU3RvcmUgTHRkMTkwNwYDVQQD
|
||||
EzBFdmVudFN0b3JlREIgQ0EgOTBmNDczY2NmYzIxM2IyYzZjNDkzMzhmMWUxOTk5
|
||||
MWEwHhcNMjMwMTMwMTUyMzQ2WhcNMjQwMTMwMTUyMzQ2WjAcMRowGAYDVQQDExFl
|
||||
dmVudHN0b3JlZGItbm9kZTCCASIwDQYJKoZIhvcNAQEBBQADggEPADCCAQoCggEB
|
||||
AN8iXoWZjjxOqJJLTHmHOy89lbk2pBo/ca7qPZ/WC+I52A4Lgw58/O7tV/RHFyao
|
||||
X8lS2hAVMlRfToUqj7ILAVBeF3t827W0qttbv+wdnxvIWqpq1HdtV5xgLIUXbyiQ
|
||||
SI97Tgn7zDJOvm41sHV0xsPWKlritliDByXlGMOabzV53yxa1c0cU2bP5n7nc9wW
|
||||
KOH03OU64qCj6MJTdi35peKDhaAcRtGmr5ZggUCP4n9GUzJ1FATAkcrLMOjoh1v1
|
||||
K6auqOQZ8f+ns+3bQ4G96rZxwwrSzI/leUFY4u/lzjLUlEuLALJquPrB6RiwzTwb
|
||||
BOaTYG6mgWORWPBupjpj67cCAwEAAaOB/zCB/DAOBgNVHQ8BAf8EBAMCBaAwHQYD
|
||||
VR0lBBYwFAYIKwYBBQUHAwIGCCsGAQUFBwMBMAwGA1UdEwEB/wQCMAAwKQYDVR0O
|
||||
BCIEIMdKDLFiWvROUmnmDVing8S3lLisBr+vfrrM+A0t3yycMCsGA1UdIwQkMCKA
|
||||
IP975meSb3EpXKsmjV4K0GeRTl5WfR72K/cfk267NzMeMGUGA1UdEQReMFyCKmNs
|
||||
dXN0ZXIudGVzdHMubm9kZS1ldmVudHN0b3JlLWNsaWVudC5sb2NhbIIobm9kZTMu
|
||||
dGVzdHMubm9kZS1ldmVudHN0b3JlLWNsaWVudC5sb2NhbIcEwKghDDANBgkqhkiG
|
||||
9w0BAQsFAAOCAQEAEJmQloXSfxqWGIdGFi7UFDNr3oTxuQsEJRztKzA1rRPbvFhp
|
||||
jJ1uPZKRv0SBnmaQa6+PW1zphP+kklmMq9XqiFqq7D7FmYgr2err08DbQfMxyEhG
|
||||
yHmaBFzEyI/rm8jRn3K5DMV6cDCB3jTn5eud3oVVAZwTsLcR3mB2UpSJ7lAJgRFs
|
||||
5pfFFgHKCQ4YQcFIkNtMeda7KpVv4YxoltJMSISDGvo4fcNhCH62H6/PDJFBi/e9
|
||||
L4vB7eZHaO//8UQQxV24VSDLDBP1MQ4ucLZEVam9HQj4qK+DiwDlH6WmQs22FqqE
|
||||
i7aLjEEu9Ko2zG7hzTp1jxDfyPw5iByax1JdXw==
|
||||
MIID0zCCArugAwIBAgIRAIrgk9b8CiaOIhKw0UVCnw0wDQYJKoZIhvcNAQELBQAw
|
||||
YjELMAkGA1UEBhMCVUsxGDAWBgNVBAoTD0V2ZW50IFN0b3JlIEx0ZDE5MDcGA1UE
|
||||
AxMwRXZlbnRTdG9yZURCIENBIDkwZjQ3M2NjZmMyMTNiMmM2YzQ5MzM4ZjFlMTk5
|
||||
OTFhMB4XDTIyMTAyMjEzNTIwM1oXDTIzMTAyMjEzNTIwM1owHDEaMBgGA1UEAxMR
|
||||
ZXZlbnRzdG9yZWRiLW5vZGUwggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIB
|
||||
AQDmS3u8Mx1OUbXqFlDSU25sthiBI8p5sUq5/VvuKVEAvBuSQydTwbCU3cfaUNCk
|
||||
wLkIEVJInqtzsUnUWkPRDg3W4bFzEoXzP1/1OffqcgjwDl+hym/k0HWGvt4UzXnw
|
||||
7MXHxlMUj6E+GK9JvleKIo9C/zWg7o7ZaC4s/cYkkkmHHzHVCcapuKCJEbUKJgzt
|
||||
JnJ8wZCPvmEHWoTT7255drMMh1cwzZvOqCWpZ0Qk1+KZc6C7QcbGrnPv1PIKT53o
|
||||
7XDZnAXTGfbah0/e5zIM4/Ms3JauObbcXv/oSb8KeiMrYmM12CfAJ9LAu7sm8uOz
|
||||
tuVvpaT9lH0v91Aat1G4k19/AgMBAAGjgckwgcYwDgYDVR0PAQH/BAQDAgWgMB0G
|
||||
A1UdJQQWMBQGCCsGAQUFBwMCBggrBgEFBQcDATAMBgNVHRMBAf8EAjAAMCkGA1Ud
|
||||
DgQiBCCla0cvcjb+WYGvsdw50JZcKNTFFj4je4cHn8xci9SQqTArBgNVHSMEJDAi
|
||||
gCD/e+Znkm9xKVyrJo1eCtBnkU5eVn0e9iv3H5NuuzczHjAvBgNVHREEKDAmgiQq
|
||||
LnRlc3RzLm5vZGUtZXZlbnRzdG9yZS1jbGllbnQubG9jYWwwDQYJKoZIhvcNAQEL
|
||||
BQADggEBAJtCYINTvOQXOYIhEUZLjyPKqAKc5Ey117WNj1BJ1OAlrddwiMGUZg1L
|
||||
g3Md2oKJXrsKrNBgePEnfa/gCt1kBUpNfO5ILVJtVzuifQAsePtbjvkRA5suzll3
|
||||
FP1QrvC8ZCq9oDW9+/WEGEi2Bjp2RPKlRBKj1wP/4MYKwjoGY2ezrb/rutKVpdIm
|
||||
3UEoaJG1VpT7IkdcIcLSCyPS5BDd/Jf1428ZZuq6DlbSOIRjCo8w9hazfizeJ+iE
|
||||
kGDygYYg5RkPsl8ACcXsZDCPr6gS2yFa1v0eQOV3CPeO8i6aiQToZekEoAVGrJ9/
|
||||
HpLfDap2pVqf8gSnX59XIsE/WwMVWjc=
|
||||
-----END CERTIFICATE-----
|
||||
|
||||
@ -1,27 +1,27 @@
|
||||
-----BEGIN RSA PRIVATE KEY-----
|
||||
MIIEpAIBAAKCAQEA3yJehZmOPE6okktMeYc7Lz2VuTakGj9xruo9n9YL4jnYDguD
|
||||
Dnz87u1X9EcXJqhfyVLaEBUyVF9OhSqPsgsBUF4Xe3zbtbSq21u/7B2fG8haqmrU
|
||||
d21XnGAshRdvKJBIj3tOCfvMMk6+bjWwdXTGw9YqWuK2WIMHJeUYw5pvNXnfLFrV
|
||||
zRxTZs/mfudz3BYo4fTc5TrioKPowlN2Lfml4oOFoBxG0aavlmCBQI/if0ZTMnUU
|
||||
BMCRyssw6OiHW/Urpq6o5Bnx/6ez7dtDgb3qtnHDCtLMj+V5QVji7+XOMtSUS4sA
|
||||
smq4+sHpGLDNPBsE5pNgbqaBY5FY8G6mOmPrtwIDAQABAoIBADk571QEVd5RrhoX
|
||||
Bb4FWMB84vFleiDhNJ7PpI5hrxqOC0NO4IXOuG/unygfM2jOtgJEJXkKdqX8635r
|
||||
s/7No8Cg4RTiqNapR0iK92XvEudlMxuR2nvmpxmL8N8Ra4jTuEhUL2eQFIaye1R4
|
||||
oJD/Khr/yk0U5/87W5H0d61y5iKobF87QbI9xxkBGGQygsvoEni4sHchN1se/Ha8
|
||||
y9nb6B/9sYU8lfSSaRhS/sqpH/ppnptWr1hwxj6jxI21uMB+cWN+rs8j1F0Zizex
|
||||
+TTDqhyuYoqh1x2J9UFCjipiKVnA1563eFmtQZk2nrNdjvN6K9qWa0iF8IgTGvdh
|
||||
m+9NNEECgYEA6sYqugSzeVCqBqHKAQKESsO6XOQjwkDZQhgeDG8Sal5RArlNsup6
|
||||
hh/ZONPCL/6zxz5oKEyxzsTg4tJI9F3uqkpF5rcM1UGCc3maywXmLUd70NuTWM2G
|
||||
hz+R4IhKyuQsFhWzFRBh10rorSvjIflkKiviZp+lNiDp1UnY0pOhxWUCgYEA807M
|
||||
i60fuTTZsvGKhExORHUOnfs3USst1zHODDAaQYyjUYJP7ix/azf1ciHeeNCZ9rzF
|
||||
9xBlDKChRSvKPnU0K07C49a+WI4rdgw8zS+8dqKdvaczPas0InPzXs+oW/O6I86I
|
||||
ANEanw9fgrAPEL4/8TLMLhjTV3msdrJ04KzVWOsCgYEAtc9Ax01cr1YIVZp1FNMe
|
||||
H8fzSnxiNMyDcuu6WWaqnDTuB234/dUXjUacsaVLfF+CWYm6n3rFN5q/jOfMF3Gm
|
||||
obli6IhZJ8zTeRlzBkZLOkVhXRytvtdqltJj5b2mLfkFKxUi2e0V1+PqzDBwdJ7t
|
||||
MrtJWK/JAWH7s3C8uFYbsQECgYEAsxD2d4H1zA/6fLlKEa47GCTymhCumJ1nwm4U
|
||||
UGICoOWJuU5n10mGiXmIufP1UQNtnOs342p8hDugFVFyKl+GAq2Xv6lnM7OGhv3g
|
||||
rb6JPOLXpyHsE2HyH70oi0nXhb0t7HZvH/LFXfUpfPxoShFK7BBPt0lsGYAiDsWu
|
||||
QUDST/sCgYAVljJlvlEx8C8HmBrSeeh+Zec9t9HDjl04jNAwenY4x5hD1l1u2ij5
|
||||
OJqVodZd1s/To7Dm9Xc6w7r6c9x8xsok4Kc3izc/KQXlxPvRnxF76J4KsMw8kEU1
|
||||
LnQN+igffijohdln2Q8cQnEZylM1N4e+sNat5ufEzTk7MBn1676aHA==
|
||||
MIIEpAIBAAKCAQEA5kt7vDMdTlG16hZQ0lNubLYYgSPKebFKuf1b7ilRALwbkkMn
|
||||
U8GwlN3H2lDQpMC5CBFSSJ6rc7FJ1FpD0Q4N1uGxcxKF8z9f9Tn36nII8A5focpv
|
||||
5NB1hr7eFM158OzFx8ZTFI+hPhivSb5XiiKPQv81oO6O2WguLP3GJJJJhx8x1QnG
|
||||
qbigiRG1CiYM7SZyfMGQj75hB1qE0+9ueXazDIdXMM2bzqglqWdEJNfimXOgu0HG
|
||||
xq5z79TyCk+d6O1w2ZwF0xn22odP3ucyDOPzLNyWrjm23F7/6Em/CnojK2JjNdgn
|
||||
wCfSwLu7JvLjs7blb6Wk/ZR9L/dQGrdRuJNffwIDAQABAoIBAHmEOO0sd3k9CmVT
|
||||
kx/4IBtC1plF3m/qCgkr1BdOO8zMdSvvPVAnstpKUEs1O3LDsp68LRPejY+Fa/Se
|
||||
EIy+ArVw76ZNjtq0hRirltJhi6/HldSUMgilqm4IRrzpUz+6X/4y+uGtjCJs+glK
|
||||
Y3yjEb8DVTPuzPeQzlS1L5lai2u9HKBBOOY5At6lwDa9ckZd3Xyf3xUPGiK/Vdyd
|
||||
HscVpr/PBQeMkXODhUCRIyY2nfSncYOv1d+TM2r7PXi4v/zrPnfybz8D7eseo6YR
|
||||
NS/70rNJSfn2snhTS1iFaAPvG8AU6nLwGlj/8m8J69IFS34znmj+T6bcCSSyV40o
|
||||
YqOPRzECgYEA6LVYbuZqkeqCtW4cGOJ5AShhl8CCG7BLR61/A2Vd1aQYUchlYi3R
|
||||
PNoH8F4lD6HT61zL25e4IRlTkYllblRldN3PzMHxyDVKak9UclW70KbP37e7Ta49
|
||||
HQAz45ewM3nOnJN8lHgSxP3IVUGXZolhjqis+3/Afr+hhzj7GDaAcicCgYEA/VhL
|
||||
6DKhacYfXvwnQuQ35n/MNkbBCH8mcytoGDGrJ62Mh8Lu0UEJ5R2HhvMrZsOsuLbR
|
||||
tAV2AGmeV1ixcdiZZoZb1J0V4BP5T1QP89DSlO9N5xwJTvV8r3rdXJUMbntcXl2F
|
||||
eUJ0L3Hi4/13wb/ohsfTIce2IWtmstFBwJ529ukCgYAvhwIlvEedv6Csf22bo32F
|
||||
QAMWpEmucAYgAI5FWkmc3aPd6CjUsXjfjcQ7Um8NT0bh9hTop4cCs5J+0en2a6RB
|
||||
ByBuuFmyQzgMmGEt7NasGbWxAmxtxB1VM/plDFD/YmxRTEoQZKmotBBbYUcTuRFE
|
||||
uqyBvSjKekb6QCgAXPlE1wKBgQCSc4Fl2CbhG2u1H/SeQYljEMt/MMWT4NTcTOJe
|
||||
4g9732JWdMRTaNKMhNZ8l4OmY0UsflqZQ3LkaCnlelsRYdHDp7XcIXas0z8SsZiL
|
||||
LFMfT3rsN5PV9ik+07q1M2A9WciasFthLp41cxNjEnoxIXwMteUCKQ3LIef7ROZK
|
||||
sBA7SQKBgQDBxdbUQCpwLs9iJQH+ddPhIGKXLGNw/3f4quKBGz6fO1X4E9STFWoa
|
||||
diu+C27608WmPEnDLy58yCameZ4sk/Pt269yhHerEuPrSFKrqVQOyyO9utCQHbRY
|
||||
9wjvymJnXAvJE4CgXvdYLIFvaog86KmhpVX830gnyFdJ+d7EDpUU9w==
|
||||
-----END RSA PRIVATE KEY-----
|
||||
|
||||
@ -1,15 +1,15 @@
|
||||
version: '3.7'
|
||||
version: '3.4'
|
||||
|
||||
services:
|
||||
eventstore1:
|
||||
image: eventstore/eventstore:22.10.0-buster-slim
|
||||
eventstore.db:
|
||||
image: eventstore/eventstore:21.10.8-buster-slim
|
||||
environment:
|
||||
- EVENTSTORE_CLUSTER_SIZE=3
|
||||
- EVENTSTORE_CLUSTER_DNS=cluster.tests.node-eventstore-client.local
|
||||
- EVENTSTORE_ADVERTISE_HOST_TO_CLIENT_AS=node1.tests.node-eventstore-client.local
|
||||
- EVENTSTORE_ADVERTISE_HTTP_PORT_TO_CLIENT_AS=2113
|
||||
- EVENTSTORE_ADVERTISE_TCP_PORT_TO_CLIENT_AS=1113
|
||||
# - EVENTSTORE_DISCOVER_VIA_DNS=False
|
||||
# - EVENTSTORE_DISCOVER_VIA_DNS=false
|
||||
# - EVENTSTORE_GOSSIP_SEED=192.168.33.10:2113,192.168.33.11:2113,192.168.33.12:2113
|
||||
- EVENTSTORE_RUN_PROJECTIONS=All
|
||||
- EVENTSTORE_START_STANDARD_PROJECTIONS=True
|
||||
@ -21,10 +21,6 @@ services:
|
||||
- EVENTSTORE_CERTIFICATE_FILE=/etc/eventstore/certs/node1/node1.crt
|
||||
- EVENTSTORE_CERTIFICATE_PRIVATE_KEY_FILE=/etc/eventstore/certs/node1/node1.key
|
||||
- EVENTSTORE_TRUSTED_ROOT_CERTIFICATES_PATH=/etc/eventstore/certs/ca
|
||||
expose:
|
||||
- "1112"
|
||||
- "1113"
|
||||
- "2113"
|
||||
ports:
|
||||
- "1112:1112"
|
||||
- "1113:1113"
|
||||
@ -39,15 +35,15 @@ services:
|
||||
- eventstore1-data:/var/lib/eventstore
|
||||
- ./certs:/etc/eventstore/certs:ro
|
||||
|
||||
eventstore2:
|
||||
image: eventstore/eventstore:22.10.0-buster-slim
|
||||
eventstore.db2:
|
||||
image: eventstore/eventstore:21.10.8-buster-slim
|
||||
environment:
|
||||
- EVENTSTORE_CLUSTER_SIZE=3
|
||||
- EVENTSTORE_CLUSTER_DNS=cluster.tests.node-eventstore-client.local
|
||||
- EVENTSTORE_ADVERTISE_HOST_TO_CLIENT_AS=node2.tests.node-eventstore-client.local
|
||||
- EVENTSTORE_ADVERTISE_HTTP_PORT_TO_CLIENT_AS=2113
|
||||
- EVENTSTORE_ADVERTISE_TCP_PORT_TO_CLIENT_AS=1113
|
||||
# - EVENTSTORE_DISCOVER_VIA_DNS=False
|
||||
# - EVENTSTORE_DISCOVER_VIA_DNS=false
|
||||
# - EVENTSTORE_GOSSIP_SEED=192.168.33.10:2113,192.168.33.11:2113,192.168.33.12:2113
|
||||
- EVENTSTORE_RUN_PROJECTIONS=All
|
||||
- EVENTSTORE_START_STANDARD_PROJECTIONS=True
|
||||
@ -73,15 +69,15 @@ services:
|
||||
- eventstore2-data:/var/lib/eventstore
|
||||
- ./certs:/etc/eventstore/certs:ro
|
||||
|
||||
eventstore3:
|
||||
image: eventstore/eventstore:22.10.0-buster-slim
|
||||
eventstore.db3:
|
||||
image: eventstore/eventstore:21.10.8-buster-slim
|
||||
environment:
|
||||
- EVENTSTORE_CLUSTER_SIZE=3
|
||||
- EVENTSTORE_CLUSTER_DNS=cluster.tests.node-eventstore-client.local
|
||||
- EVENTSTORE_ADVERTISE_HOST_TO_CLIENT_AS=node3.tests.node-eventstore-client.local
|
||||
- EVENTSTORE_ADVERTISE_HTTP_PORT_TO_CLIENT_AS=2113
|
||||
- EVENTSTORE_ADVERTISE_TCP_PORT_TO_CLIENT_AS=1113
|
||||
# - EVENTSTORE_DISCOVER_VIA_DNS=False
|
||||
# - EVENTSTORE_DISCOVER_VIA_DNS=false
|
||||
# - EVENTSTORE_GOSSIP_SEED=192.168.33.10:2113,192.168.33.11:2113,192.168.33.12:2113
|
||||
- EVENTSTORE_RUN_PROJECTIONS=All
|
||||
- EVENTSTORE_START_STANDARD_PROJECTIONS=True
|
||||
@ -108,18 +104,14 @@ services:
|
||||
- ./certs:/etc/eventstore/certs:ro
|
||||
|
||||
nodejs:
|
||||
image: node:14
|
||||
working_dir: /var/build
|
||||
image: node:12
|
||||
working_dir: /var/code
|
||||
volumes:
|
||||
- ./:/var/code:ro
|
||||
- ./build-and-test.sh:/var/build/build-and-test.sh:ro
|
||||
- ./certs:/var/certs:ro
|
||||
environment:
|
||||
- NODE_EXTRA_CA_CERTS=/var/certs/ca/ca.crt
|
||||
- .:/var/code
|
||||
- /var/code/node_modules
|
||||
command: bash -c "tail -f /dev/null"
|
||||
networks:
|
||||
app_net:
|
||||
ipv4_address: 192.168.33.5
|
||||
- app_net
|
||||
|
||||
volumes:
|
||||
eventstore1-data:
|
||||
|
||||
@ -1,8 +1,8 @@
|
||||
version: '3.4'
|
||||
|
||||
services:
|
||||
eventstore:
|
||||
image: eventstore/eventstore:22.10.0-buster-slim
|
||||
eventstore.db:
|
||||
image: eventstore/eventstore:21.10.8-buster-slim
|
||||
environment:
|
||||
- EVENTSTORE_CLUSTER_SIZE=1
|
||||
- EVENTSTORE_RUN_PROJECTIONS=All
|
||||
@ -18,30 +18,22 @@ services:
|
||||
ports:
|
||||
- "1113:1113"
|
||||
- "2113:2113"
|
||||
tmpfs:
|
||||
- /var/log/eventstore
|
||||
volumes:
|
||||
- eventstore-data:/var/lib/eventstore
|
||||
- ./certs:/etc/eventstore/certs:ro
|
||||
networks:
|
||||
app_net:
|
||||
aliases:
|
||||
- node1.tests.node-eventstore-client.local
|
||||
ipv4_address: 192.168.33.10
|
||||
|
||||
nodejs:
|
||||
image: node:14
|
||||
working_dir: /var/build
|
||||
image: node:12
|
||||
working_dir: /var/code
|
||||
volumes:
|
||||
- ./:/var/code:ro
|
||||
- ./build-and-test.sh:/var/build/build-and-test.sh:ro
|
||||
- ./certs:/var/certs:ro
|
||||
environment:
|
||||
- NODE_EXTRA_CA_CERTS=/var/certs/ca/ca.crt
|
||||
- .:/var/code
|
||||
- /var/code/node_modules
|
||||
command: bash -c "tail -f /dev/null"
|
||||
networks:
|
||||
app_net:
|
||||
ipv4_address: 192.168.33.5
|
||||
- app_net
|
||||
|
||||
volumes:
|
||||
eventstore-data:
|
||||
|
||||
10869
package-lock.json
generated
10869
package-lock.json
generated
File diff suppressed because it is too large
Load Diff
25
package.json
25
package.json
@ -1,18 +1,17 @@
|
||||
{
|
||||
"name": "node-eventstore-client",
|
||||
"version": "22.10.0",
|
||||
"version": "21.10.0",
|
||||
"description": "A port of the EventStore .Net ClientAPI to Node.js",
|
||||
"main": "index.js",
|
||||
"types": "index.d.ts",
|
||||
"engines": {
|
||||
"node": ">=14",
|
||||
"npm": ">=6"
|
||||
"node": ">=12"
|
||||
},
|
||||
"engineStrict": true,
|
||||
"scripts": {
|
||||
"clean": "rm -f lib/dist.js",
|
||||
"prebuild": "npm run clean",
|
||||
"build": "webpack",
|
||||
"build": "webpack -o ./lib/dist.js",
|
||||
"pretest": "npm run build",
|
||||
"test": "nodeunit",
|
||||
"test-debug": "TESTS_VERBOSE_LOGGING=1 nodeunit",
|
||||
@ -25,9 +24,9 @@
|
||||
"compose:single:stop": "docker-compose -f docker-compose-single.yaml down -v --remove-orphans",
|
||||
"compose:cluster:stop": "docker-compose -f docker-compose-cluster.yaml down -v --remove-orphans",
|
||||
"compose:wait": "while [ \"$(curl -s -o /dev/null -w ''%{http_code}'' -k https://localhost:2113/ping)\" != \"200\" ]; do sleep 5; done",
|
||||
"compose:single:test": "docker-compose -f docker-compose-single.yaml exec nodejs bash -c \"EVENTSTORE_CONNECTION_TYPE=tcp EVENTSTORE_HOST=192.168.33.10 ./build-and-test.sh\"",
|
||||
"compose:gossip:test": "docker-compose -f docker-compose-cluster.yaml exec nodejs bash -c \"EVENTSTORE_CONNECTION_TYPE=gossip EVENTSTORE_HOST=192.168.33.10 EVENTSTORE_HOST_1=192.168.33.10 EVENTSTORE_HOST_2=192.168.33.11 EVENTSTORE_HOST_3=192.168.33.12 ./build-and-test.sh\"",
|
||||
"compose:cluster:test": "docker-compose -f docker-compose-cluster.yaml exec nodejs bash -c \"EVENTSTORE_CONNECTION_TYPE=dns EVENTSTORE_HOST=cluster.tests.node-eventstore-client.local ./build-and-test.sh\"",
|
||||
"compose:single:test": "docker-compose -f docker-compose-single.yaml exec nodejs bash -c \"npm i && npm run build && EVENTSTORE_CONNECTION_TYPE=tcp EVENTSTORE_HOST=192.168.33.10 npm run test-debug\"",
|
||||
"compose:cluster:test": "docker-compose -f docker-compose-cluster.yaml exec nodejs bash -c \"npm i && npm run build && EVENTSTORE_CONNECTION_TYPE=gossip EVENTSTORE_HOST=192.168.33.10 EVENTSTORE_HOST_1=192.168.33.10 EVENTSTORE_HOST_2=192.168.33.11 EVENTSTORE_HOST_3=192.168.33.12 npm run test-debug\"",
|
||||
"compose:gossip:test": "docker-compose -f docker-compose-cluster.yaml exec nodejs bash -c \"npm i && npm run build && EVENTSTORE_CONNECTION_TYPE=dns EVENTSTORE_HOST=192.168.33.10 npm run test-debug\"",
|
||||
"prepublishOnly": "npm run build && npm run gendocs",
|
||||
"gendocs": "rm -rf docs && jsdoc src -r -d docs"
|
||||
},
|
||||
@ -59,18 +58,18 @@
|
||||
},
|
||||
"homepage": "https://github.com/nicdex/node-eventstore-client#readme",
|
||||
"dependencies": {
|
||||
"@types/node": ">=14",
|
||||
"@types/node": ">=12",
|
||||
"long": "^5.2.0",
|
||||
"protobufjs": "^7.1.2",
|
||||
"protobufjs-cli": "^1.0.2",
|
||||
"strict-event-emitter-types": "^1.2.0",
|
||||
"uuid": "^9.0.0"
|
||||
},
|
||||
"devDependencies": {
|
||||
"jest": "^29.4.1",
|
||||
"jsdoc": "^4.0.0",
|
||||
"jest": "^26.4.2",
|
||||
"jsdoc": "^3.6.3",
|
||||
"nodeunit": "^0.11.3",
|
||||
"protobufjs": "^7.2.0",
|
||||
"protobufjs-cli": "^1.1.0",
|
||||
"webpack": "^5.75.0",
|
||||
"webpack": "^4.41.2",
|
||||
"webpack-cli": "^3.3.10"
|
||||
}
|
||||
}
|
||||
|
||||
29022
src/messages/messages.js
29022
src/messages/messages.js
File diff suppressed because it is too large
Load Diff
@ -1,4 +1,4 @@
|
||||
syntax = "proto3";
|
||||
syntax = "proto2";
|
||||
|
||||
package EventStore.Client.Messages;
|
||||
|
||||
@ -15,115 +15,115 @@ enum OperationResult
|
||||
}
|
||||
|
||||
message NewEvent {
|
||||
bytes event_id = 1;
|
||||
string event_type = 2;
|
||||
int32 data_content_type = 3;
|
||||
int32 metadata_content_type = 4;
|
||||
bytes data = 5;
|
||||
bytes metadata = 6;
|
||||
required bytes event_id = 1;
|
||||
required string event_type = 2;
|
||||
required int32 data_content_type = 3;
|
||||
required int32 metadata_content_type = 4;
|
||||
required bytes data = 5;
|
||||
optional bytes metadata = 6;
|
||||
}
|
||||
|
||||
message EventRecord {
|
||||
string event_stream_id = 1;
|
||||
int64 event_number = 2;
|
||||
bytes event_id = 3;
|
||||
string event_type = 4;
|
||||
int32 data_content_type = 5;
|
||||
int32 metadata_content_type = 6;
|
||||
bytes data = 7;
|
||||
bytes metadata = 8;
|
||||
int64 created = 9;
|
||||
int64 created_epoch = 10;
|
||||
required string event_stream_id = 1;
|
||||
required int64 event_number = 2;
|
||||
required bytes event_id = 3;
|
||||
required string event_type = 4;
|
||||
required int32 data_content_type = 5;
|
||||
required int32 metadata_content_type = 6;
|
||||
required bytes data = 7;
|
||||
optional bytes metadata = 8;
|
||||
optional int64 created = 9;
|
||||
optional int64 created_epoch = 10;
|
||||
}
|
||||
|
||||
message ResolvedIndexedEvent {
|
||||
EventRecord event = 1;
|
||||
EventRecord link = 2;
|
||||
optional EventRecord event = 1;
|
||||
optional EventRecord link = 2;
|
||||
}
|
||||
|
||||
message ResolvedEvent {
|
||||
EventRecord event = 1;
|
||||
EventRecord link = 2;
|
||||
int64 commit_position = 3;
|
||||
int64 prepare_position = 4;
|
||||
optional EventRecord event = 1;
|
||||
optional EventRecord link = 2;
|
||||
required int64 commit_position = 3;
|
||||
required int64 prepare_position = 4;
|
||||
}
|
||||
|
||||
message WriteEvents {
|
||||
string event_stream_id = 1;
|
||||
int64 expected_version = 2;
|
||||
required string event_stream_id = 1;
|
||||
required int64 expected_version = 2;
|
||||
repeated NewEvent events = 3;
|
||||
bool require_leader = 4;
|
||||
required bool require_leader = 4;
|
||||
}
|
||||
|
||||
message WriteEventsCompleted {
|
||||
OperationResult result = 1;
|
||||
string message = 2;
|
||||
int64 first_event_number = 3;
|
||||
int64 last_event_number = 4;
|
||||
int64 prepare_position = 5;
|
||||
int64 commit_position = 6;
|
||||
int64 current_version = 7;
|
||||
required OperationResult result = 1;
|
||||
optional string message = 2;
|
||||
required int64 first_event_number = 3;
|
||||
required int64 last_event_number = 4;
|
||||
optional int64 prepare_position = 5;
|
||||
optional int64 commit_position = 6;
|
||||
optional int64 current_version = 7;
|
||||
}
|
||||
|
||||
message DeleteStream {
|
||||
string event_stream_id = 1;
|
||||
int64 expected_version = 2;
|
||||
bool require_leader = 3;
|
||||
bool hard_delete = 4;
|
||||
required string event_stream_id = 1;
|
||||
required int64 expected_version = 2;
|
||||
required bool require_leader = 3;
|
||||
optional bool hard_delete = 4;
|
||||
}
|
||||
|
||||
message DeleteStreamCompleted {
|
||||
OperationResult result = 1;
|
||||
string message = 2;
|
||||
int64 prepare_position = 3;
|
||||
int64 commit_position = 4;
|
||||
int64 current_version = 5;
|
||||
required OperationResult result = 1;
|
||||
optional string message = 2;
|
||||
optional int64 prepare_position = 3;
|
||||
optional int64 commit_position = 4;
|
||||
optional int64 current_version = 5;
|
||||
}
|
||||
|
||||
message TransactionStart {
|
||||
string event_stream_id = 1;
|
||||
int64 expected_version = 2;
|
||||
bool require_leader = 3;
|
||||
required string event_stream_id = 1;
|
||||
required int64 expected_version = 2;
|
||||
required bool require_leader = 3;
|
||||
}
|
||||
|
||||
message TransactionStartCompleted {
|
||||
int64 transaction_id = 1;
|
||||
OperationResult result = 2;
|
||||
string message = 3;
|
||||
required int64 transaction_id = 1;
|
||||
required OperationResult result = 2;
|
||||
optional string message = 3;
|
||||
}
|
||||
|
||||
message TransactionWrite {
|
||||
int64 transaction_id = 1;
|
||||
required int64 transaction_id = 1;
|
||||
repeated NewEvent events = 2;
|
||||
bool require_leader = 3;
|
||||
required bool require_leader = 3;
|
||||
}
|
||||
|
||||
message TransactionWriteCompleted {
|
||||
int64 transaction_id = 1;
|
||||
OperationResult result = 2;
|
||||
string message = 3;
|
||||
required int64 transaction_id = 1;
|
||||
required OperationResult result = 2;
|
||||
optional string message = 3;
|
||||
}
|
||||
|
||||
message TransactionCommit {
|
||||
int64 transaction_id = 1;
|
||||
bool require_leader = 2;
|
||||
required int64 transaction_id = 1;
|
||||
required bool require_leader = 2;
|
||||
}
|
||||
|
||||
message TransactionCommitCompleted {
|
||||
int64 transaction_id = 1;
|
||||
OperationResult result = 2;
|
||||
string message = 3;
|
||||
int64 first_event_number = 4;
|
||||
int64 last_event_number = 5;
|
||||
int64 prepare_position = 6;
|
||||
int64 commit_position = 7;
|
||||
required int64 transaction_id = 1;
|
||||
required OperationResult result = 2;
|
||||
optional string message = 3;
|
||||
required int64 first_event_number = 4;
|
||||
required int64 last_event_number = 5;
|
||||
optional int64 prepare_position = 6;
|
||||
optional int64 commit_position = 7;
|
||||
}
|
||||
|
||||
message ReadEvent {
|
||||
string event_stream_id = 1;
|
||||
int64 event_number = 2;
|
||||
bool resolve_link_tos = 3;
|
||||
bool require_leader = 4;
|
||||
required string event_stream_id = 1;
|
||||
required int64 event_number = 2;
|
||||
required bool resolve_link_tos = 3;
|
||||
required bool require_leader = 4;
|
||||
}
|
||||
|
||||
message ReadEventCompleted {
|
||||
@ -137,18 +137,18 @@ message ReadEventCompleted {
|
||||
AccessDenied = 5;
|
||||
}
|
||||
|
||||
ReadEventResult result = 1;
|
||||
ResolvedIndexedEvent event = 2;
|
||||
required ReadEventResult result = 1;
|
||||
required ResolvedIndexedEvent event = 2;
|
||||
|
||||
string error = 3;
|
||||
optional string error = 3;
|
||||
}
|
||||
|
||||
message ReadStreamEvents {
|
||||
string event_stream_id = 1;
|
||||
int64 from_event_number = 2;
|
||||
int32 max_count = 3;
|
||||
bool resolve_link_tos = 4;
|
||||
bool require_leader = 5;
|
||||
required string event_stream_id = 1;
|
||||
required int64 from_event_number = 2;
|
||||
required int32 max_count = 3;
|
||||
required bool resolve_link_tos = 4;
|
||||
required bool require_leader = 5;
|
||||
}
|
||||
|
||||
message ReadStreamEventsCompleted {
|
||||
@ -163,21 +163,21 @@ message ReadStreamEventsCompleted {
|
||||
}
|
||||
|
||||
repeated ResolvedIndexedEvent events = 1;
|
||||
ReadStreamResult result = 2;
|
||||
int64 next_event_number = 3;
|
||||
int64 last_event_number = 4;
|
||||
bool is_end_of_stream = 5;
|
||||
int64 last_commit_position = 6;
|
||||
required ReadStreamResult result = 2;
|
||||
required int64 next_event_number = 3;
|
||||
required int64 last_event_number = 4;
|
||||
required bool is_end_of_stream = 5;
|
||||
required int64 last_commit_position = 6;
|
||||
|
||||
string error = 7;
|
||||
optional string error = 7;
|
||||
}
|
||||
|
||||
message ReadAllEvents {
|
||||
int64 commit_position = 1;
|
||||
int64 prepare_position = 2;
|
||||
int32 max_count = 3;
|
||||
bool resolve_link_tos = 4;
|
||||
bool require_leader = 5;
|
||||
required int64 commit_position = 1;
|
||||
required int64 prepare_position = 2;
|
||||
required int32 max_count = 3;
|
||||
required bool resolve_link_tos = 4;
|
||||
required bool require_leader = 5;
|
||||
}
|
||||
|
||||
message ReadAllEventsCompleted {
|
||||
@ -189,14 +189,14 @@ message ReadAllEventsCompleted {
|
||||
AccessDenied = 3;
|
||||
}
|
||||
|
||||
int64 commit_position = 1;
|
||||
int64 prepare_position = 2;
|
||||
required int64 commit_position = 1;
|
||||
required int64 prepare_position = 2;
|
||||
repeated ResolvedEvent events = 3;
|
||||
int64 next_commit_position = 4;
|
||||
int64 next_prepare_position = 5;
|
||||
required int64 next_commit_position = 4;
|
||||
required int64 next_prepare_position = 5;
|
||||
|
||||
ReadAllResult result = 6;
|
||||
string error = 7;
|
||||
optional ReadAllResult result = 6 [default = Success];
|
||||
optional string error = 7;
|
||||
}
|
||||
|
||||
message Filter{
|
||||
@ -212,19 +212,19 @@ message Filter{
|
||||
Prefix = 1;
|
||||
}
|
||||
|
||||
FilterContext context = 1;
|
||||
FilterType type = 2;
|
||||
required FilterContext context = 1;
|
||||
required FilterType type = 2;
|
||||
repeated string data = 3;
|
||||
}
|
||||
|
||||
message FilteredReadAllEvents {
|
||||
int64 commit_position = 1;
|
||||
int64 prepare_position = 2;
|
||||
int32 max_count = 3;
|
||||
int32 max_search_window = 4;
|
||||
bool resolve_link_tos = 5;
|
||||
bool require_leader = 6;
|
||||
Filter filter = 7;
|
||||
required int64 commit_position = 1;
|
||||
required int64 prepare_position = 2;
|
||||
required int32 max_count = 3;
|
||||
optional int32 max_search_window = 4;
|
||||
required bool resolve_link_tos = 5;
|
||||
required bool require_leader = 6;
|
||||
required Filter filter = 7;
|
||||
}
|
||||
|
||||
message FilteredReadAllEventsCompleted {
|
||||
@ -236,58 +236,58 @@ message FilteredReadAllEventsCompleted {
|
||||
AccessDenied = 3;
|
||||
}
|
||||
|
||||
int64 commit_position = 1;
|
||||
int64 prepare_position = 2;
|
||||
required int64 commit_position = 1;
|
||||
required int64 prepare_position = 2;
|
||||
repeated ResolvedEvent events = 3;
|
||||
int64 next_commit_position = 4;
|
||||
int64 next_prepare_position = 5;
|
||||
bool is_end_of_stream = 6;
|
||||
required int64 next_commit_position = 4;
|
||||
required int64 next_prepare_position = 5;
|
||||
required bool is_end_of_stream = 6;
|
||||
|
||||
FilteredReadAllResult result = 7;
|
||||
string error = 8;
|
||||
optional FilteredReadAllResult result = 7 [default = Success];
|
||||
optional string error = 8;
|
||||
}
|
||||
|
||||
message CreatePersistentSubscription {
|
||||
string subscription_group_name = 1;
|
||||
string event_stream_id = 2;
|
||||
bool resolve_link_tos = 3;
|
||||
int64 start_from = 4;
|
||||
int32 message_timeout_milliseconds = 5;
|
||||
bool record_statistics = 6;
|
||||
int32 live_buffer_size = 7;
|
||||
int32 read_batch_size = 8;
|
||||
int32 buffer_size = 9;
|
||||
int32 max_retry_count = 10;
|
||||
bool prefer_round_robin = 11;
|
||||
int32 checkpoint_after_time = 12;
|
||||
int32 checkpoint_max_count = 13;
|
||||
int32 checkpoint_min_count = 14;
|
||||
int32 subscriber_max_count = 15;
|
||||
string named_consumer_strategy = 16;
|
||||
required string subscription_group_name = 1;
|
||||
required string event_stream_id = 2;
|
||||
required bool resolve_link_tos = 3;
|
||||
required int64 start_from = 4;
|
||||
required int32 message_timeout_milliseconds = 5;
|
||||
required bool record_statistics = 6;
|
||||
required int32 live_buffer_size = 7;
|
||||
required int32 read_batch_size = 8;
|
||||
required int32 buffer_size = 9;
|
||||
required int32 max_retry_count = 10;
|
||||
required bool prefer_round_robin = 11;
|
||||
required int32 checkpoint_after_time = 12;
|
||||
required int32 checkpoint_max_count = 13;
|
||||
required int32 checkpoint_min_count = 14;
|
||||
required int32 subscriber_max_count = 15;
|
||||
optional string named_consumer_strategy = 16;
|
||||
}
|
||||
|
||||
message DeletePersistentSubscription {
|
||||
string subscription_group_name = 1;
|
||||
string event_stream_id = 2;
|
||||
required string subscription_group_name = 1;
|
||||
required string event_stream_id = 2;
|
||||
}
|
||||
|
||||
message UpdatePersistentSubscription {
|
||||
string subscription_group_name = 1;
|
||||
string event_stream_id = 2;
|
||||
bool resolve_link_tos = 3;
|
||||
int64 start_from = 4;
|
||||
int32 message_timeout_milliseconds = 5;
|
||||
bool record_statistics = 6;
|
||||
int32 live_buffer_size = 7;
|
||||
int32 read_batch_size = 8;
|
||||
int32 buffer_size = 9;
|
||||
int32 max_retry_count = 10;
|
||||
bool prefer_round_robin = 11;
|
||||
int32 checkpoint_after_time = 12;
|
||||
int32 checkpoint_max_count = 13;
|
||||
int32 checkpoint_min_count = 14;
|
||||
int32 subscriber_max_count = 15;
|
||||
string named_consumer_strategy = 16;
|
||||
required string subscription_group_name = 1;
|
||||
required string event_stream_id = 2;
|
||||
required bool resolve_link_tos = 3;
|
||||
required int64 start_from = 4;
|
||||
required int32 message_timeout_milliseconds = 5;
|
||||
required bool record_statistics = 6;
|
||||
required int32 live_buffer_size = 7;
|
||||
required int32 read_batch_size = 8;
|
||||
required int32 buffer_size = 9;
|
||||
required int32 max_retry_count = 10;
|
||||
required bool prefer_round_robin = 11;
|
||||
required int32 checkpoint_after_time = 12;
|
||||
required int32 checkpoint_max_count = 13;
|
||||
required int32 checkpoint_min_count = 14;
|
||||
required int32 subscriber_max_count = 15;
|
||||
optional string named_consumer_strategy = 16;
|
||||
}
|
||||
|
||||
message UpdatePersistentSubscriptionCompleted {
|
||||
@ -297,8 +297,8 @@ message UpdatePersistentSubscriptionCompleted {
|
||||
Fail = 2;
|
||||
AccessDenied=3;
|
||||
}
|
||||
UpdatePersistentSubscriptionResult result = 1;
|
||||
string reason = 2;
|
||||
required UpdatePersistentSubscriptionResult result = 1 [default = Success];
|
||||
optional string reason = 2;
|
||||
}
|
||||
|
||||
message CreatePersistentSubscriptionCompleted {
|
||||
@ -308,8 +308,8 @@ message CreatePersistentSubscriptionCompleted {
|
||||
Fail = 2;
|
||||
AccessDenied=3;
|
||||
}
|
||||
CreatePersistentSubscriptionResult result = 1;
|
||||
string reason = 2;
|
||||
required CreatePersistentSubscriptionResult result = 1 [default = Success];
|
||||
optional string reason = 2;
|
||||
}
|
||||
|
||||
message DeletePersistentSubscriptionCompleted {
|
||||
@ -319,19 +319,19 @@ message DeletePersistentSubscriptionCompleted {
|
||||
Fail = 2;
|
||||
AccessDenied = 3;
|
||||
}
|
||||
DeletePersistentSubscriptionResult result = 1;
|
||||
string reason = 2;
|
||||
required DeletePersistentSubscriptionResult result = 1 [default = Success];
|
||||
optional string reason = 2;
|
||||
}
|
||||
|
||||
message ConnectToPersistentSubscription {
|
||||
string subscription_id = 1;
|
||||
string event_stream_id = 2;
|
||||
int32 allowed_in_flight_messages = 3;
|
||||
required string subscription_id = 1;
|
||||
required string event_stream_id = 2;
|
||||
required int32 allowed_in_flight_messages = 3;
|
||||
|
||||
}
|
||||
|
||||
message PersistentSubscriptionAckEvents {
|
||||
string subscription_id = 1;
|
||||
required string subscription_id = 1;
|
||||
repeated bytes processed_event_ids = 2;
|
||||
}
|
||||
|
||||
@ -344,47 +344,47 @@ message PersistentSubscriptionNakEvents {
|
||||
Stop = 4;
|
||||
}
|
||||
|
||||
string subscription_id = 1;
|
||||
required string subscription_id = 1;
|
||||
repeated bytes processed_event_ids = 2;
|
||||
string message = 3;
|
||||
NakAction action = 4;
|
||||
optional string message = 3;
|
||||
required NakAction action = 4 [default = Unknown];
|
||||
}
|
||||
|
||||
message PersistentSubscriptionConfirmation {
|
||||
int64 last_commit_position = 1;
|
||||
string subscription_id = 2;
|
||||
int64 last_event_number = 3;
|
||||
required int64 last_commit_position = 1;
|
||||
required string subscription_id = 2;
|
||||
optional int64 last_event_number = 3;
|
||||
}
|
||||
|
||||
message PersistentSubscriptionStreamEventAppeared {
|
||||
ResolvedIndexedEvent event = 1;
|
||||
int32 retryCount = 2;
|
||||
required ResolvedIndexedEvent event = 1;
|
||||
optional int32 retryCount = 2;
|
||||
}
|
||||
|
||||
message SubscribeToStream {
|
||||
string event_stream_id = 1;
|
||||
bool resolve_link_tos = 2;
|
||||
required string event_stream_id = 1;
|
||||
required bool resolve_link_tos = 2;
|
||||
}
|
||||
|
||||
message FilteredSubscribeToStream {
|
||||
string event_stream_id = 1;
|
||||
bool resolve_link_tos = 2;
|
||||
Filter filter = 3;
|
||||
int32 checkpoint_interval = 4;
|
||||
required string event_stream_id = 1;
|
||||
required bool resolve_link_tos = 2;
|
||||
required Filter filter = 3;
|
||||
required int32 checkpoint_interval = 4;
|
||||
}
|
||||
|
||||
message CheckpointReached {
|
||||
int64 commit_position = 1;
|
||||
int64 prepare_position = 2;
|
||||
required int64 commit_position = 1;
|
||||
required int64 prepare_position = 2;
|
||||
}
|
||||
|
||||
message SubscriptionConfirmation {
|
||||
int64 last_commit_position = 1;
|
||||
int64 last_event_number = 2;
|
||||
required int64 last_commit_position = 1;
|
||||
optional int64 last_event_number = 2;
|
||||
}
|
||||
|
||||
message StreamEventAppeared {
|
||||
ResolvedEvent event = 1;
|
||||
required ResolvedEvent event = 1;
|
||||
}
|
||||
|
||||
message UnsubscribeFromStream {
|
||||
@ -400,7 +400,7 @@ message SubscriptionDropped {
|
||||
SubscriberMaxCountReached=4;
|
||||
}
|
||||
|
||||
SubscriptionDropReason reason = 1;
|
||||
optional SubscriptionDropReason reason = 1 [default = Unsubscribed];
|
||||
}
|
||||
|
||||
message NotHandled {
|
||||
@ -412,16 +412,16 @@ message NotHandled {
|
||||
IsReadOnly = 3;
|
||||
}
|
||||
|
||||
NotHandledReason reason = 1;
|
||||
bytes additional_info = 2;
|
||||
required NotHandledReason reason = 1;
|
||||
optional bytes additional_info = 2;
|
||||
|
||||
message LeaderInfo {
|
||||
string external_tcp_address = 1;
|
||||
int32 external_tcp_port = 2;
|
||||
string http_address = 3;
|
||||
int32 http_port = 4;
|
||||
string external_secure_tcp_address = 5;
|
||||
int32 external_secure_tcp_port = 6;
|
||||
optional string external_tcp_address = 1;
|
||||
optional int32 external_tcp_port = 2;
|
||||
required string http_address = 3;
|
||||
required int32 http_port = 4;
|
||||
optional string external_secure_tcp_address = 5;
|
||||
optional int32 external_secure_tcp_port = 6;
|
||||
}
|
||||
}
|
||||
|
||||
@ -436,14 +436,14 @@ message ScavengeDatabaseResponse {
|
||||
Unauthorized = 2;
|
||||
}
|
||||
|
||||
ScavengeResult result = 1;
|
||||
string scavengeId = 2;
|
||||
required ScavengeResult result = 1;
|
||||
optional string scavengeId = 2;
|
||||
|
||||
}
|
||||
|
||||
message IdentifyClient {
|
||||
int32 version = 1;
|
||||
string connection_name = 2;
|
||||
required int32 version = 1;
|
||||
optional string connection_name = 2;
|
||||
}
|
||||
|
||||
message ClientIdentified {
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user