代码拉取完成,页面将自动刷新
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{}
)
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。