1 Star 0 Fork 0

jack/protoactor-go

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
克隆/下载
k8s_cluster_monitor.go 2.17 KB
一键复制 编辑 原始数据 按行查看 历史
490689386@qq.com 提交于 2025-05-19 14:50 +08:00 . 初始化
package k8s
import (
"log/slog"
"time"
"gitee.com/wujianhai/protoactor-go/actor"
"gitee.com/wujianhai/protoactor-go/scheduler"
)
type k8sClusterMonitorActor struct {
*Provider
actor.Behavior
refreshCanceller scheduler.CancelFunc
}
func (kcm *k8sClusterMonitorActor) Receive(ctx actor.Context) { kcm.Behavior.Receive(ctx) }
func (kcm *k8sClusterMonitorActor) init(ctx actor.Context) {
switch r := ctx.Message().(type) {
case *RegisterMember:
// make sure timeout is set to some meaningful value
timeout := getTimeout(ctx, kcm)
if err := kcm.registerMember(timeout); err != nil {
ctx.Logger().Error("Failed to register service to k8s, will retry", slog.Any("error", err))
ctx.Send(ctx.Self(), r)
return
}
ctx.Logger().Info("Registered service to k8s")
case *DeregisterMember:
ctx.Logger().Debug("Deregistering service from k8s")
timeout := getTimeout(ctx, kcm)
if err := kcm.deregisterMember(timeout); err != nil {
ctx.Logger().Error("Failed to deregister service from k8s, proceeding with shutdown", slog.Any("error", err))
} else {
ctx.Logger().Info("Deregistered service from k8s")
}
ctx.Respond(&DeregisterMemberResponse{})
case *StartWatchingCluster:
if err := kcm.startWatchingCluster(); err != nil {
ctx.Logger().Error("Failed to start watching k8s cluster, will retry", slog.Any("error", err))
ctx.Send(ctx.Self(), r)
return
}
ctx.Logger().Info("k8s cluster started to being watched")
case *StopWatchingCluster:
if kcm.cancelWatch != nil {
kcm.cancelWatch()
}
ctx.Respond(&StopWatchingClusterResponse{})
}
}
func getTimeout(ctx actor.Context, kcm *k8sClusterMonitorActor) time.Duration {
timeout := ctx.ReceiveTimeout()
if timeout.Microseconds() == 0 {
timeout = kcm.Provider.cluster.Config.RequestTimeoutTime
if timeout.Microseconds() == 0 {
timeout = time.Second * 5 // default to 5 seconds
}
}
return timeout
}
// creates and initializes a new k8sClusterMonitorActor in the heap and
// returns a reference to its memory address
func newClusterMonitor(provider *Provider) actor.Actor {
kcm := k8sClusterMonitorActor{
Behavior: actor.NewBehavior(),
Provider: provider,
}
kcm.Become(kcm.init)
return &kcm
}
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
1
https://gitee.com/wujianhai/protoactor-go.git
git@gitee.com:wujianhai/protoactor-go.git
wujianhai
protoactor-go
protoactor-go
5633fe2499dd

搜索帮助