70aa6cd295
api/channel_test.go: rearange fields.
2024-10-16 16:23:03 +02:00
c769b6a700
typo fixes and added comments
2024-08-26 13:11:32 +02:00
a466392b84
use github.com/shufflingpixels/jsontime-go instead of github.com/eosswedenorg-go/jsontime
2024-06-23 11:33:35 +02:00
2b3dc35393
jsontime: skip aliases and use actual format and location
...
This is so weird. this works in tests but not when running the
application. I guess there is some weird global state race condition
going on because its used by antelope-go.
Should rewrite the jsontime api because I have forked it anyway.
2024-06-22 17:39:10 +02:00
5b02dfa53f
jsontime: use struct tags instead of setting default format.
...
Some other package (antelope-go in this case) also sets the default
format and therefore it clashes with our code.
2024-06-22 16:19:48 +02:00
aeac190c94
Minor fixes.
2024-03-07 18:09:14 +01:00
4c843f16bf
api/README.md: update.
2024-03-05 15:00:04 +01:00
cbe791d7df
api/message/msgpack/codec_test.go: fix tests.
2024-02-29 19:11:25 +01:00
212a8c892c
api/message/json/codec_test.go: fix tests.
2024-02-29 16:15:54 +01:00
700d7d0168
api/message/types.go: Adding FirstReceiver to ActionTrace
2024-02-29 14:41:56 +01:00
d862788b8d
Add api/README.md
2024-02-07 17:56:19 +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
0b3b383977
Merge branch 'table-deltas'
2024-01-21 14:01:08 +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
5b5b28669a
api/message/types.go: Adding RollbackMessage struct
2024-01-09 15:49:20 +01:00
8321c1633a
api/channel.go: Adding rollback channel.
2024-01-07 19:25:57 +01:00
8dbf411b36
api/channel.go: adding TableDelta channel
2024-01-07 19:11:55 +01:00
dc3e59ad23
api/message/json/codec.go: minor fix.
2024-01-07 14:33:46 +01:00
8ffd86daac
api/message: for codec implementations, define a function instead of global variables.
2024-01-07 14:32:00 +01:00
24bf44a175
move writer interface and redis publish from api module as these are for the server side.
2023-11-25 15:14:21 +01:00
d6d9fa5ca0
api/go.mod: require at least go 1.20
2023-10-22 20:37:23 +02:00
cfc6cb9e42
api/client_test.go: test segfaults sometimes because of nil pointers. so setup mock structs and functions.
2023-06-05 17:53:03 +02:00
fd5ecf4268
Merge remote-tracking branch 'origin/21-add-actiontracereceipt'
2023-06-05 17:25:04 +02:00
a91df0c39e
Upgrade from redis v8 to v9
2023-06-05 16:55:15 +02:00
c2d60a1240
api/redis/publisher.go: pass context as first parameter to NewPublisher()
2023-06-05 13:24:14 +02:00
f9124c2864
api/redis/subscriber.go: Adding context as first parameter to NewSubscriber()
2023-06-05 13:21:57 +02:00
9d2b621b27
api/message/msgpack/codec_test.go: Test ActionReceipt.
2023-05-26 15:11:59 +02:00
e2962c719b
api/message/json/codec_test.go: Test ActionReceipt.
2023-05-26 15:11:39 +02:00
7041f4328c
api/message/types.go: Adding ActionReceipt type
2023-05-26 15:11:06 +02:00
c34603325e
api/message/msgpack/codec_test.go: remove outcommented code.
2023-05-26 15:08:41 +02:00
8154bee1c2
api/client.go: implement Client.Subscribe correctly by returning a error on unsupported channel type.
2023-05-26 14:10:01 +02:00
9e586d879d
api/channel.go: Adding Channel.Type()
2023-05-26 14:09:07 +02:00
