actors

Apr 4, 2024

Changes in this version

+ var ErrTypeNotRegistered = errors.New("actor type is not registered")

+ func RemoteSpawn(ctx context.Context, host string, port int, name, actorType string) error

type ActorSystem

+ Deregister func(ctx context.Context, actor Actor) error

+ Register func(ctx context.Context, actor Actor) error

type PID

+ Equals func(to PID) bool

+ ID func() string

+ RemoteSpawn func(ctx context.Context, host string, port int, name, actorType string) error

type Path

+ func (p *Path) Equals(x *Path) bool

Mar 30, 2024

Changes in this version

+ func IsEOF(err error) bool

+ func RemoteStop(ctx context.Context, host string, port int, name string) error

type PID

+ RemoteStop func(ctx context.Context, host string, port int, name string) error

Mar 10, 2024

Changes in this version

type ActorSystem

+ SpawnFromFunc func(ctx context.Context, receiveFunc ReceiveFunc, opts ...FuncOption) (PID, error)

+ type FuncOption interface

+ Apply func(actor *fnActor)

+ func WithPostStop(fn PostStopFunc) FuncOption

+ func WithPreStart(fn PreStartFunc) FuncOption

type Path

+ func (p *Path) Equal(x *Path) bool

+ type PostStopFunc = func(ctx context.Context) error

+ type PreStartFunc = func(ctx context.Context) error

type ReceiveContext

+ Err func(err error)

+ type ReceiveFunc = func(ctx context.Context, message proto.Message) error

Feb 16, 2024

Changes in this version

+ func RemoteReSpawn(ctx context.Context, host string, port int, name string) error

type PID

+ RemoteReSpawn func(ctx context.Context, host string, port int, name string) error

type ReceiveContext

+ RemoteReSpawn func(host string, port int, name string)

+ type Registry interface

+ GetNamedType func(name string) (reflect.Type, bool)

+ GetType func(v any) (reflect.Type, bool)

+ Register func(name string, v any)

+ func NewRegistry() Registry

Feb 4, 2024

Changes in this version

type ActorSystem

+ PeerAddress func() string

Dec 31, 2023

Changes in this version

type Option

+ func WithMetric() Option

Dec 16, 2023

Changes in this version

type Mailbox

+ Iterator func() <-chan ReceiveContext

type Option

+ func WithTracing() Option

Nov 18, 2023

Changes in this version

+ func BatchAsk(ctx context.Context, to PID, timeout time.Duration, messages ...proto.Message) (responses chan proto.Message, err error)

+ func BatchTell(ctx context.Context, to PID, messages ...proto.Message) error

+ func RemoteBatchAsk(ctx context.Context, to *addresspb.Address, messages ...proto.Message) (responses []*anypb.Any, err error)

+ func RemoteBatchTell(ctx context.Context, to *addresspb.Address, messages ...proto.Message) error

type PID

+ BatchAsk func(ctx context.Context, to PID, messages ...proto.Message) (responses chan proto.Message, err error)

+ BatchTell func(ctx context.Context, to PID, messages ...proto.Message) error

+ RemoteBatchAsk func(ctx context.Context, to *addresspb.Address, messages ...proto.Message) (responses []*anypb.Any, err error)

+ RemoteBatchTell func(ctx context.Context, to *addresspb.Address, messages ...proto.Message) error

type ReceiveContext

+ BatchAsk func(to PID, messages ...proto.Message) (responses chan proto.Message)

+ BatchTell func(to PID, messages ...proto.Message)

+ RemoteBatchAsk func(to *addresspb.Address, messages ...proto.Message) (responses []*anypb.Any)

+ RemoteBatchTell func(to *addresspb.Address, messages ...proto.Message)

Nov 6, 2023

Changes in this version

+ const DefaultInitTimeout

type Option

+ func WithActorInitTimeout(timeout time.Duration) Option

Nov 1, 2023

Changes in this version

type ActorSystem

+ RemoteScheduleOnce func(ctx context.Context, message proto.Message, address *addresspb.Address, ...) error

+ RemoteScheduleWithCron func(ctx context.Context, message proto.Message, address *addresspb.Address, ...) error

+ ScheduleOnce func(ctx context.Context, message proto.Message, pid PID, interval time.Duration) error

+ ScheduleWithCron func(ctx context.Context, message proto.Message, pid PID, cronExpression string) error

Oct 23, 2023

Changes in this version

type Option

+ func WithPartitionHasher(hasher hash.Hasher) Option

Oct 1, 2023

Changes in this version

type ActorSystem

+ Subscribe func(event eventspb.Event) (eventstream.Subscriber, error)

+ Unsubscribe func(event eventspb.Event, subscriber eventstream.Subscriber) error

Sep 27, 2023

Changes in this version

+ var ErrActorSystemNotStarted = errors.New("actor system has not started yet")

+ var ErrClusterDisabled = errors.New("cluster is not enabled")

+ var ErrInitFailure = func(err error) error

+ var ErrInvalidActorInterface = errors.New(...)

+ var ErrInvalidNode = connect.NewError(connect.CodeFailedPrecondition, errors.New("invalid actor system node"))

+ var ErrRemotingDisabled = errors.New("remoting is not enabled")

type ActorSystem

+ SubscribeToEvent func(ctx context.Context, event eventspb.Event) (eventstream.Subscriber, error)

+ UnsubscribeToEvent func(ctx context.Context, event eventspb.Event, subscriber eventstream.Subscriber) error

type ReceiveContext

+ Forward func(to PID)

+ Unhandled func()

Sep 12, 2023

Changes in this version

+ var ErrDead = errors.New("actor is not alive")

type PID

+ Child func(ctx context.Context, name string) (PID, error)

+ StartCount func(ctx context.Context) uint64

+ Stop func(ctx context.Context, pid PID) error

type ReceiveContext

+ Ask func(to PID, message proto.Message) (response proto.Message)

+ Child func(name string) PID

+ Children func() []PID

+ RemoteAsk func(to *addresspb.Address, message proto.Message) (response *anypb.Any)

+ RemoteLookup func(host string, port int, name string) (addr *addresspb.Address)

+ RemoteTell func(to *addresspb.Address, message proto.Message)

+ Shutdown func()

+ Spawn func(name string, actor Actor) PID

+ Stop func(child PID)

+ Tell func(to PID, message proto.Message)

Sep 10, 2023

Changes in this version

+ var ErrStashBufferNotSet = errors.New("actor is not setup with a stash buffer")

type Mailbox

+ Capacity func() uint64

type Option

+ func WithStash(capacity uint64) Option

type PID

+ StashSize func(ctx context.Context) uint64

type ReceiveContext

+ Stash func()

+ Unstash func()

+ UnstashAll func()

Sep 7, 2023

Changes in this version

+ var ErrAddressNotFound = func(addr string) error

+ var ErrClusterNotEnabled = errors.New("cluster is not enabled")

+ var ErrEmptyMailbox = errors.New("mailbox is empty")

+ var ErrFullMailbox = errors.New("mailbox is full")

+ var ErrInvalidActorSystemNode = connect.NewError(connect.CodeFailedPrecondition, errors.New("invalid actor system node"))

+ var ErrInvalidRemoteMessage = func(err error) error

+ type Mailbox interface

+ Clone func() Mailbox

+ IsEmpty func() bool

+ IsFull func() bool

+ Pop func() (msg ReceiveContext, err error)

+ Push func(msg ReceiveContext) error

+ Reset func()

+ Size func() uint64

type Option

+ func WithMailbox(mailbox Mailbox) Option

+ func WithMailboxSize(size uint64) Option

type WatchMan

+ ID PID

Aug 29, 2023

Changes in this version

type ReceiveContext

+ RemoteSender func() *pb.Address

Aug 19, 2023

Changes in this version

+ const DefaultInitMaxRetries

+ const DefaultPassivationTimeout

+ const DefaultReplyTimeout

+ const DefaultShutdownTimeout

+ const DefaultSupervisoryStrategy

+ var ErrMethodCallNotAllowed = errors.New("method call not allowed")

+ var ErrNotRunning = errors.New("actor is not running")

type ActorSystem

+ ActorOf func(ctx context.Context, actorName string) (addr *pb.Address, pid PID, err error)

+ GetPartition func(ctx context.Context, actorName string) uint64

+ Kill func(ctx context.Context, name string) error

+ LocalActor func(ctx context.Context, actorName string) (PID, error)

+ ReSpawn func(ctx context.Context, name string) (PID, error)

+ RemoteActor func(ctx context.Context, actorName string) (addr *pb.Address, err error)

+ Spawn func(ctx context.Context, name string, actor Actor) PID

type Option

+ func WithShutdownTimeout(timeout time.Duration) Option

type PID

+ ActorHandle func() Actor

+ IsRunning func() bool

May 23, 2023

Changes in this version

+ var ErrActorNotFound = errors.New("actor not found")

+ var ErrLocalAddress = errors.New("address is a local address")

+ var ErrRemoteAddress = errors.New("address is a remote address")

+ var ErrRemotingNotEnabled = errors.New("remoting is not enabled")

+ func Ask(ctx context.Context, to PID, message proto.Message, timeout time.Duration) (response proto.Message, err error)

+ func RemoteAsk(ctx context.Context, to *pb.Address, message proto.Message) (response *anypb.Any, err error)

+ func RemoteTell(ctx context.Context, to *pb.Address, message proto.Message) error

+ func Tell(ctx context.Context, to PID, message proto.Message) error

type ActorSystem

+ GetRemoteActor func(ctx context.Context, actorName string) (addr *pb.Address, err error)

+ InCluster func() bool

+ type Address struct

+ func NewAddress(protocol string, system string, host string, port int) *Address

+ func (a *Address) Host() string

+ func (a *Address) HostPort() string

+ func (a *Address) IsLocal() bool

+ func (a *Address) IsRemote() bool

+ func (a *Address) Port() int

+ func (a *Address) Protocol() string

+ func (a *Address) String() string

+ func (a *Address) System() string

+ func (a *Address) WithHost(host string) (*Address, error)

+ func (a *Address) WithPort(port int) (*Address, error)

+ func (a *Address) WithSystem(system string) *Address

type Option

+ func WithClustering(disco discovery.Discovery, remotingPort int32) Option

type Path

+ func (p *Path) Address() *Address

+ type WatchMan struct

+ Done chan Unit

+ ErrChan chan error

+ Parent PID

Apr 8, 2023

Changes in this version

type ActorSystem

+ GetLocalActor func(ctx context.Context, actorName string) (PID, error)

type Config

+ func (c Config) RemotingEnabled() bool

+ func (c Config) SupervisorStrategy() StrategyDirective

+ func (c Config) Telemetry() *telemetry.Telemetry

Mar 25, 2023

Changes in this version

+ var ErrEmptyBehavior = errors.New("no behavior defined")

+ var ErrInstanceNotAnActor = errors.New(...)

+ var ErrInvalidActorSystemName = errors.New(...)

+ var ErrInvalidInstance = errors.New("failed to create instance. Reason: invalid instance")

+ var ErrMissingConfig = errors.New("config is missing")

+ var ErrNameRequired = errors.New("actor system is required")

+ var ErrNodeAddrRequired = errors.New("actor system node address is required")

+ var ErrNotReady = errors.New("actor is not ready")

+ var ErrRemoteActorNotFound = func(addr string) error

+ var ErrRemoteSendFailure = func(err error) error

+ var ErrRemoteSendInvalidActorSystem = status.Error(codes.FailedPrecondition, "invalid actor system")

+ var ErrRemoteSendInvalidNode = status.Error(codes.FailedPrecondition, "invalid actor system node")

+ var ErrRequestTimeout = errors.New("request timed out")

+ var ErrTypeNotFound = func(typeName string) error

+ var ErrUndefinedActor = errors.New("actor is not defined")

+ var ErrUnhandled = errors.New("unhandled message")

+ var RemoteNoSender = new(pb.Address)

+ func RemoteLookup(ctx context.Context, host string, port int, name string) (addr *pb.Address, err error)

+ func RemoteSendAsync(ctx context.Context, to *pb.Address, message proto.Message) error

+ func RemoteSendSync(ctx context.Context, to *pb.Address, message proto.Message) (response proto.Message, err error)

+ func SendAsync(ctx context.Context, to PID, message proto.Message) error

+ func SendSync(ctx context.Context, to PID, message proto.Message, timeout time.Duration) (response proto.Message, err error)

+ type Actor interface

+ PostStop func(ctx context.Context) error

+ PreStart func(ctx context.Context) error

+ Receive func(ctx ReceiveContext)

+ type ActorSystem interface

+ Actors func() []PID

+ Host func() string

+ Name func() string

+ NodeAddr func() string

+ NumActors func() uint64

+ Port func() int

+ RestartActor func(ctx context.Context, name string) (PID, error)

+ Start func(ctx context.Context) error

+ StartActor func(ctx context.Context, name string, actor Actor) PID

+ Stop func(ctx context.Context) error

+ StopActor func(ctx context.Context, name string) error

+ func NewActorSystem(config *Config) (ActorSystem, error)

+ type Behavior func(ctx ReceiveContext)

+ type BehaviorStack []Behavior

+ func NewBehaviorStack() BehaviorStack

+ func (b *BehaviorStack) Clear()

+ func (b *BehaviorStack) IsEmpty() bool

+ func (b *BehaviorStack) Len() int

+ func (b *BehaviorStack) Peek() (behavior Behavior, ok bool)

+ func (b *BehaviorStack) Pop() (behavior Behavior, ok bool)

+ func (b *BehaviorStack) Push(behavior Behavior)

+ type Config struct

+ func NewConfig(name, nodeHostAndPort string, options ...Option) (*Config, error)

+ func (c Config) ActorInitMaxRetries() int

+ func (c Config) ExpireActorAfter() time.Duration

+ func (c Config) HostAndPort() (host string, port int)

+ func (c Config) Logger() log.Logger

+ func (c Config) Name() string

+ func (c Config) NodeHostAndPort() string

+ func (c Config) ReplyTimeout() time.Duration

+ type LocalAddress struct

+ func NewLocalAddress(protocol string, system string, host string, port int) *LocalAddress

+ func (a *LocalAddress) Host() string

+ func (a *LocalAddress) HostPort() string

+ func (a *LocalAddress) Parse(address string) *LocalAddress

+ func (a *LocalAddress) Port() int

+ func (a *LocalAddress) Protocol() string

+ func (a *LocalAddress) String() string

+ func (a *LocalAddress) System() string

+ func (a *LocalAddress) WithHost(host string) *LocalAddress

+ func (a *LocalAddress) WithPort(port int) *LocalAddress

+ func (a *LocalAddress) WithProtocol(protocol string) *LocalAddress

+ func (a *LocalAddress) WithSystem(system string) *LocalAddress

+ type Option interface

+ Apply func(config *Config)

+ func WithActorInitMaxRetries(max int) Option

+ func WithExpireActorAfter(duration time.Duration) Option

+ func WithLogger(logger log.Logger) Option

+ func WithPassivationDisabled() Option

+ func WithRemoting() Option

+ func WithReplyTimeout(timeout time.Duration) Option

+ func WithSupervisorStrategy(strategy StrategyDirective) Option

+ func WithTelemetry(telemetry *telemetry.Telemetry) Option

+ type OptionFunc func(*Config)

+ func (f OptionFunc) Apply(c *Config)

+ type PID interface

+ ActorPath func() *Path

+ ActorSystem func() ActorSystem

+ Ask func(ctx context.Context, to PID, message proto.Message) (response proto.Message, err error)

+ Children func(ctx context.Context) []PID

+ ErrorsCount func(ctx context.Context) uint64

+ IsOnline func() bool

+ MailboxSize func(ctx context.Context) uint64

+ ReceivedCount func(ctx context.Context) uint64

+ RemoteAsk func(ctx context.Context, to *pb.Address, message proto.Message) (response proto.Message, err error)

+ RemoteLookup func(ctx context.Context, host string, port int, name string) (addr *pb.Address, err error)

+ RemoteTell func(ctx context.Context, to *pb.Address, message proto.Message) error

+ Restart func(ctx context.Context) error

+ RestartCount func(ctx context.Context) uint64

+ Shutdown func(ctx context.Context) error

+ SpawnChild func(ctx context.Context, name string, actor Actor) (PID, error)

+ Tell func(ctx context.Context, to PID, message proto.Message) error

+ UnWatch func(pid PID)

+ Watch func(pid PID)

+ var NoSender PID

+ type Path struct

+ func NewPath(name string, address *LocalAddress) *Path

+ func (a *Path) ID() uuid.UUID

+ func (a *Path) LocalAddress() *LocalAddress

+ func (a *Path) Name() string

+ func (a *Path) Parent() *Path

+ func (a *Path) RemoteAddress() *pb.Address

+ func (a *Path) String() string

+ func (a *Path) WithParent(parent *Path) *Path

+ type ReceiveContext interface

+ Become func(behavior Behavior)

+ BecomeStacked func(behavior Behavior)

+ Context func() context.Context

+ Message func() proto.Message

+ Response func(resp proto.Message)

+ Self func() PID

+ Sender func() PID

+ UnBecome func()

+ UnBecomeStacked func()

+ type Reflection interface

+ ActorFrom func(name string) (actor Actor, err error)

+ ActorOf func(rtype reflect.Type) (actor Actor, err error)

+ func NewReflection(loader TypesLoader) Reflection

+ type StrategyDirective int

+ const RestartDirective

+ const StopDirective

+ type TypesLoader interface

+ Parent func() TypesLoader

+ Register func(name string, v any)

+ Type func(v any) (reflect.Type, bool)

+ TypeByName func(name string) (reflect.Type, bool)

+ func NewTypesLoader(parent TypesLoader) TypesLoader

+ type Unit struct