thalos

eosswedenorg/thalos

Fork 0

mirror of https://github.com/eosswedenorg/thalos synced 2026-07-02 11:43:40 +02:00

Commit graph

834adb6ca8 cmd/main/main.go: close processor when application is done. Henrik Hautakoski 2023-03-29 11:55:42 +02:00
0034225e7a move main.go to cmd/main/main.go Henrik Hautakoski 2023-03-29 11:55:13 +02:00
1f09993925 app/ship_processor.go: Add Close() method that closes the writer. Henrik Hautakoski 2023-03-29 11:53:11 +02:00
c225505143 transport/writer.go: Add Close() method. Henrik Hautakoski 2023-03-29 11:52:31 +02:00
1de6cd9432 transport/redis_pubsub/publisher.go: Adding Close() method. Henrik Hautakoski 2023-03-29 11:51:15 +02:00
6a5292da5e app/ship_processor.go: Return ShipProcessor object from SpawnProcessor() Henrik Hautakoski 2023-03-29 11:50:14 +02:00
bbda49ab90 transport/reader.go: document concurrency requirement of Read() Henrik Hautakoski 2023-03-29 11:38:54 +02:00
2f76057f2e WIP redis-stream-wip Henrik Hautakoski 2023-03-13 20:56:19 +01:00
531a2d3d17 Move Key and Namespace from transport/redis_pubsub to transport/redis_common Henrik Hautakoski 2023-03-08 16:28:52 +01:00
acdf827223 config/config.go: use shipclient.NULL_BLOCK_NUMBER instead of defining our own. Henrik Hautakoski 2023-03-08 15:56:45 +01:00
074c089679 WIP services Henrik Hautakoski 2023-03-08 15:51:54 +01:00
764db98417 config/config.go: Use redis and telegram config from app/serivce packages. Henrik Hautakoski 2023-03-08 14:04:20 +01:00
a2ab62afa0 Adding app/service/telegram/config.go Henrik Hautakoski 2023-03-08 14:03:40 +01:00
48f2b2dff1 Adding app/service/redis/config.go Henrik Hautakoski 2023-03-08 14:03:26 +01:00
bd5037b044 Adding transport/redis_pubsub/subscriber.go Henrik Hautakoski 2023-03-08 11:32:37 +01:00
7843dda6d9 app/ship_processor.go: Support ActionTraceV1 Henrik Hautakoski 2023-03-08 10:49:55 +01:00
454c8f7197 Adding config/config_test.go Henrik Hautakoski 2023-03-08 10:04:50 +01:00
bc5a351853 config/config.go: Refactor Load() into Parse() and Load() functions. Henrik Hautakoski 2023-03-08 10:04:12 +01:00
edaf662d50 transport/redis_pubsub/publisher_test.go: Change Publish to Write in test name. Henrik Hautakoski 2023-03-08 10:01:56 +01:00
347de718af transport/channel.go: rename Action.Action to Action.Name Henrik Hautakoski 2023-03-07 18:53:52 +01:00
7637b6e16b transport/message/types.go: Rename Action field to Name in ActionTrace struct Henrik Hautakoski 2023-03-07 18:41:41 +01:00
68c21c8ed8 transport/channel.go: Rewrite to not use a interface. Action struct has a Channel() method that returns a channel instead. Henrik Hautakoski 2023-03-07 18:35:58 +01:00
8e99146cc2 transport/channel.go: Adding Channel.Is() Henrik Hautakoski 2023-03-07 11:58:03 +01:00
7358bebc76 main.go: Minor fix. Henrik Hautakoski 2023-03-07 11:55:02 +01:00
f9fc88b0fb transport/publisher.go: rename to writer.go Henrik Hautakoski 2023-03-07 11:41:22 +01:00
b3f773655d Adding transport/reader.go Henrik Hautakoski 2023-03-07 11:35:13 +01:00
19b93495ee transport/redis_pubsub/redis.go rename to publisher.go Henrik Hautakoski 2023-03-07 11:33:53 +01:00
b46c070948 transport/message/encoding.go: make Decoder type match common Unmarshal interface. Henrik Hautakoski 2023-02-21 10:56:36 +01:00
6ca9f408f9 app/ship_processor.go: in encodeQueue() should check for err == nil, not err != nil. Henrik Hautakoski 2023-02-21 10:45:17 +01:00
315d7e19c9 transport/message/encoding.go: Add Decoder and Codec Henrik Hautakoski 2023-02-10 16:54:31 +01:00
027ba0b1ff transport/message/encoder.go: rename to encoding.go Henrik Hautakoski 2023-02-10 16:54:08 +01:00
a20295ee88 transport/message/encoder.go: remove Encode() function. Henrik Hautakoski 2023-02-10 16:50:59 +01:00
55f013a386 app/ship_processor.go: Use an message.Encoder function instead of directly calling massage.Encode() Henrik Hautakoski 2023-02-10 16:44:32 +01:00
2c3af6e4c5 transport/message/encoder.go: Define the Encoder type Henrik Hautakoski 2023-02-10 16:42:58 +01:00
38ae3a4630 transport/redis_pubsub/redis.go: No need to alias redis import. Henrik Hautakoski 2023-02-10 16:32:56 +01:00
82dce9b190 Update github.com/eosswedenorg-go/antelope-ship-client to v0.2.2 Henrik Hautakoski 2023-02-10 16:05:43 +01:00
788cc2621e main.go: os.Interrupt can be changed to syscall.SIGINT Henrik Hautakoski 2023-01-20 12:15:24 +01:00
1d6c05b402 main.go: modify signal handling to also check syscall.SIGTERM Henrik Hautakoski 2023-01-20 12:14:54 +01:00
c6a2c49f9a main.go: simplify go routines and signal handling. Henrik Hautakoski 2023-01-20 12:02:32 +01:00
af0a4d2714 transport: move key and namespace into redis_pubsub as it is redis specific. Henrik Hautakoski 2023-01-19 19:07:35 +01:00
e0bf53496a transport/message/types.go: get rid of eos-go here. Henrik Hautakoski 2023-01-19 19:04:19 +01:00
2bec1f09c5 app/ship_processor.go: remove ns from struct. should not be used here. Henrik Hautakoski 2023-01-19 17:46:47 +01:00
69a9e9f47d transport/publisher.go: pass ChannelInterface instead of string to Publish() Henrik Hautakoski 2023-01-19 17:42:26 +01:00
5202247200 move app/types.go to transport/message/types.go Henrik Hautakoski 2023-01-19 16:28:54 +01:00
0027a80af0 Move ship_processor.go and types.go into app package. Henrik Hautakoski 2023-01-19 14:07:54 +01:00
a9c512d0b0 ship_processor.go: rename struct to ShipProcessor Henrik Hautakoski 2023-01-17 21:44:51 +01:00
5c5d7e57a9 ship_processor.go: move encodeMessage to transport/message/encoding.go Henrik Hautakoski 2023-01-17 21:03:48 +01:00
f589f5c0ed ship_processor.go: Move decodeAction() to abi/helpers.go Henrik Hautakoski 2023-01-17 21:01:09 +01:00
2d369adabf ship_processor.go: refactor to a struct to get rid of global state. Henrik Hautakoski 2023-01-17 20:57:09 +01:00
30e3d0e012 main.go: Remove some global variables that does not need to be global. Henrik Hautakoski 2023-01-17 19:24:19 +01:00
d825f3bc50 abi/cache_test.go: use redismock. Henrik Hautakoski 2023-01-13 14:39:07 +01:00
bcf55f1c12 Remove internal/redis/wrapper.go Henrik Hautakoski 2023-01-13 13:45:41 +01:00
b22118898d move channel stuffs from internal/redis to transport. Henrik Hautakoski 2023-01-13 13:38:04 +01:00
d0782c3c7c ship_processor.go: Use publisher instead of redis directly. Henrik Hautakoski 2023-01-13 13:33:01 +01:00
eec834a338 main.go: setup redis pubsub publisher. Henrik Hautakoski 2023-01-13 13:32:23 +01:00
45bf043d8a Adding transport/redis_pubsub publisher Henrik Hautakoski 2023-01-13 13:30:50 +01:00
6b6a375228 Adding transport/publisher.go Henrik Hautakoski 2023-01-13 13:21:20 +01:00
3251c94416 move internal/config to config Henrik Hautakoski 2023-01-12 16:49:27 +01:00
92c605c7fa move internal/abi_cache to abi Henrik Hautakoski 2023-01-12 16:48:04 +01:00
c05b789269 move abi.go to abi/manager.go Henrik Hautakoski 2023-01-12 16:46:09 +01:00
45d1a468e8 abi.go: Get rid of global state by defining an AbiManager struct. Henrik Hautakoski 2023-01-12 16:38:03 +01:00
0ded3ee6fe abi.go: move DecodeAction to ship_processor. Henrik Hautakoski 2023-01-12 16:33:06 +01:00
9c3bd1e879 internal/abi_cache/cache.go: change "this" variable to "cache". Henrik Hautakoski 2023-01-12 16:31:51 +01:00
caf7460875 internal/redis/channel.go: Don't need to use fmt.Sprintf() anymore. Henrik Hautakoski 2023-01-12 15:03:31 +01:00
51af80d3aa internal/redis/channel.go: Make Append() accept a variadic number of parameters. Henrik Hautakoski 2023-01-12 15:02:16 +01:00
0e19f6d146 internal/redis/channel.go: Change delimiter to "/" Henrik Hautakoski 2023-01-12 15:00:07 +01:00
dd9bd85801 internal/redis/namespace.go: Change delimiter to "::" Henrik Hautakoski 2023-01-12 14:59:32 +01:00
fb3ed0f976 Makefile: add test target. Henrik Hautakoski 2023-01-06 17:18:25 +01:00
83a4c9f70f ship_processor.go: encodeQueue should accept and redis.ChannelInterface instead of redis.Channel to make it more generic. Henrik Hautakoski 2023-01-06 17:17:01 +01:00
723b0786cb ship_processor.go: make queueMessage() accept an redis.ChannelInterface instead of redis.Key so we can call redisNs.NewKey() as late as possible. Henrik Hautakoski 2023-01-06 17:15:31 +01:00
93300f01ea ship_processor.go: in processTraces() make a slice of redis.ChannelInterface instead of redis.Key so we don't have to repeat our self. Henrik Hautakoski 2023-01-06 17:12:55 +01:00
4b41718c78 ship_processor.go: Use redis.Namespace.NewKey() Henrik Hautakoski 2023-01-06 17:09:41 +01:00
1bc43cc87b internal/redis/namespace.go: Adding Namespace.NewKey() helper function. Henrik Hautakoski 2023-01-06 17:07:22 +01:00
13c8ed7692 Refactor to use the new redis.Key,redis.Namespace and redis.Channel types. Henrik Hautakoski 2023-01-06 17:06:27 +01:00
61beca435c Adding internal/redis/key.go Henrik Hautakoski 2023-01-06 17:05:44 +01:00
15b9a9804f Adding internal/redis/namespace.go Henrik Hautakoski 2023-01-06 16:55:36 +01:00
e91951d7ed Adding internal/redis/channel.go Henrik Hautakoski 2023-01-06 16:50:00 +01:00
177b715ba4 ship_processor.go: typo fix. hearthbeat should be heartbeat. Henrik Hautakoski 2023-01-06 16:39:14 +01:00
73f0ba0555 ship_processor.go: improve channel names for actions. Henrik Hautakoski 2023-01-06 15:39:13 +01:00
42da179c74 internal/redis/wrapper.go: in Key() used "::" as a separator between namespace and channel. Henrik Hautakoski 2023-01-06 15:38:21 +01:00
dcb1e173a2 Adding LICENSE file. Henrik Hautakoski 2023-01-05 17:09:55 +01:00
8ebcf70ba1 main.go: minor style fixes. Henrik Hautakoski 2023-01-05 17:08:47 +01:00
a9c8bd3a04 go.mod: change github.com/eosswedenorg-go/eos-ship-client to github.com/eosswedenorg-go/antelope-ship-client v0.2.0 Henrik Hautakoski 2022-12-01 10:56:24 +01:00
433b23b77b main.go: in readerLoop() bail out of function if error returned from shClient.Read is "socket closed". Henrik Hautakoski 2022-11-29 16:46:34 +01:00
7a24e9d684 go.mod: Upgrade github.com/eosswedenorg-go/eos-ship-client to v0.1.4 Henrik Hautakoski 2022-11-29 16:39:48 +01:00
becd50da9c go.mod: remove unneeded packages. Henrik Hautakoski 2022-11-29 16:39:11 +01:00
6d8c63f958 Remove internal/telegram/wrapper.go Henrik Hautakoski 2022-11-29 16:38:54 +01:00
9f1b2f3026 main.go: use github.com/nikoksr/notify as notification system instead of calling telegram directly. Henrik Hautakoski 2022-11-29 16:37:09 +01:00
1d350fc5f1 Adding docs/messages.md Henrik Hautakoski 2022-11-29 15:08:57 +01:00
ddd5d67901 Move internal packages into internal subdirectory Henrik Hautakoski 2022-11-29 15:08:23 +01:00
770f0a48ef ship_processor.go: Send hearthbeat every 10'th block. Henrik Hautakoski 2022-11-29 15:04:50 +01:00
3694bc1c42 types.go: adding HearthBeat struct Henrik Hautakoski 2022-11-29 15:04:29 +01:00
3ecf4c7c42 ship_processor.go: move some repetitive code into helper functions. Henrik Hautakoski 2022-11-29 14:51:51 +01:00
6c9350136c ship_processor.go: Include hex data in action traces. Henrik Hautakoski 2022-11-29 14:50:24 +01:00
0c91290afb types.go: Adding ActionTrace.HexData field. Henrik Hautakoski 2022-11-29 14:49:56 +01:00
61d9836275 config.example.json: Adding redis.prefix Henrik Hautakoski 2022-11-29 13:45:48 +01:00
186983d54f main.go: Pass config.Redis.Prefix to redis.SetPrefix() Henrik Hautakoski 2022-11-29 13:45:13 +01:00
ab7a8f0433 config/config.go: Adding RedisConfig.Prefix Henrik Hautakoski 2022-11-29 13:44:29 +01:00
cd9dd6468a redis/wrapper.go: make "prefix" variable internal and provide SetPrefix() function Henrik Hautakoski 2022-11-29 05:55:13 +01:00
c1cdf50975 abi_cache/cache_test.go: change require.Error() to assert.Error() and remove the import. Henrik Hautakoski 2022-11-29 05:41:28 +01:00