Add container controller

Add container model

Author: YLonely

server/controller/container/container.go

@@ -0,0 +1,27 @@
+package container
+
+import (
+	"github.com/YLonely/sysdig-monitor/server/controller"
+	"github.com/YLonely/sysdig-monitor/server/model"
+	"github.com/YLonely/sysdig-monitor/server/router"
+	"github.com/YLonely/sysdig-monitor/sysdig"
+)
+
+// Container represents a top level controller for container
+type ContainerController struct {
+	containerRouter router.Router
+	// event chan
+	ec chan sysdig.Event
+
+	// containers
+	containers map[string]model.Container
+}
+
+func NewController(ec chan sysdig.Event) controller.Controller {
+	r := router.NewGroupRouter("/container")
+
+}
+
+func (cc *ContainerController) initRouter() {
+
+}

server/controller/controller.go

@@ -0,0 +1,9 @@
+package controller
+
+import (
+	"github.com/YLonely/sysdig-monitor/server/router"
+)
+
+type Controller interface {
+	BindedRoutes() []router.Route
+}

server/model/container.go

@@ -0,0 +1,69 @@
+package model
+
+import "time"
+
+type Container struct {
+	ID string
+
+	SystemCalls
+
+	FileSystem
+
+	Network
+}
+
+type SystemCalls struct {
+	// map system call name to SystemCall
+	IndividualCalls map[string]SystemCall
+	TotalCalls      int64
+}
+
+type FileSystem struct {
+	// map file name to file
+	AccessedFiles map[string]File
+	// io calls whose latency is bigger than 1ms
+	IOCalls1 []IOCall
+	// io calls whose latency is bigger than 10ms
+	IOCalls10 []IOCall
+	// io calls whose latency is bigger than 100ms
+	IOCalls100    []IOCall
+	TotalReadIn   int64
+	TotalWriteOut int64
+}
+
+type Network struct {
+	ActiveConnections          map[ConnectionMeta]Connection
+	TotalReadIn, TotalWriteOut int64
+}
+
+type SystemCall struct {
+	Name string
+	// total number of times it is invoked
+	Calls     int64
+	TotalTime time.Duration
+}
+
+type File struct {
+	Name     string
+	WriteOut int64
+	ReadIn   int64
+}
+
+type Connection struct {
+	Type string
+	ConnectionMeta
+	WriteOut int64
+	ReadIn   int64
+}
+
+type ConnectionMeta struct {
+	SourceIP   string
+	DestIP     string
+	SourcePort int
+	DestPort   int
+}
+
+type IOCall struct {
+	FileName string
+	Latency  time.Duration
+}

server/router/container/container.go

@@ -1,41 +1,54 @@
 package router
 
-type localRoute struct {
-	method  string
-	path    string
-	handler HandlerType
+type router struct {
+	routes []Route
 }
 
-var _ Route = localRoute{}
+var _ Router = &router{}
 
-func (l localRoute) Method() string {
-	return l.method
+func NewRouter() Router {
+	return &router{}
 }
 
-func (l localRoute) Path() string {
-	return l.path
+func (r *router) Routes() []Route {
+	return r.routes
 }
 
-func (l localRoute) Handler() HandlerType {
-	return l.handler
+func (r *router) AddRoute(path, method string, handler HandlerType) {
+	r.routes = append(r.routes, route{method: method, path: path, handler: handler})
+}
+
+type groupRouter struct {
+	router
+	prefix string
+}
+
+var _ Router = &groupRouter{}
+
+func NewGroupRouter(prefix string) Router {
+	return &groupRouter{prefix: prefix}
 }
 
-func NewRoute(method, path string, handler HandlerType) Route {
-	return localRoute{method: method, path: path, handler: handler}
+func (gr *groupRouter) AddRoute(path, method string, handler HandlerType) {
+	gr.routes = append(gr.routes, route{path: gr.prefix + path, method: method, handler: handler})
 }
 
-func NewGetRoute(method, path string, handler HandlerType) Route {
-	return NewRoute(MethodGet, path, handler)
+type route struct {
+	method  string
+	path    string
+	handler HandlerType
 }
 
-func NewPostRoute(method, path string, handler HandlerType) Route {
-	return NewRoute(MethodPost, path, handler)
+var _ Route = &route{}
+
+func (l route) Method() string {
+	return l.method
 }
 
-func NewPutRoute(method, path string, handler HandlerType) Route {
-	return NewRoute(MethodPut, path, handler)
+func (l route) Path() string {
+	return l.path
 }
 
-func NewDeleteRoute(method, path string, handler HandlerType) Route {
-	return NewRoute(MethodDelete, path, handler)
+func (l route) Handler() HandlerType {
+	return l.handler
 }

server/router/local.go

@@ -9,6 +9,7 @@ type HandlerType func(c *gin.Context)
 // Router defines an interface to specify a group of routes ot add to the server
 type Router interface {
 	Routes() []Route
+	AddRoute(path, method string, handler HandlerType)
 }
 
 // Route defines an individual API route in the sysdig-monitor server