|
|
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 |
|
