cluster: group default option factories
Signed-off-by: Alejandro Mery <amery@jpi.io>
This commit is contained in:
@@ -6,7 +6,6 @@ import (
|
|||||||
|
|
||||||
"darvaza.org/resolver"
|
"darvaza.org/resolver"
|
||||||
"darvaza.org/slog"
|
"darvaza.org/slog"
|
||||||
"darvaza.org/slog/handlers/discard"
|
|
||||||
"github.com/hack-pad/hackpadfs/os"
|
"github.com/hack-pad/hackpadfs/os"
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -65,7 +64,7 @@ func WithResolver(h resolver.Resolver) ScanOption {
|
|||||||
func WithLogger(log slog.Logger) ScanOption {
|
func WithLogger(log slog.Logger) ScanOption {
|
||||||
return func(m *Cluster, opt *ScanOptions) error {
|
return func(m *Cluster, opt *ScanOptions) error {
|
||||||
if log == nil {
|
if log == nil {
|
||||||
log = discard.New()
|
log = DefaultLogger()
|
||||||
}
|
}
|
||||||
|
|
||||||
opt.Logger = log
|
opt.Logger = log
|
||||||
@@ -76,7 +75,7 @@ func WithLogger(log slog.Logger) ScanOption {
|
|||||||
|
|
||||||
func (m *Cluster) setDefaults(opt *ScanOptions) error {
|
func (m *Cluster) setDefaults(opt *ScanOptions) error {
|
||||||
if m.resolver == nil {
|
if m.resolver == nil {
|
||||||
h := resolver.NewCloudflareLookuper()
|
h := DefaultLookuper()
|
||||||
|
|
||||||
if err := WithLookuper(h)(m, opt); err != nil {
|
if err := WithLookuper(h)(m, opt); err != nil {
|
||||||
return err
|
return err
|
||||||
|
|||||||
@@ -0,0 +1,17 @@
|
|||||||
|
package cluster
|
||||||
|
|
||||||
|
import (
|
||||||
|
"darvaza.org/resolver"
|
||||||
|
"darvaza.org/slog"
|
||||||
|
"darvaza.org/slog/handlers/discard"
|
||||||
|
)
|
||||||
|
|
||||||
|
// DefaultLogger returns a logger that doesn't log anything
|
||||||
|
func DefaultLogger() slog.Logger {
|
||||||
|
return discard.New()
|
||||||
|
}
|
||||||
|
|
||||||
|
// DefaultLookuper returns a [resolver.Lookuper] using Cloudflare's 1.1.1.1
|
||||||
|
func DefaultLookuper() resolver.Lookuper {
|
||||||
|
return resolver.NewCloudflareLookuper()
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user