forked from steadybit/extension-kubernetes
-
Notifications
You must be signed in to change notification settings - Fork 0
/
main.go
69 lines (55 loc) · 2.21 KB
/
main.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
// SPDX-License-Identifier: MIT
// SPDX-FileCopyrightText: 2023 Steadybit GmbH
package main
import (
"context"
_ "github.com/KimMachineGun/automemlimit" // By default, it sets `GOMEMLIMIT` to 90% of cgroup's memory limit.
"github.com/rs/zerolog"
"github.com/steadybit/action-kit/go/action_kit_api/v2"
"github.com/steadybit/action-kit/go/action_kit_sdk"
"github.com/steadybit/discovery-kit/go/discovery_kit_api"
"github.com/steadybit/discovery-kit/go/discovery_kit_sdk"
"github.com/steadybit/extension-kit/extbuild"
"github.com/steadybit/extension-kit/exthealth"
"github.com/steadybit/extension-kit/exthttp"
"github.com/steadybit/extension-kit/extlogging"
"github.com/steadybit/extension-kit/extruntime"
"github.com/steadybit/extension-kit/extsignals"
"github.com/steadybit/extension-kubernetes-kubectl-example/client"
"github.com/steadybit/extension-kubernetes-kubectl-example/extconfig"
"github.com/steadybit/extension-kubernetes-kubectl-example/extcontainer"
"github.com/steadybit/extension-kubernetes-kubectl-example/extexample"
_ "go.uber.org/automaxprocs" // Importing automaxprocs automatically adjusts GOMAXPROCS.
_ "net/http/pprof" //allow pprof
)
func main() {
stopCh := make(chan struct{})
defer close(stopCh)
extlogging.InitZeroLog()
extconfig.ParseConfiguration()
extconfig.ValidateConfiguration()
extbuild.PrintBuildInformation()
extruntime.LogRuntimeInformation(zerolog.DebugLevel)
exthealth.SetReady(false)
exthealth.StartProbes(8089)
client.PrepareClient(stopCh)
discovery_kit_sdk.Register(extcontainer.NewContainerDiscovery(context.Background(), client.K8S))
action_kit_sdk.RegisterAction(extexample.NewExampleAction())
exthttp.RegisterHttpHandler("/", exthttp.GetterAsHandler(getExtensionList))
extsignals.ActivateSignalHandlers()
action_kit_sdk.RegisterCoverageEndpoints()
exthealth.SetReady(true)
exthttp.Listen(exthttp.ListenOpts{
Port: 8088,
})
}
type ExtensionListResponse struct {
action_kit_api.ActionList `json:",inline"`
discovery_kit_api.DiscoveryList `json:",inline"`
}
func getExtensionList() ExtensionListResponse {
return ExtensionListResponse{
ActionList: action_kit_sdk.GetActionList(),
DiscoveryList: discovery_kit_sdk.GetDiscoveryList(),
}
}