1 Star 0 Fork 0

jack/protoactor-go

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
克隆/下载
messages.go 3.47 KB
一键复制 编辑 原始数据 按行查看 历史
490689386@qq.com 提交于 2025-05-19 14:50 +08:00 . 初始化
package actor
// ResumeMailbox is message sent by the actor system to resume mailbox processing.
//
// This will not be forwarded to the Receive method
type ResumeMailbox struct{}
// SuspendMailbox is message sent by the actor system to suspend mailbox processing.
//
// This will not be forwarded to the Receive method
type SuspendMailbox struct{}
type MailboxMessage interface {
MailboxMessage()
}
func (*SuspendMailbox) MailboxMessage() {}
func (*ResumeMailbox) MailboxMessage() {}
// InfrastructureMessage is a marker for all built in Proto.Actor messages
type InfrastructureMessage interface {
InfrastructureMessage()
}
// IgnoreDeadLetterLogging messages are not logged in deadletter log
type IgnoreDeadLetterLogging interface {
IgnoreDeadLetterLogging()
}
// An AutoReceiveMessage is a special kind of user message that will be handled in some way automatically by the actor
type AutoReceiveMessage interface {
AutoReceiveMessage()
}
// NotInfluenceReceiveTimeout messages will not reset the ReceiveTimeout timer of an actor that receives the message
type NotInfluenceReceiveTimeout interface {
NotInfluenceReceiveTimeout()
}
// A SystemMessage message is reserved for specific lifecycle messages used by the actor system
type SystemMessage interface {
SystemMessage()
}
// A ReceiveTimeout message is sent to an actor after the Context.ReceiveTimeout duration has expired
type ReceiveTimeout struct{}
// A Restarting message is sent to an actor when the actor is being restarted by the system due to a failure
type Restarting struct{}
// A Stopping message is sent to an actor prior to the actor being stopped
type Stopping struct{}
// A Stopped message is sent to the actor once it has been stopped. A stopped actor will receive no further messages
type Stopped struct{}
// A Started message is sent to an actor once it has been started and ready to begin receiving messages.
type Started struct{}
// Restart is message sent by the actor system to control the lifecycle of an actor
type Restart struct{}
// Failure message is sent to an actor parent when an exception is thrown by one of its methods
type Failure struct {
Who *PID
Reason interface{}
RestartStats *RestartStatistics
Message interface{}
}
type continuation struct {
message interface{}
f func()
}
func (*Touch) GetAutoResponse(ctx Context) interface{} {
return &Touched{
Who: ctx.Self(),
}
}
func (*Restarting) AutoReceiveMessage() {}
func (*Stopping) AutoReceiveMessage() {}
func (*Stopped) AutoReceiveMessage() {}
func (*PoisonPill) AutoReceiveMessage() {}
func (*Started) SystemMessage() {}
func (*Stop) SystemMessage() {}
func (*Watch) SystemMessage() {}
func (*Unwatch) SystemMessage() {}
func (*Terminated) SystemMessage() {}
func (*Failure) SystemMessage() {}
func (*Restart) SystemMessage() {}
func (*continuation) SystemMessage() {}
var (
restartingMessage AutoReceiveMessage = &Restarting{}
stoppingMessage AutoReceiveMessage = &Stopping{}
stoppedMessage AutoReceiveMessage = &Stopped{}
poisonPillMessage AutoReceiveMessage = &PoisonPill{}
receiveTimeoutMessage interface{} = &ReceiveTimeout{}
restartMessage SystemMessage = &Restart{}
startedMessage SystemMessage = &Started{}
stopMessage SystemMessage = &Stop{}
resumeMailboxMessage MailboxMessage = &ResumeMailbox{}
suspendMailboxMessage MailboxMessage = &SuspendMailbox{}
_ AutoRespond = &Touch{}
)
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
1
https://gitee.com/wujianhai/protoactor-go.git
git@gitee.com:wujianhai/protoactor-go.git
wujianhai
protoactor-go
protoactor-go
5633fe2499dd

搜索帮助