table

type ActorHostOptions struct {
	EntityConfigs           map[string]api.EntityConfig
	DrainRebalancedActors   bool
	DrainOngoingCallTimeout time.Duration
}

type ActorTypeFactory struct {
	Type       string
	Reentrancy config.ReentrancyConfig
	Factory    targets.Factory
}

type Interface interface {
	io.Closer

	Types() []string
	IsActorTypeHosted(actorType string) bool
	HostedTarget(actorType, actorKey string) (targets.Interface, bool)
	GetOrCreate(actorType, actorID string) (targets.Interface, bool, error)
	RegisterActorTypes(opts RegisterActorTypeOptions)
	UnRegisterActorTypes(actorTypes ...string) error
	SubscribeToTypeUpdates(ctx context.Context) (<-chan []string, []string)
	HaltAll() error
	HaltIdlable(ctx context.Context, target targets.Idlable) error
	Drain(fn func(target targets.Interface) bool) error
	Len() map[string]int

	DeleteFromTableIn(actor targets.Interface, in time.Duration)
	RemoveIdler(actor targets.Interface)
}

type Options struct {
	IdlerQueue      *queue.Processor[string, targets.Idlable]
	Locker          locker.Interface
	ReentrancyStore *reentrancystore.Store
}

type RegisterActorTypeOptions struct {
	HostOptions *ActorHostOptions
	Factories   []ActorTypeFactory
}