actor

type Actor interface {
	// Receive 处理接收到的消息，通过ctx获取上下文信息
	Receive(ctx ActorContext)
}

type ActorCell struct {
	Props         *Props
	Mailbox       Mailbox
	Dispatcher    Dispatcher
	Ref           ActorRef
	Parent        ActorRef
	Children      map[string]ActorRef // 使用map实现O(1)查找和删除
	ChildrenMutex sync.RWMutex        // 保护Children的读写锁
	State         atomic.Int32        // LifecycleState
	// contains filtered or unexported fields
}

type ActorContext interface {
	// Self 获取actor自己的引用
	Self() ActorRef

	// Sender 获取消息发送者引用
	Sender() ActorRef

	// Message 获取当前正在处理的消息
	Message() interface{}

	// Tell 发送消息给其他actor
	Tell(ref ActorRef, msg interface{}) error

	// Ask 发送消息并等待响应（Future模式）
	// 返回一个Future，可以等待结果或注册回调
	Ask(target ActorRef, msg interface{}, timeout time.Duration) (Future, error)

	// Stop 停止当前actor
	Stop() error

	// Spawn 创建子actor
	Spawn(props *Props) (ActorRef, error)

	// Path 获取actor路径
	Path() string

	// Parent 获取父actor引用
	Parent() ActorRef
}

type ActorRef interface {
	// Tell 异步发送消息给actor
	Tell(msg interface{}) error

	// Path 返回actor的路径
	Path() string

	// IsAlive 检查actor是否存活
	IsAlive() bool

	// Equals 比较两个引用是否指向同一个actor
	Equals(other ActorRef) bool
}

type ActorSystem interface {
	// Name 返回系统名称
	Name() string

	// Spawn 创建顶级actor
	Spawn(props *Props) (ActorRef, error)

	// SpawnWithName 创建指定名称的顶级actor
	SpawnWithName(props *Props, name string) (ActorRef, error)

	// Stop 停止指定actor
	Stop(ref ActorRef) error

	// Suspend 暂停actor
	Suspend(ref ActorRef) error

	// Resume 恢复actor
	Resume(ref ActorRef) error

	// Restart 重启actor
	Restart(ref ActorRef) error

	// Lookup 按路径查找actor
	Lookup(path string) (ActorRef, bool)

	// Shutdown 优雅关闭整个系统
	Shutdown(timeout *int) error

	// ShutdownNow 立即关闭系统
	ShutdownNow()

	// DeadLetters 返回死信actor引用
	DeadLetters() ActorRef

	// Root 获取根guardian引用
	Root() ActorRef

	// User 获取user guardian引用
	User() ActorRef

	// System 获取system guardian引用
	System() ActorRef

	// SystemActorOf 创建系统级actor
	SystemActorOf(props *Props, name string) (ActorRef, error)

	// LookupDispatcher 按名称查找dispatcher
	LookupDispatcher(name string) (Dispatcher, bool)

	// RegisterDispatcher 注册dispatcher
	RegisterDispatcher(name string, dispatcher Dispatcher)
}

type AllForOneStrategy struct {
	// contains filtered or unexported fields
}

type Config struct {
	Name               string
	DefaultDispatcher  Dispatcher
	DefaultMailboxSize int
	DefaultSupervisor  SupervisorStrategy
	RootGuardian       string
	UserGuardian       string
	SystemGuardian     string
}

type ConfigOption func(*Config)

type CustomFutureLogger struct {
	DebugFunc func(format string, args ...interface{})
	InfoFunc  func(format string, args ...interface{})
	WarnFunc  func(format string, args ...interface{})
	ErrorFunc func(format string, args ...interface{})
}

type DeadLetter struct {
	Message   interface{}
	Sender    ActorRef
	Recipient ActorRef
	Timestamp string // RFC3339格式时间戳
}

type DeadLettersActor struct {
	*DefaultActor
	// contains filtered or unexported fields
}

type Decider func(reason interface{}) Directive

type DefaultActor struct{}

type DefaultFutureManager struct {
	// contains filtered or unexported fields
}

type Directive int

type Dispatcher interface {
	// Schedule 调度任务执行
	Schedule(fn func())

	// Throughput 返回每次处理的消息数量
	Throughput() int

	// Name 返回dispatcher名称
	Name() string
}

type Future interface {
	// CorrelationID 返回Future的关联ID
	CorrelationID() string

	// Result 等待并返回结果，支持超时控制
	// 如果超时则返回 ErrFutureTimeout
	// 如果被取消则返回 ErrFutureCancelled
	// 如果操作失败则返回相应的错误
	Result(timeout time.Duration) (interface{}, error)

	// Await 是Result的别名，提供更简洁的API
	Await(timeout time.Duration) (interface{}, error)

	// OnComplete 注册一个回调函数，当Future完成时被调用
	// 如果Future已经完成，回调将立即被调用
	OnComplete(callback func(result interface{}, err error))

	// Cancel 取消Future操作
	Cancel()

	// IsReady 检查Future是否已完成
	IsReady() bool

	// State 返回Future当前的状态
	State() FutureState
}

type FutureCallback func(result interface{}, err error)

type FutureImpl struct {
	// contains filtered or unexported fields
}

type FutureLogger interface {
	// Debug 记录调试日志
	Debug(format string, args ...interface{})

	// Info 记录信息日志
	Info(format string, args ...interface{})

	// Warn 记录警告日志
	Warn(format string, args ...interface{})

	// Error 记录错误日志
	Error(format string, args ...interface{})
}

type FutureManager interface {
	// Create 创建一个新的Future并发送消息
	// 为消息包装correlation ID并返回Future实例
	Create(target ActorRef, msg interface{}, timeout time.Duration) (Future, error)

	// Complete 完成一个Future，将响应传递给等待者
	Complete(responseMsg ResponseMessage) bool

	// Cancel 取消一个Future
	Cancel(correlationID string) bool

	// Cleanup 清理已完成或超时的Future
	Cleanup()

	// Count 返回当前活跃的Future数量
	Count() int
}

type FutureState int32

type GuardianActor struct {
	*DefaultActor
	// contains filtered or unexported fields
}

type IDGenerator struct {
	// contains filtered or unexported fields
}

type JSONFutureLogger struct {
	// contains filtered or unexported fields
}

type LifecycleActor interface {
	Actor

	// PreStart 在actor启动前调用
	PreStart(ctx ActorContext) error

	// PostStop 在actor停止后调用
	PostStop(ctx ActorContext) error

	// PreRestart 在actor重启前调用（子actor停止后）
	PreRestart(ctx ActorContext, reason interface{})

	// PostRestart 在actor重启后调用（PreStart之前）
	PostRestart(ctx ActorContext, reason interface{})
}

type LifecycleManager struct {
	// contains filtered or unexported fields
}

type LifecycleState int32

type LogLevel int

type Mailbox interface {
	// PostUserMessage 投递用户消息
	PostUserMessage(msg interface{})

	// PostSystemMessage 投递系统消息
	PostSystemMessage(msg interface{})

	// UserMessageCount 获取用户消息数量
	UserMessageCount() int
}

type MessageInvoker interface {
	// Invoke 调用actor处理消息
	Invoke(receiver Actor, msg interface{})

	// EscalateFailure 将故障上报给监督者
	EscalateFailure(reason string, msg interface{})
}

type Metrics struct {
	MessagesSent      atomic.Uint64
	MessagesReceived  atomic.Uint64
	ActorCreations    atomic.Uint64
	ActorTerminations atomic.Uint64
	RegistryLookups   atomic.Uint64
	LockAcquisitions  atomic.Uint64

	// Latency measurements (in nanoseconds)
	TotalLatency atomic.Uint64
	LatencyCount atomic.Uint64

	// Start time for rate calculations
	StartTime atomic.Int64
}

type MetricsSnapshot struct {
	MessagesPerSec     float64
	MessagesReceived   uint64
	MessagesSent       uint64
	ActiveActors       uint64
	ActorCreations     uint64
	RegistryLookupsSec float64
	AvgLatency         float64
	Uptime             time.Duration
}

type OneForOneStrategy struct {
	// contains filtered or unexported fields
}

type ProfilingConfig struct {
	Enabled bool
	Port    string
}

type Props struct {
	Actor      func() Actor     // actor工厂函数
	Name       string           // actor名称
	Mailbox    Mailbox          // 自定义mailbox（可选）
	Dispatcher Dispatcher       // 自定义dispatcher（可选）
	Supervisor SupervisorConfig // 监督配置
}

type PropsFunc func(*Props)

type Registry interface {
	// Register 注册actor到指定路径
	Register(path string, cell *ActorCell) error

	// Unregister 注销actor
	Unregister(path string)

	// Lookup 查找路径对应的actor
	Lookup(path string) (*ActorCell, bool)

	// Resolve 解析路径字符串为actor引用
	Resolve(path string) (ActorRef, bool)

	// All 返回所有注册的actor路径
	All() []string

	// Children 返回父路径下所有子actor路径
	Children(parent string) []string

	// Count 返回注册的actor总数
	Count() int
}

type ResponseMessage struct {
	CorrelationID string      // 关联ID，用于匹配Future请求
	Result        interface{} // 响应结果
	Error         error       // 响应错误
}

type Supervisor interface {
	// HandleChildFailure 处理子actor故障
	HandleChildFailure(child *ActorCell, reason interface{})
}

type SupervisorConfig struct {
	Strategy     SupervisorStrategy
	StopChildren bool
}

type SupervisorStrategy interface {
	// Decider 决定如何处理子actor故障
	Decider(child ActorRef, reason interface{}) Directive

	// HandleFailure 处理子actor失败
	HandleFailure(child ActorRef, reason interface{})

	// SetSystem 设置ActorSystem引用
	SetSystem(system ActorSystem)
}

type WorkerPool struct {
	// contains filtered or unexported fields
}