refactor: refactor message handling and encoding in queue system #138
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Encode
method call inBenchmarkQueue
functionTaskMessage
interface extendingQueuedMessage
withPayload
methodPayload
field toBody
inMessage
structPayload
method toMessage
struct to returnBody
Data
field andEncode
method inMessage
struct withBytes
method using JSON marshallingNewMessage
to useBody
instead ofPayload
Encode
method injob
packageTestMessageEncodeDecode
to usePayload()
methodEncode
method call with direct handling oftask
inQueue
methodsErrorf
toFatalf
inQueue
error handlingjob.Message
inQueue
'srun
methodjob
package inring.go
Data
struct withPayload
field andBytes
method inring.go
Ring
'sRun
method to useData
struct for task handling