-
Notifications
You must be signed in to change notification settings - Fork 0
/
api.go
76 lines (60 loc) · 1.76 KB
/
api.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
// Package api contains the api to access the radar test cases.
package api
/* Copyright (C) 2017 Radar team (see AUTHORS)
This file is part of radar.
radar is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.
radar is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with radar. If not, see <http://www.gnu.org/licenses/>.
*/
import (
"fmt"
"net"
"time"
"github.com/golang/glog"
"github.com/valyala/fasthttp"
"github.com/radar-go/radar/config"
"github.com/radar-go/radar/ui/api/controller"
)
// API structure to manage the Radar API.
type API struct {
listener net.Listener
}
// New creates and returns a new API object.
func New() *API {
return &API{}
}
// Start starts the Radar API.
func (a *API) Start() error {
var err error
cfg := config.New()
c := controller.New()
server := fasthttp.Server{
Handler: fasthttp.CompressHandler(c.Router.Handler),
ReadBufferSize: 1024 * 64,
WriteBufferSize: 1024 * 64,
ReduceMemoryUsage: true,
}
a.listener, err = net.Listen("tcp4", fmt.Sprint(":", cfg.APIPort))
if err != nil {
return err
}
glog.Infof("Starting api on port %d...", cfg.APIPort)
return server.Serve(a.listener)
}
// Stop stops the API.
func (a *API) Stop() error {
var err error
if a.listener != nil {
err = a.listener.Close()
time.Sleep(time.Second)
a.listener = nil
}
return err
}