kubelatte-ce

1
package modules
2

3
import (
4
	"context"
5
	"gitverse.ru/ktrntrsv/kubelatte-ce/pkg/creation"
6
	"gitverse.ru/ktrntrsv/kubelatte-ce/pkg/kubeapi"
7
	"gitverse.ru/ktrntrsv/kubelatte-ce/pkg/operator/audit"
8
	controllers2 "gitverse.ru/ktrntrsv/kubelatte-ce/pkg/operator/controllers/controllers"
9
	"gitverse.ru/ktrntrsv/kubelatte-ce/pkg/operator/init_manager"
10
	"gitverse.ru/ktrntrsv/kubelatte-ce/pkg/operator/permission"
11
	"gitverse.ru/ktrntrsv/kubelatte-ce/pkg/operator/utils"
12
	"gitverse.ru/ktrntrsv/kubelatte-ce/pkg/sideeffect"
13
	"gitverse.ru/ktrntrsv/kubelatte-ce/pkg/sideeffect/sideeffect"
14
)
15

16
var (
17
	aud = audit.AuditStub
18

19
	watcher     = creation.NewWatcher(5)
20
	creRenderer = creation.NewRender()
21
	factory     = creation.NewFactoryController(kubeapi.GetClient(), creRenderer, nil)
22

23
	sideEffectExecutor = sideeffect.NewExecutor(nil)
24

25
	permissioner = permission.NewManager()
26
	initer       = initmanager.NewInitManager(nil)
27

28
	templateReconciler        utils.TemplateReconciler  = controllers2.NewTemplateReconciler(nil)
29
	triggerReconciler         utils.TriggerReconciler   = controllers2.NewTriggerReconciler(nil)
30
	scoperReconciler          utils.ScopeReconciler     = controllers2.NewScopeReconciler(nil)
31
	namespaceReconciler       utils.ReconcilerInterface = controllers2.NewNamespaceReconciler(permissioner, nil)
32
	triggerInstanceReconciler utils.ReconcilerInterface = controllers2.NewTriggerInstanceReconciler(nil)
33
)
34

35
type ActorsOperator struct {
36
	Audit                     func()
37
	SideEffectExecutor        base.ExecutorI
38
	Watcher                   creation.WatcherI
39
	Factory                   creation.FactoryI
40
	Permissioner              permission.PermissionerI
41
	Initer                    initmanager.InitManagerI
42
	Syncer                    SyncI
43
	TemplateReconciler        utils.TemplateReconciler
44
	TriggerReconciler         utils.TriggerReconciler
45
	ScoperReconciler          utils.ScopeReconciler
46
	TriggerInstanceReconciler utils.ReconcilerInterface
47
	NamespaceReconciler       utils.ReconcilerInterface
48
}
49

50
var ActorsOp = ActorsOperator{
51
	Audit:                     aud,
52
	SideEffectExecutor:        sideEffectExecutor,
53
	Watcher:                   watcher,
54
	Factory:                   factory,
55
	Permissioner:              permissioner,
56
	Initer:                    initer,
57
	TemplateReconciler:        templateReconciler,
58
	TriggerReconciler:         triggerReconciler,
59
	ScoperReconciler:          scoperReconciler,
60
	TriggerInstanceReconciler: triggerInstanceReconciler,
61
	NamespaceReconciler:       namespaceReconciler,
62
}
63

64
type SyncI interface {
65
	Start()
66
	Stop()
67
	Ping() error
68
	LastTime() int64
69
	WaitForServerReadiness(ctx context.Context)
70
}
71