system

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

type ApplicationMemberSpecOptions struct {
	AddressBook             *AddressBook
	CronJobs                []CronJob
	SyncAddressBookInterval time.Duration
}

type AtomicValue[T any] struct {
	// contains filtered or unexported fields
}

type CronJob struct {
	// Name is the unique name of the cron job.
	Name gen.Atom
	// Spec is the cron expression (e.g., "* * * * *").
	Spec string
	// Location specifies the timezone for the schedule, default is UTC.
	Location string
	// TriggerProcess is the name of the process to receive the trigger message.
	TriggerProcess gen.Atom
	// Scope defines whether the job runs on a single node or across the cluster.
	Scope CronJobScope
}

type CronJobScope int

type DaemonIterator func() ([]DaemonProcess, bool, error)

type DaemonIteratorFactory func() DaemonIterator

type DaemonProcess struct {
	// ProcessName is the name of the process.
	ProcessName gen.Atom
	// Args are the arguments to start the process.
	Args []any
}

type IAddressBook interface {
	QueryBy(caller gen.Process, option QueryOption) IAddressBookQuery
	PickNode(process gen.Atom) gen.Atom
	PickDirectoryNode(process gen.Atom) gen.Atom
	GetAvailableNodes() *NodeList
}

type IAddressBookQuery interface {
	// Locate performs a global lookup for a process name across the cluster.
	// This operation involves network communication and may fail due to timeouts.
	Locate(processName gen.Atom) (node gen.Atom, err error)
}

type ImmutableList[T comparable] struct {
	// contains filtered or unexported fields
}

type Launcher struct {
	// Factory is a function that creates a new process.
	Factory gen.ProcessFactory
	// Option provides options for configuring the process.
	Option gen.ProcessOptions

	// RecoveryScanner is an optional function that scans for daemons to recover.
	RecoveryScanner DaemonIteratorFactory // optional
	// contains filtered or unexported fields
}

type Member string

type MessageAddressBook struct {
	Owner gen.PID
	Book  IAddressBook
}

type MessageForwardLocate struct {
	Name gen.Atom
	From gen.PID
	Ref  gen.Ref
}

type MessageGetAddressBook struct{}

type MessageLaunchAllDaemon struct{}

type MessageLaunchOneDaemon struct {
	Launcher gen.Atom
	Process  DaemonProcess
}

type MessageLocate struct {
	Name gen.Atom
}

type MessageLocateResult struct {
	Name gen.Atom
	Node gen.Atom
}

type MessageProcessChanged struct {
	Node        gen.Atom
	UpProcess   []ProcessInfo
	DownProcess []ProcessInfo
	Version     ProcessVersion
	FullSync    bool
}

type NodeList = ImmutableList[gen.Atom]

type ProcessInfo struct {
	// Node is the node name hosting this process.
	Node gen.Atom
	// PID is the process identifier.
	PID gen.PID
	// Name is the registered name associated with this process.
	Name gen.Atom
	// BirthAt is the Unix timestamp (seconds) when the process was started.
	BirthAt int64
}

type ProcessInfoList []ProcessInfo

type ProcessVersion [2]int64

type QueryOption struct {
	// Timeout specifies the query timeout in seconds.
	Timeout int
}

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