|
|
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 |
|
|
|
1de6cd9432
|
transport/redis_pubsub/publisher.go: Adding Close() method.
|
2023-03-29 11:51:15 +02:00 |
|
|
|
6a5292da5e
|
app/ship_processor.go: Return ShipProcessor object from SpawnProcessor()
|
2023-03-29 11:50:14 +02:00 |
|
|
|
bbda49ab90
|
transport/reader.go: document concurrency requirement of Read()
|
2023-03-29 11:38:54 +02:00 |
|
|
|
531a2d3d17
|
Move Key and Namespace from transport/redis_pubsub to transport/redis_common
|
2023-03-08 16:28:52 +01:00 |
|
|
|
acdf827223
|
config/config.go: use shipclient.NULL_BLOCK_NUMBER instead of defining our own.
|
2023-03-08 15:56:45 +01:00 |
|
|
|
bd5037b044
|
Adding transport/redis_pubsub/subscriber.go
|
2023-03-08 11:32:37 +01:00 |
|
|
|
7843dda6d9
|
app/ship_processor.go: Support ActionTraceV1
|
2023-03-08 10:49:55 +01:00 |
|
|
|
454c8f7197
|
Adding config/config_test.go
|
2023-03-08 10:04:50 +01:00 |
|
|
|
bc5a351853
|
config/config.go: Refactor Load() into Parse() and Load() functions.
|
2023-03-08 10:04:12 +01:00 |
|
|
|
edaf662d50
|
transport/redis_pubsub/publisher_test.go: Change Publish to Write in test name.
|
2023-03-08 10:01:56 +01:00 |
|
|
|
347de718af
|
transport/channel.go: rename Action.Action to Action.Name
|
2023-03-07 18:53:52 +01:00 |
|
|
|
7637b6e16b
|
transport/message/types.go: Rename Action field to Name in ActionTrace struct
|
2023-03-07 18:47:58 +01:00 |
|
|
|
68c21c8ed8
|
transport/channel.go: Rewrite to not use a interface. Action struct has a Channel() method that returns a channel instead.
|
2023-03-07 18:35:58 +01:00 |
|
|
|
8e99146cc2
|
transport/channel.go: Adding Channel.Is()
|
2023-03-07 11:58:40 +01:00 |
|
|
|
7358bebc76
|
main.go: Minor fix.
|
2023-03-07 11:55:02 +01:00 |
|
|
|
f9fc88b0fb
|
transport/publisher.go: rename to writer.go
|
2023-03-07 11:41:22 +01:00 |
|
|
|
b3f773655d
|
Adding transport/reader.go
|
2023-03-07 11:35:13 +01:00 |
|
|
|
19b93495ee
|
transport/redis_pubsub/redis.go rename to publisher.go
|
2023-03-07 11:33:53 +01:00 |
|
|
|
b46c070948
|
transport/message/encoding.go: make Decoder type match common Unmarshal interface.
|
2023-02-21 10:56:36 +01:00 |
|
|
|
6ca9f408f9
|
app/ship_processor.go: in encodeQueue() should check for err == nil, not err != nil.
|
2023-02-21 10:45:17 +01:00 |
|
|
|
315d7e19c9
|
transport/message/encoding.go: Add Decoder and Codec
|
2023-02-10 16:54:57 +01:00 |
|
|
|
027ba0b1ff
|
transport/message/encoder.go: rename to encoding.go
|
2023-02-10 16:54:08 +01:00 |
|
|
|
a20295ee88
|
transport/message/encoder.go: remove Encode() function.
|
2023-02-10 16:50:59 +01:00 |
|
|
|
55f013a386
|
app/ship_processor.go: Use an message.Encoder function instead of directly calling massage.Encode()
|
2023-02-10 16:48:16 +01:00 |
|
|
|
2c3af6e4c5
|
transport/message/encoder.go: Define the Encoder type
|
2023-02-10 16:43:23 +01:00 |
|
|
|
38ae3a4630
|
transport/redis_pubsub/redis.go: No need to alias redis import.
|
2023-02-10 16:32:56 +01:00 |
|
|
|
82dce9b190
|
Update github.com/eosswedenorg-go/antelope-ship-client to v0.2.2
|
2023-02-10 16:05:43 +01:00 |
|
|
|
788cc2621e
|
main.go: os.Interrupt can be changed to syscall.SIGINT
|
2023-01-20 12:15:24 +01:00 |
|
|
|
1d6c05b402
|
main.go: modify signal handling to also check syscall.SIGTERM
|
2023-01-20 12:14:54 +01:00 |
|
