|
|
9974bfe3fd
|
rename app folder to internal.
|
2024-02-14 13:00:33 +01:00 |
|
|
|
afb90af1db
|
cmd/thalos/server.go: in run() set running flag to false before calling shClient.Shutdown() so readerLoop() exists correctly.
|
2024-02-13 23:14:47 +01:00 |
|
|
|
775760ec32
|
cmd/thalos/server.go: get rid of exit channel. its sufficient to just use running flag.
|
2024-02-13 23:13:51 +01:00 |
|
|
|
e723e81786
|
go mod: update dependancies
|
2024-02-13 22:20:23 +01:00 |
|
|
|
84d9df9246
|
Merge branch 'cli'
|
2024-02-12 17:59:25 +01:00 |
|
|
|
457e0e4eeb
|
cmd/thalos/server.go: define and use ReadConfig() that utilizes Config.ReadFile and Config.ReadCliFlags() methods
|
2024-02-12 15:14:21 +01:00 |
|
|
|
4a5cff20cd
|
app/config: Adding description to methods.
|
2024-02-12 15:13:09 +01:00 |
|
|
|
49faaf5325
|
Adding app/config/cli.go
|
2024-02-12 15:09:17 +01:00 |
|
|
|
57cc55b601
|
app/config/config.go: refactor yaml and file methods into their own files.
|
2024-02-12 15:08:19 +01:00 |
|
|
|
a36c3f7853
|
cmd/thalos/server.go: wrap errors returned to main (to give more context)
|
2024-02-12 14:55:02 +01:00 |
|
|
|
e5e15a7645
|
app/config/config.go: rework api.
|
2024-02-11 14:29:01 +01:00 |
|
|
|
655dd730d7
|
switch github.com/pborman/getopt to github.com/urfave/cli for handling cli flags
|
2024-02-10 18:52:50 +01:00 |
|
|
|
f99bbec5ff
|
Version 1.0.0
|
2024-02-07 19:32:24 +01:00 |
|
|
|
f08b6a3e45
|
debian/control: update email.
|
2024-02-07 19:31:13 +01:00 |
|
|
|
d862788b8d
|
Add api/README.md
|
2024-02-07 17:56:19 +01:00 |
|
|
|
729860cf76
|
cmd/tools/validate.go: log errors from client.
|
2024-02-07 17:32:03 +01:00 |
|
|
|
7feee11fad
|
api/client.go: Don't report io.EOF as an error.
|
2024-02-07 17:31:19 +01:00 |
|
|
|
daa89cf372
|
api/reader.go: Document io.EOF
|
2024-02-07 17:30:19 +01:00 |
|
|
|
d789b6a294
|
api/redis/subscriber.go: in worker() no need to spawn a goroutine when sending to the channel.
|
2024-02-07 17:29:54 +01:00 |
|
|
|
b854c1dfa7
|
api/redis/subscriber.go: in Read() return io.EOF if redis connection is closed or channel returns a empty byte slice.
|
2024-02-07 17:27:24 +01:00 |
|
|
|
816d405d31
|
api/client.go: make Subscribe support a list of channels as argument.
|
2024-02-04 22:49:49 +01:00 |
|
|
|
133af980a3
|
api/client.go: Rework to use a channel instead of callback.
|
2024-02-04 22:49:49 +01:00 |
|
|
|
a4954ab949
|
api/client_test.go: Adding test for reading rollback messages.
Because these don't happen that often on a real ship node. Test as much as possible with unit tests.
|
2024-02-04 16:56:59 +01:00 |
|
|
|
9d79bb8315
|
api/client.go: add rollback callback
|
2024-02-04 16:55:21 +01:00 |
|
|
|
021c71f50b
|
api/client.go: add Transaction callback.
|
2024-02-04 16:05:01 +01:00 |
|
|
|
38f885f0df
|
api/client.go: refactor decoding in handler functions to a helper function
|
2024-02-04 15:54:10 +01:00 |
|
|
|
728b03422f
|
api/redis/subscriber.go: adding some comments.
|
2024-02-04 15:53:24 +01:00 |
|
|
|
35a9706954
|
api/client.go: in Subscribe() handle nil handler correctly.
|
2024-02-04 15:53:24 +01:00 |
|
|
|
bcd4a93c46
|
api/client_test.go: add test for calling Subscribe with nil handler.
|
2024-02-04 14:30:59 +01:00 |
|
|
|
e7ad37c38a
|
api/client.go: add handler for table delta
|
2024-02-04 11:32:28 +01:00 |
|
|
|
9143c1e06b
|
api/message/msgpack/codec_test.go: adding test for table delta messages.
|
2024-02-03 14:06:47 +01:00 |
|
|
|
bd742e678a
|
api/message/json/codec_test.go: add tests for table delta messages.
|
2024-02-03 13:40:25 +01:00 |
|
|
|
0d8ecaea36
|
api/client.go: some comments.
|
2024-02-03 13:39:25 +01:00 |
|
|
|
e69ff9781f
|
api: update dependancies
|
2024-02-02 17:05:29 +01:00 |
|
|
|
cb14978118
|
cmd/tools/mock_publisher.go: add log message before starting.
|
2024-02-02 16:52:50 +01:00 |
|
|
|
e93cc1d139
|
tools: rename redis prefix flag to just prefix.
|
2024-02-02 16:52:31 +01:00 |
|
|
|
569eefd07a
|
go.mod: update dependancies
|
2024-02-02 16:43:02 +01:00 |
|
|
|
2b252ea24a
|
Documentation
|
2024-02-01 11:27:42 +01:00 |
|
|
|
6da433dc4d
|
Version 0.3.1
|
2024-01-22 14:47:56 +01:00 |
|
|
|
02923aadc6
|
install.sh: remove $INSTALL_DIR if installation failed.
|
2024-01-22 14:43:02 +01:00 |
|
|
|
a2491aa355
|
install.sh: improve error checking.
|
2024-01-22 14:39:14 +01:00 |
|
|
|
9e47ae54e7
|
debian/patches/0001-fix-config-logpath.patch: fix correct path.
|
2024-01-22 13:51:24 +01:00 |
|
|
|
062bdae620
|
Version 0.3.0
|
2024-01-22 00:29:45 +01:00 |
|
|
|
a3624d131e
|
app/ship_processor.go: improve logging info.
|
2024-01-21 14:09:40 +01:00 |
|
|
|
0b3b383977
|
Merge branch 'table-deltas'
|
2024-01-21 14:01:08 +01:00 |
|
|
|
5249dc1f50
|
app/ship_processor.go: process table deltas.
|
2024-01-21 14:00:03 +01:00 |
|
|
|
2268d19b08
|
app/ship_processor.go: Store abi from ship in processor.
|
2024-01-21 13:56:18 +01:00 |
|
|
|
b3961f4eec
|
api/message/types.go: Update TableDeltaRow
|
2024-01-21 13:56:18 +01:00 |
|
|
|
dc6dd6ae70
|
api/message/types.go: Adding TableDelta and TableDeltaRow structs
|
2024-01-21 13:56:18 +01:00 |
|
|
|
3866d5382c
|
app/ship_processor.go: fix a bug where GlobalSequence was passed as ActionTrace.Receipt.RecvSequence
|
2024-01-15 23:16:33 +01:00 |
|
