|
|
5136b835a2
|
Adding api/message/protobuf
|
2023-04-26 14:33:12 +02:00 |
|
|
|
ffb5a10788
|
Adding docs/redis-channels.md
|
2023-04-26 14:31:54 +02:00 |
|
|
|
5fc83635be
|
api/channel.go: change transaction channel from "transaction" to "transactions"
|
2023-04-26 14:30:31 +02:00 |
|
|
|
76464c5b7d
|
config.example.yml: ship.url should have "ws://"
|
2023-04-26 14:17:14 +02:00 |
|
|
|
dd562b4231
|
Adding README.md
|
2023-04-26 12:30:59 +02:00 |
|
|
|
8798428b62
|
install.sh: fix config path
|
2023-04-26 12:12:22 +02:00 |
|
|
|
bd84a1c019
|
Generate new api/message/msgpack/msgpack.go
|
2023-04-26 11:42:34 +02:00 |
|
|
|
0e60e604bb
|
api/message/msgpack/codec.go: fix go:generate command
|
2023-04-26 11:41:29 +02:00 |
|
|
|
903317ba61
|
Remove app/abi/helpers.go: unused
|
2023-04-26 11:40:07 +02:00 |
|
|
|
0650845a0c
|
api/message/types.go: Change ActionTrace.Data to a byte slice and provide GetData() function that unmarshalls.
Only the client code should care about the content. So just transmit it as
a byte slice containing json data.
|
2023-04-26 11:39:58 +02:00 |
|
|
|
d5adb71bf2
|
.github/workflows/test.yml: also test api module.
|
2023-04-25 17:02:50 +02:00 |
|
|
|
b832697419
|
cmd/main/main.go: support msgpack as message encoder
|
2023-04-25 16:59:20 +02:00 |
|
|
|
2e8c228076
|
Adding api/message/msgpack
|
2023-04-25 16:58:31 +02:00 |
|
|
|
f3900bc262
|
api/message/types.go: add msgpack tags
|
2023-04-25 16:57:28 +02:00 |
|
|
|
9533e3499a
|
go.mod: downgrade go.uber.org/multierr to v1.6.0 as newer versions requires go v1.19
|
2023-04-24 18:27:05 +02:00 |
|
|
|
e4c852c99e
|
app/config/config.go: Move from json format to yaml.
|
2023-04-24 17:45:31 +02:00 |
|
|
|
bbf63e447d
|
cmd/main/main.go: Load message codec from config and pass to SpawnProccessor
|
2023-04-24 16:08:47 +02:00 |
|
|
|
f8f1d0399f
|
app/ship_processor.go: make SpawnProccessor() take in a message.Codec
|
2023-04-24 16:07:31 +02:00 |
|
|
|
3e8712c0c0
|
Adding api/message/json/codec.go
|
2023-04-24 16:06:56 +02:00 |
|
|
|
0d1b0f4310
|
Adding api/message/codec_manager.go to manager message codecs.
|
2023-04-24 16:06:23 +02:00 |
|
|
|
b5eb602e7d
|
app/config/config.go: Adding MessageCodec field.
|
2023-04-24 16:02:58 +02:00 |
|
|
|
b221b0415a
|
Typo fix. should be Heartbeat and not Hearthbeat
|
2023-04-21 15:23:13 +02:00 |
|
|
|
967de3260f
|
api/channel.go: Change Action struct name to ActionChannel
|
2023-04-21 12:28:21 +02:00 |
|
|
|
220f1976f0
|
api/redis/subscriber.go: remove client field from Subscriber struct
|
2023-04-21 11:58:16 +02:00 |
|
|
|
8881b2a529
|
api/writer.go: add documentation about low-level interface
|
2023-04-20 16:52:48 +02:00 |
|
|
|
8b981a0bc0
|
api/reader.go: improve documentation abit
|
2023-04-20 16:52:21 +02:00 |
|
|
|
c774cbf3ca
|
move config directory to app/config
|
2023-04-20 16:45:47 +02:00 |
|
|
|
a8183a6766
|
move abi directory to app/abi
|
2023-04-20 16:44:38 +02:00 |
|
|
|
da7056b2da
|
go.mod: update dependancies
|
2023-04-19 18:23:04 +02:00 |
|
|
|
ad0d4f4c28
|
make a module of the "api" packages.
|
2023-04-19 17:57:39 +02:00 |
|
|
|
b6aabef7f3
|
Adding .github/workflows/test.yml
|
2023-04-19 17:55:48 +02:00 |
|
|
|
9c4aa79c11
|
go.mod: update module name to github.com/eosswedenorg/thalos
|
2023-04-19 17:50:06 +02:00 |
|
|
|
a8bac16aa9
|
merge api/redis_common and api/redis_pubsub to api/redis
|
2023-04-19 09:56:52 +02:00 |
|
|
|
102045e47e
|
rename transport to api
|
2023-04-19 09:52:29 +02:00 |
|
|
|
044ed4e891
|
app/ship_processor.go: do not send newline in log message.
|
2023-04-18 17:31:09 +02:00 |
|
|
|
c4167d2b92
|
cmd/main/main.go: simplify ship (re)connection by removing the statemachine and using a simple bool instead.
|
2023-04-17 15:36:39 +02:00 |
|
|
|
93479506b6
|
Upgrade to github.com/eosswedenorg-go/antelope-ship-client v0.2.3
|
2023-04-17 15:28:32 +02:00 |
|
|
|
5fa1dbb504
|
config/config.go: put Ship stuff into its own struct/section and also provide a shorthand "string" value for "ship" field (only url)
|
2023-04-17 15:17:46 +02:00 |
|
|
|
e860c81601
|
transport/redis_common/key.go: use Channel.Format() instead of Channel.String()
|
2023-03-30 03:37:35 +02:00 |
|
|
|
e45259603b
|
transport/channel_test.go: dont test Action Channel with String() method. just compare Channel objects.
|
2023-03-30 03:36:43 +02:00 |
|
|
|
f76290f299
|
transport/channel.go: Add Format()
|
2023-03-30 03:35:44 +02:00 |
|
|
|
08c84d81ca
|
transport/channel_test.go: Add test for Channel.Is()
|
2023-03-30 03:35:03 +02:00 |
|
|
|
70bc689736
|
transport/reader.go: Add Close() method
|
2023-03-29 15:41:01 +02:00 |
|
|
|
65173425a6
|
transport/redis_pubsub/subscriber.go: make Close() return an error.
|
2023-03-29 15:40:37 +02:00 |
|
|
|
a23661e088
|
Change project name to "thalos" (working name).
|
2023-03-29 15:28:40 +02:00 |
|
|
|
f174863a17
|
transport/redis_pubsub/subscriber.go: implement Close()
|
2023-03-29 11:57:51 +02:00 |
|
|
|
834adb6ca8
|
cmd/main/main.go: close processor when application is done.
|
2023-03-29 11:55:42 +02:00 |
|
|
|
0034225e7a
|
move main.go to cmd/main/main.go
|
2023-03-29 11:55:13 +02:00 |
|
|
|
1f09993925
|
app/ship_processor.go: Add Close() method that closes the writer.
|
2023-03-29 11:53:11 +02:00 |
|
|
|
c225505143
|
transport/writer.go: Add Close() method.
|
2023-03-29 11:52:31 +02:00 |
|
