Versions in this module Expand all Collapse all v0 v0.6.1 Aug 17, 2024 v0.6.0 Aug 14, 2024 Changes in this version + const AbyssTopic + const DefaultFutureAskTimeout + const DefaultPersistenceEventThreshold + var File_messages_proto protoreflect.FileDescriptor + func FutureAsk[M Message](ctx mixinDeliver, target ActorRef, message Message, timeout ...time.Duration) future.Future[M] + func GetDefaultPersistenceStorageProvider() persistence.StorageProvider + func RegisterFutureAskType(handler func(ctx any) *ActorSystem) + type AbyssProcess interface + OnInitialize func(system *ActorSystem) + type Actor interface + OnReceive func(ctx ActorContext) + type ActorBehavior = behavior.Behavior[ActorContext] + type ActorContext interface + type ActorDescriptor struct + func (d *ActorDescriptor) WithDispatcherProvider(provider DispatcherProvider) *ActorDescriptor + func (d *ActorDescriptor) WithExpireDuration(duration time.Duration) *ActorDescriptor + func (d *ActorDescriptor) WithIdleDeadline(deadline time.Duration) *ActorDescriptor + func (d *ActorDescriptor) WithMailboxProvider(provider MailboxProvider) *ActorDescriptor + func (d *ActorDescriptor) WithName(name string) *ActorDescriptor + func (d *ActorDescriptor) WithNamePrefix(prefix string) *ActorDescriptor + func (d *ActorDescriptor) WithPersistenceEventThreshold(threshold int) *ActorDescriptor + func (d *ActorDescriptor) WithPersistenceName(name persistence.Name) *ActorDescriptor + func (d *ActorDescriptor) WithPersistenceStorageProvider(provider persistence.StorageProvider) *ActorDescriptor + func (d *ActorDescriptor) WithSlowProcessingDuration(duration time.Duration, receivers ...ActorRef) *ActorDescriptor + func (d *ActorDescriptor) WithSupervisionStrategyProvider(provider supervision.StrategyProvider, loggers ...supervision.Logger) *ActorDescriptor + type ActorDescriptorConfigurator interface + Configure func(descriptor *ActorDescriptor) + type ActorPerformance = behavior.Performance[ActorContext] + type ActorProvider interface + Provide func() Actor + type ActorRef = *prc.ProcessId + func NewActorRef(physicalAddress prc.PhysicalAddress, logicAddress prc.LogicalAddress) ActorRef + type ActorSystem struct + func NewActorSystem(configurator ...ActorSystemConfigurator) *ActorSystem + func NewActorSystemWithConfiguration(configuration *ActorSystemConfiguration, ...) *ActorSystem + func (sys *ActorSystem) Abyss() ActorRef + func (sys *ActorSystem) ActorOf(provider ActorProvider, configurator ...ActorDescriptorConfigurator) ActorRef + func (sys *ActorSystem) ActorOfF(provider FunctionalActorProvider, ...) ActorRef + func (sys *ActorSystem) Ask(target ActorRef, message Message) + func (sys *ActorSystem) AwaitForward(target ActorRef, asyncFunc func() Message) + func (sys *ActorSystem) Broadcast(message Message) + func (sys *ActorSystem) Context() ActorContext + func (sys *ActorSystem) FutureAsk(target ActorRef, message Message, timeout ...time.Duration) future.Future[Message] + func (sys *ActorSystem) Logger() *log.Logger + func (sys *ActorSystem) Name() string + func (sys *ActorSystem) PhysicalAddress() prc.PhysicalAddress + func (sys *ActorSystem) Publish(topic Topic, message Message) + func (sys *ActorSystem) Shutdown(gracefully bool) + func (sys *ActorSystem) Signal(handler func(system *ActorSystem, signal os.Signal)) + func (sys *ActorSystem) Tell(target ActorRef, message Message) + func (sys *ActorSystem) Terminate(target ActorRef, gracefully bool) + type ActorSystemConfiguration struct + func NewActorSystemConfiguration() *ActorSystemConfiguration + func (c *ActorSystemConfiguration) WithAbyss(abyss AbyssProcess) *ActorSystemConfiguration + func (c *ActorSystemConfiguration) WithAccidentTrace() *ActorSystemConfiguration + func (c *ActorSystemConfiguration) WithGRPCServerHooks(hooks ...func(server *grpc.Server)) *ActorSystemConfiguration + func (c *ActorSystemConfiguration) WithLoggerProvider(provider log.LoggerProvider) *ActorSystemConfiguration + func (c *ActorSystemConfiguration) WithName(name string) *ActorSystemConfiguration + func (c *ActorSystemConfiguration) WithShared(address prc.PhysicalAddress, codec ...codec.Codec) *ActorSystemConfiguration + func (c *ActorSystemConfiguration) WithShutdownAfterHooks(hooks ...ShutdownAfterHook) *ActorSystemConfiguration + func (c *ActorSystemConfiguration) WithSubscriptionContactProviders(providers ...SubscriptionContactProvider) *ActorSystemConfiguration + type ActorSystemConfigurator interface + Configure func(config *ActorSystemConfiguration) + type DispatcherProvider interface + Provide func() dispatcher.Dispatcher + func GetDefaultDispatcherProvider() DispatcherProvider + type FunctionalActor func(ctx ActorContext) + func (f FunctionalActor) OnReceive(ctx ActorContext) + type FunctionalActorDescriptorConfigurator func(descriptor *ActorDescriptor) + func (f FunctionalActorDescriptorConfigurator) Configure(descriptor *ActorDescriptor) + type FunctionalActorPerformance = behavior.FunctionalPerformance[ActorContext] + type FunctionalActorProvider func() Actor + func (f FunctionalActorProvider) Provide() Actor + type FunctionalActorSystemConfigurator func(config *ActorSystemConfiguration) + func (f FunctionalActorSystemConfigurator) Configure(config *ActorSystemConfiguration) + type FunctionalDispatcherProvider func() dispatcher.Dispatcher + func (f FunctionalDispatcherProvider) Provide() dispatcher.Dispatcher + type FunctionalMailboxProvider func(dispatcher dispatcher.Dispatcher, recipient mailbox.Recipient) mailbox.Mailbox + func (f FunctionalMailboxProvider) Provide(dispatcher dispatcher.Dispatcher, recipient mailbox.Recipient) mailbox.Mailbox + type FunctionalStatefulActorPerformance = behavior.FunctionalStatefulPerformance[ActorContext] + type MailboxProvider interface + Provide func(dispatcher dispatcher.Dispatcher, recipient mailbox.Recipient) mailbox.Mailbox + func GetDefaultMailboxProvider() MailboxProvider + type Message = prc.Message + type MessageWrapper struct + Message Message + Receiver ActorRef + Sender ActorRef + type OnAbyssMessageEvent struct + Forward ActorRef + Message Message + Receiver ActorRef + Sender ActorRef + Time time.Time + type OnLaunch int8 + type OnPersistenceSnapshot int8 + type OnRestarted int8 + type OnRestarting int8 + type OnSlowProcess struct + ActorRef ActorRef + Duration time.Duration + type OnTerminate struct + Gracefully bool + func (*OnTerminate) Descriptor() ([]byte, []int) + func (*OnTerminate) ProtoMessage() + func (x *OnTerminate) GetGracefully() bool + func (x *OnTerminate) ProtoReflect() protoreflect.Message + func (x *OnTerminate) Reset() + func (x *OnTerminate) String() string + type OnTerminated struct + TerminatedActor ActorRef + type ShutdownAfterHook func() + type Subscription interface + SubscriptionId func() uint64 + type SubscriptionContactEvent struct + Address prc.PhysicalAddress + Stop bool + type SubscriptionContactProvider interface + ChangeNotify func() <-chan *SubscriptionContactEvent + type Topic = string
Go to main page