|
|
074c089679
|
WIP
|
2023-03-08 15:52:10 +01:00 |
|
|
|
bd5037b044
|
Adding transport/redis_pubsub/subscriber.go
|
2023-03-08 11:32:37 +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 |
|
|
|
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 |
|
|
|
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 |
|
|
|
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 |
|
|
|
af0a4d2714
|
transport: move key and namespace into redis_pubsub as it is redis specific.
|
2023-01-19 19:07:35 +01:00 |
|
|
|
e0bf53496a
|
transport/message/types.go: get rid of eos-go here.
|
2023-01-19 19:04:34 +01:00 |
|
|
|
69a9e9f47d
|
transport/publisher.go: pass ChannelInterface instead of string to Publish()
|
2023-01-19 17:42:26 +01:00 |
|
|
|
5202247200
|
move app/types.go to transport/message/types.go
|
2023-01-19 16:28:54 +01:00 |
|
|
|
5c5d7e57a9
|
ship_processor.go: move encodeMessage to transport/message/encoding.go
|
2023-01-17 21:03:48 +01:00 |
|
|
|
b22118898d
|
move channel stuffs from internal/redis to transport.
|
2023-01-13 13:38:04 +01:00 |
|
|
|
45bf043d8a
|
Adding transport/redis_pubsub publisher
|
2023-01-13 13:31:05 +01:00 |
|
|
|
6b6a375228
|
Adding transport/publisher.go
|
2023-01-13 13:30:11 +01:00 |
|
