File tree 1 file changed +10
-0
lines changed
1 file changed +10
-0
lines changed Original file line number Diff line number Diff line change 4
4
"context"
5
5
"fmt"
6
6
"io"
7
+ "net"
7
8
"os"
8
9
"regexp"
9
10
"strconv"
@@ -19,6 +20,7 @@ import (
19
20
"github.com/go-mysql-org/go-mysql/schema"
20
21
"github.com/pingcap/errors"
21
22
"github.com/pingcap/parser"
23
+ "github.com/siddontang/go-log/log"
22
24
)
23
25
24
26
// Canal can sync your MySQL data into everywhere, like Elasticsearch, Redis, etc...
@@ -60,6 +62,14 @@ var ErrExcludedTable = errors.New("excluded table meta")
60
62
61
63
func NewCanal (cfg * Config ) (* Canal , error ) {
62
64
c := new (Canal )
65
+ if cfg .Logger == nil {
66
+ streamHandler , _ := log .NewStreamHandler (os .Stdout )
67
+ cfg .Logger = log .NewDefault (streamHandler )
68
+ }
69
+ if cfg .Dialer == nil {
70
+ dialer := & net.Dialer {}
71
+ cfg .Dialer = dialer .DialContext
72
+ }
63
73
c .cfg = cfg
64
74
65
75
c .ctx , c .cancel = context .WithCancel (context .Background ())
You can’t perform that action at this time.
0 commit comments