refactor: optimize code following Google Go best practices

- Simplify error wrapping to avoid redundant double wrapping
- Add clear documentation for intentional error ignoring in fingerprint generation
- Improve error messages with specific context instead of generic sentinel errors
- Follow Google Go style guide recommendations for error handling

Author: kaptinlin

client.go

@@ -34,7 +34,7 @@ func NewClient(redisConfig *RedisConfig, opts ...ClientOption) (*Client, error)
 		return nil, ErrInvalidRedisConfig
 	}
 	if err := redisConfig.Validate(); err != nil {
-		return nil, fmt.Errorf("%w: %w", ErrInvalidRedisConfig, err)
+		return nil, fmt.Errorf("invalid redis config: %w", err)
 	}
 
 	asynqClient := asynq.NewClient(redisConfig.ToAsynqRedisOpt())

job.go

@@ -99,7 +99,7 @@ func (j *Job) ConvertToAsynqTask() (*asynq.Task, []asynq.Option, error) {
 
 	payloadBytes, err := json.Marshal(j.Payload)
 	if err != nil {
-		return nil, nil, fmt.Errorf("%w: %w", ErrSerializationFailure, err)
+		return nil, nil, fmt.Errorf("failed to serialize payload: %w", err)
 	}
 
 	opts := j.ConvertToAsynqOptions()
@@ -142,6 +142,10 @@ func (j *Job) fingerprint() {
 
 	hash := md5.New() //nolint:gosec
 	hash.Write([]byte(j.Type))
+
+	// Marshal payload and options for fingerprint generation.
+	// Errors are intentionally ignored - partial JSON is acceptable for fingerprinting.
+	// The fingerprint is used for deduplication and debugging, not data integrity.
 	payloadBytes, _ := json.Marshal(j.Payload)
 	hash.Write(payloadBytes)
 	optionsBytes, _ := json.Marshal(j.Options)
@@ -154,7 +158,7 @@ func (j *Job) fingerprint() {
 func (j *Job) DecodePayload(v any) error {
 	payloadBytes, err := json.Marshal(j.Payload)
 	if err != nil {
-		return fmt.Errorf("%w: %w", ErrSerializationFailure, err)
+		return fmt.Errorf("failed to serialize payload: %w", err)
 	}
 	return json.Unmarshal(payloadBytes, v)
 }
@@ -179,12 +183,12 @@ func (j *Job) WriteResult(result any) error {
 
 	resultBytes, err := json.Marshal(result)
 	if err != nil {
-		return fmt.Errorf("%w: %w", ErrSerializationFailure, err)
+		return fmt.Errorf("failed to serialize result: %w", err)
 	}
 
 	_, err = j.resultWriter.Write(resultBytes)
 	if err != nil {
-		return fmt.Errorf("%w: %w", ErrFailedToWriteResult, err)
+		return fmt.Errorf("failed to write result: %w", err)
 	}
 
 	return nil

scheduler.go

@@ -82,7 +82,7 @@ func NewScheduler(redisConfig *RedisConfig, opts ...SchedulerOption) (*Scheduler
 		return nil, ErrInvalidRedisConfig
 	}
 	if err := redisConfig.Validate(); err != nil {
-		return nil, fmt.Errorf("%w: %w", ErrInvalidRedisConfig, err)
+		return nil, fmt.Errorf("invalid redis config: %w", err)
 	}
 
 	asynqClientOpt := redisConfig.ToAsynqRedisOpt()

worker.go

@@ -77,7 +77,7 @@ func NewWorker(redisConfig *RedisConfig, opts ...WorkerOption) (*Worker, error)
 		return nil, ErrInvalidRedisConfig
 	}
 	if err := redisConfig.Validate(); err != nil {
-		return nil, fmt.Errorf("%w: %w", ErrInvalidRedisConfig, err)
+		return nil, fmt.Errorf("invalid redis config: %w", err)
 	}
 
 	// Apply default configuration and options.
@@ -97,7 +97,7 @@ func NewWorker(redisConfig *RedisConfig, opts ...WorkerOption) (*Worker, error)
 
 	// Validate the WorkerConfig.
 	if err := config.Validate(); err != nil {
-		return nil, fmt.Errorf("%w: %w", ErrInvalidWorkerConfig, err)
+		return nil, fmt.Errorf("invalid worker config: %w", err)
 	}
 
 	// Setup the Worker instance.