refactor: move factory to its own file

Author: Reasno

dependency.go

@@ -43,46 +43,12 @@ func Providers() di.Deps {
 // Gauge is an alias used for dependency injection
 type Gauge metrics.Gauge
 
-// ConsumableDispatcher is the key JobFrom *Queue in the dependencies graph. Used as a type hint for injection.
+// ConsumableDispatcher is the key of *Queue in the dependencies graph. Used as a type hint for injection.
 type ConsumableDispatcher interface {
 	JobDispatcher
 	Consume(ctx context.Context) error
 }
 
-// DispatcherFactory is a factory for *Queue. Note DispatcherFactory doesn't contain the factory method
-// itself. ie. How to factory a dispatcher left there for users to define. Users then can use this type to create
-// their own dispatcher implementation.
-//
-// Here is an example on how to create a custom DispatcherFactory with an InProcessDriver.
-//
-//		factory := di.NewFactory(func(name string) (di.Pair, error) {
-//			queuedDispatcher := queue.NewQueue(
-//				&Jobs.SyncDispatcher{},
-//				queue.NewInProcessDriver(),
-//			)
-//			return di.Pair{Conn: queuedDispatcher}, nil
-//		})
-//		dispatcherFactory := DispatcherFactory{Factory: factory}
-//
-type DispatcherFactory struct {
-	*di.Factory
-}
-
-// Make returns a Queue by the given name. If it has already been created under the same name,
-// the that one will be returned.
-func (s DispatcherFactory) Make(name string) (*Queue, error) {
-	client, err := s.Factory.Make(name)
-	if err != nil {
-		return nil, err
-	}
-	return client.(*Queue), nil
-}
-
-// DispatcherMaker is the key JobFrom *DispatcherFactory in the dependencies graph. Used as a type hint for injection.
-type DispatcherMaker interface {
-	Make(string) (*Queue, error)
-}
-
 type configuration struct {
 	RedisName                      string `yaml:"redisName" json:"redisName"`
 	Parallelism                    int    `yaml:"parallelism" json:"parallelism"`

factory.go

@@ -0,0 +1,37 @@
+package queue
+
+import "github.com/DoNewsCode/core/di"
+
+// DispatcherFactory is a factory for *Queue. Note DispatcherFactory doesn't contain the factory method
+// itself. ie. How to factory a dispatcher left there for users to define. Users then can use this type to create
+// their own dispatcher implementation.
+//
+// Here is an example on how to create a custom DispatcherFactory with an InProcessDriver.
+//
+//		factory := di.NewFactory(func(name string) (di.Pair, error) {
+//			queuedDispatcher := queue.NewQueue(
+//				&Jobs.SyncDispatcher{},
+//				queue.NewInProcessDriver(),
+//			)
+//			return di.Pair{Conn: queuedDispatcher}, nil
+//		})
+//		dispatcherFactory := DispatcherFactory{Factory: factory}
+//
+type DispatcherFactory struct {
+	*di.Factory
+}
+
+// Make returns a Queue by the given name. If it has already been created under the same name,
+// the that one will be returned.
+func (s DispatcherFactory) Make(name string) (*Queue, error) {
+	client, err := s.Factory.Make(name)
+	if err != nil {
+		return nil, err
+	}
+	return client.(*Queue), nil
+}
+
+// DispatcherMaker is the key of *DispatcherFactory in the dependencies graph. Used as a type hint for injection.
+type DispatcherMaker interface {
+	Make(string) (*Queue, error)
+}

go.sum

@@ -458,8 +458,6 @@ github.com/klauspost/compress v1.9.8/go.mod h1:RyIbtBH6LamlWaDj8nUwkbUhJ87Yi3uG0
 github.com/klauspost/compress v1.11.12/go.mod h1:aoV0uJVorq1K+umq18yTdKaF57EivdYsUV+/s2qKfXs=
 github.com/klauspost/compress v1.12.2/go.mod h1:8dP1Hq4DHOhN9w426knH3Rhby4rFm6D8eO+e+Dq5Gzg=
 github.com/knadh/koanf v0.15.0/go.mod h1:Ut3d4JaTRZYfO5a0wdYIGE+oyGaGFo4vXQ3ZvaSWxNc=
-github.com/knadh/koanf v1.2.0 h1:fANR65nD9cI3HGm0s3pmzqh4hkknt4TasmZzh+rLy1M=
-github.com/knadh/koanf v1.2.0/go.mod h1:xpPTwMhsA/aaQLAilyCCqfpEiY1gpa160AiCuWHJUjY=
 github.com/knadh/koanf v1.2.1 h1:tVR+BbAM5PA2YkB0OMyfSnEsmt3uygpn3R0WB6jKw7s=
 github.com/knadh/koanf v1.2.1/go.mod h1:xpPTwMhsA/aaQLAilyCCqfpEiY1gpa160AiCuWHJUjY=
 github.com/konsorten/go-windows-terminal-sequences v1.0.1/go.mod h1:T0+1ngSBFLxvqU3pZ+m/2kptfBszLMUkC4ZK/EgS/cQ=