fix(publisher): fix redis command usage #184
Merged
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.
This pull request introduces Redis integration into the
publisher
service, refactoring the code to accommodate the new Redis client and updating the handling of Redis commands. The most important changes include adding the Redis client configuration, modifying thePublisher
andService
structs, and updating Redis command methods.Redis Integration:
publisher/cmd/worker/main.go
: Added Redis client configuration and passed the Redis client to thetiup.NewPublisher
function. [1] [2]Struct Modifications:
publisher/pkg/config/config.go
: Added aRedis
struct to hold Redis configuration and updated theWorker
andService
structs to include this newRedis
field.Redis Command Updates:
publisher/pkg/impl/tiup/publisher.go
: Changed theredisClient
type from*redis.Client
toredis.Cmdable
and updated Redis command methods to useSetXX
instead ofSet
. [1] [2] [3]publisher/pkg/impl/tiup/service.go
: Updated theredisClient
type and changed the Redis command method fromSetXX
toSetNX
for initial status setting. [1] [2]Signed-off-by: wuhuizuo [email protected]