Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Submit feedback
Sign in
Toggle navigation
L
lcc-akm
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
wangmingming
lcc-akm
Commits
b515d23b
Commit
b515d23b
authored
Mar 23, 2023
by
王明明
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
更换goquery
parent
782d5483
Changes
2
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
3 additions
and
8 deletions
+3
-8
main.go
src/main.go
+0
-4
akm_init.go
src/model/akm_init.go
+3
-4
No files found.
src/main.go
View file @
b515d23b
...
@@ -9,7 +9,6 @@ import (
...
@@ -9,7 +9,6 @@ import (
"gopkg.in/natefinch/lumberjack.v2"
"gopkg.in/natefinch/lumberjack.v2"
"log"
"log"
"net/http"
"net/http"
_
"net/http/pprof"
"path"
"path"
"test/model"
"test/model"
"test/util"
"test/util"
...
@@ -20,9 +19,6 @@ func WelcomeHandler(w http.ResponseWriter, r *http.Request) {
...
@@ -20,9 +19,6 @@ func WelcomeHandler(w http.ResponseWriter, r *http.Request) {
}
}
func
main
()
{
func
main
()
{
go
func
()
{
log
.
Println
(
http
.
ListenAndServe
(
"0.0.0.0:6060"
,
nil
))
}()
logname
:=
flag
.
String
(
"logname"
,
"akm.log"
,
"日志文件名"
)
logname
:=
flag
.
String
(
"logname"
,
"akm.log"
,
"日志文件名"
)
flag
.
Parse
()
flag
.
Parse
()
...
...
src/model/akm_init.go
View file @
b515d23b
...
@@ -70,21 +70,20 @@ func (akm *AkmClient) Init() error {
...
@@ -70,21 +70,20 @@ func (akm *AkmClient) Init() error {
for
_
,
attr
:=
range
attrs
{
for
_
,
attr
:=
range
attrs
{
if
attr
.
Key
==
"src"
&&
!
strings
.
Contains
(
attr
.
Val
,
"."
)
{
if
attr
.
Key
==
"src"
&&
!
strings
.
Contains
(
attr
.
Val
,
"."
)
{
akm
.
SensorUrl
=
fmt
.
Sprintf
(
"%s://%s%s"
,
uri
.
Scheme
,
uri
.
Host
,
attr
.
Val
)
akm
.
SensorUrl
=
fmt
.
Sprintf
(
"%s://%s%s"
,
uri
.
Scheme
,
uri
.
Host
,
attr
.
Val
)
break
goto
continute
}
}
}
}
startIdx
--
startIdx
--
lastScript
=
scripts
[
startIdx
]
lastScript
=
scripts
[
startIdx
]
}
}
continute
:
// akm.SensorUrl = fmt.Sprintf("%s://%s%s", uri.Scheme, uri.Host, matchs[1])
// akm.SensorUrl = fmt.Sprintf("%s://%s%s", uri.Scheme, uri.Host, matchs[1])
if
akm
.
SensorUrl
==
""
{
if
akm
.
SensorUrl
==
""
{
akm
.
logger
.
Errorln
(
"提取不到sensorUrl失败"
)
akm
.
logger
.
Errorln
(
"提取不到sensorUrl失败"
)
return
errors
.
New
(
"提取不到sensorUrl 失败"
)
return
errors
.
New
(
"提取不到sensorUrl 失败"
)
}
}
akm
.
logger
.
Info
(
"请求sensor url:"
,
akm
.
SensorUrl
)
akm
.
logger
.
Info
(
"初始化abck 耗时"
,
time
.
Since
(
startTime
)
.
String
(),
" 请求sensor url:"
,
akm
.
SensorUrl
)
akm
.
logger
.
Info
(
"初始化abck 耗时"
,
time
.
Since
(
startTime
)
.
String
())
return
nil
return
nil
}
}
func
NewAkmClient
(
initUrl
,
postUrl
,
proxyUrl
string
,
logger
*
logrus
.
Entry
)
*
AkmClient
{
func
NewAkmClient
(
initUrl
,
postUrl
,
proxyUrl
string
,
logger
*
logrus
.
Entry
)
*
AkmClient
{
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment