admin/kubesphere
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #3212 from wanjunlei/es

Browse Source 
add a es client for auditing, events, and logging
This commit is contained in:
KubeSphere CI Bot
2021-01-19 17:09:19 +08:00
committed by GitHub
parent 1f4d5cb686 83c010c691
commit bed6465993
44 changed files with 1890 additions and 2293 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/api/auditing/v1alpha1/types.go
View File

@@ -48,8 +48,8 @@ type Query struct {
ResponseCodeFilter string `json:"response_code_filter,omitempty"`
ResponseStatusFilter string `json:"response_status_filter,omitempty"`
StartTime *time.Time `json:"start_time,omitempty"`
EndTime *time.Time `json:"end_time,omitempty"`
StartTime time.Time `json:"start_time,omitempty"`
EndTime time.Time `json:"end_time,omitempty"`
Interval string `json:"interval,omitempty"`
Sort string `json:"sort,omitempty"`
@@ -84,7 +84,7 @@ func ParseQueryParameter(req *restful.Request) (*Query, error) {
return nil, err
}
t := time.Unix(sec, 0)
q.StartTime = &t
q.StartTime = t
}
if tstr := req.QueryParameter("end_time"); tstr != "" {
sec, err := strconv.ParseInt(tstr, 10, 64)
@@ -92,7 +92,7 @@ func ParseQueryParameter(req *restful.Request) (*Query, error) {
return nil, err
}
t := time.Unix(sec, 0)
q.EndTime = &t
q.EndTime = t
}
if q.Interval = req.QueryParameter("interval"); q.Interval == "" {
q.Interval = "15m"

8
pkg/api/events/v1alpha1/types.go
View File

@@ -43,8 +43,8 @@ type Query struct {
MessageSearch string `json:"message_search,omitempty"`
TypeFilter string `json:"type_filter,omitempty"`
StartTime *time.Time `json:"start_time,omitempty"`
EndTime *time.Time `json:"end_time,omitempty"`
StartTime time.Time `json:"start_time,omitempty"`
EndTime time.Time `json:"end_time,omitempty"`
Interval string `json:"interval,omitempty"`
Sort string `json:"sort,omitempty"`
@@ -74,7 +74,7 @@ func ParseQueryParameter(req *restful.Request) (*Query, error) {
return nil, err
}
t := time.Unix(sec, 0)
q.StartTime = &t
q.StartTime = t
}
if tstr := req.QueryParameter("end_time"); tstr != "" {
sec, err := strconv.ParseInt(tstr, 10, 64)
@@ -82,7 +82,7 @@ func ParseQueryParameter(req *restful.Request) (*Query, error) {
return nil, err
}
t := time.Unix(sec, 0)
q.EndTime = &t
q.EndTime = t
}
if q.Interval = req.QueryParameter("interval"); q.Interval == "" {
q.Interval = "15m"