45 lines
957 B
Go
45 lines
957 B
Go
// Copyright 2022 Listware
|
|
|
|
package main
|
|
|
|
import (
|
|
"context"
|
|
|
|
"git.fg-tech.ru/listware/go-core/pkg/client/system"
|
|
"git.fg-tech.ru/listware/proto/sdk/pbcmdb"
|
|
"git.fg-tech.ru/listware/proto/sdk/pbtypes"
|
|
)
|
|
|
|
var logTrigger = &pbcmdb.Trigger{
|
|
Type: "create",
|
|
FunctionType: &pbtypes.FunctionType{
|
|
Namespace: "system",
|
|
Type: "log.system.functions.root",
|
|
},
|
|
}
|
|
var initTrigger = &pbcmdb.Trigger{
|
|
Type: "update",
|
|
FunctionType: &pbtypes.FunctionType{
|
|
Namespace: "proxy",
|
|
Type: "init.inventory.functions.root",
|
|
},
|
|
}
|
|
|
|
func createInitTrigger(ctx context.Context) (err error) {
|
|
message, err := system.AddLinkTrigger("types/node", "types/function", initTrigger)
|
|
if err != nil {
|
|
return
|
|
}
|
|
|
|
return exec.ExecSync(ctx, message)
|
|
}
|
|
|
|
func deleteInitTrigger(ctx context.Context) (err error) {
|
|
message, err := system.DeleteLinkTrigger("types/node", "types/function", initTrigger)
|
|
if err != nil {
|
|
return
|
|
}
|
|
|
|
return exec.ExecSync(ctx, message)
|
|
}
|