chore: update

Signed-off-by: Bo-Yi.Wu <[email protected]>

Author: appleboy

job/job.go

@@ -46,11 +46,6 @@ func (m *Message) Encode() []byte {
 
 func NewMessage(m core.QueuedMessage, opts ...Option) *Message {
 	o := NewOptions(opts...)
-	// Loop through each option
-	for _, opt := range opts {
-		// Call the option giving the instantiated
-		opt.Apply(o)
-	}
 
 	return &Message{
 		RetryCount: o.retryCount,
@@ -62,11 +57,6 @@ func NewMessage(m core.QueuedMessage, opts ...Option) *Message {
 
 func NewTask(task TaskFunc, opts ...Option) *Message {
 	o := NewOptions(opts...)
-	// Loop through each option
-	for _, opt := range opts {
-		// Call the option giving the instantiated
-		opt.Apply(o)
-	}
 
 	return &Message{
 		Timeout:    o.timeout,

job/option.go

@@ -10,14 +10,14 @@ type Options struct {
 
 // An Option configures a mutex.
 type Option interface {
-	Apply(*Options)
+	apply(*Options)
 }
 
 // OptionFunc is a function that configures a job.
 type OptionFunc func(*Options)
 
-// Apply calls f(option)
-func (f OptionFunc) Apply(option *Options) {
+// apply calls f(option)
+func (f OptionFunc) apply(option *Options) {
 	f(option)
 }
 
@@ -31,7 +31,7 @@ func NewOptions(opts ...Option) *Options {
 	// Loop through each option
 	for _, opt := range opts {
 		// Call the option giving the instantiated
-		opt.Apply(o)
+		opt.apply(o)
 	}
 
 	return o