@@ -36,57 +36,3 @@ func octopusTest() {
3636 octopus .SetupSystem ()
3737 octopus .BeginCrawling (Url1 )
3838}
39-
40- func checkPipelineA () {
41- exp .Temp ()
42- crawler := exp .NewEngine ()
43- crawler .Consume (HomeUrl )
44- crawler .Consume ("Chicken Nugget" )
45- crawler .Consume ("Tina kicks ass!!" )
46- fmt .Printf ("1. %v\n " , crawler .IsRunning ())
47- crawler .TurnOff ()
48- <- time .After (200 * time .Millisecond )
49- fmt .Printf ("2. %v\n " , crawler .IsRunning ())
50- crawler .RestartEngine ()
51- <- time .After (100 * time .Millisecond )
52- fmt .Printf ("3. %v\n " , crawler .IsRunning ())
53- crawler .Consume ("Hello Poppet!!" )
54- fmt .Printf ("4. %v\n " , crawler .IsRunning ())
55- crawler .TurnOff ()
56- }
57-
58- func checkParsing () {
59- resp , err := http .Get (HomeUrl )
60- if err != nil {
61- log .Fatal (err )
62- }
63- defer resp .Body .Close ()
64- results := exp .GetLinks (resp .Body )
65- fmt .Println (len (results ))
66- results = exp .ProcessLinks (HomeUrl , results )
67- fmt .Println (len (results ))
68- results = exp .RemoveDuplicates (results )
69- fmt .Println (len (results ))
70- results = exp .ValidateLinks (results )
71- fmt .Println (len (results ))
72- for _ , v := range results {
73- fmt .Println (v )
74- }
75- }
76-
77- func runPipeline () {
78- crawler := exp .NewMonster ()
79- opAdapterPipe := exp .GetOutputAdapterPipe ()
80- crawler .BuildSystem (opAdapterPipe )
81- crawler .StartCrawling (LessLinkUrl )
82- }
83-
84- func runPipelineWithOptions () {
85- opt := & exp.Options {
86- MaxDepth : 1 ,
87- }
88- crawler := exp .NewMonsterWithOptions (opt )
89- opAdapterPipe := exp .GetOutputAdapterPipe ()
90- crawler .BuildSystem (opAdapterPipe )
91- crawler .StartCrawling (HomeUrl )
92- }
0 commit comments