internal

Documentation

Index

• type ActorPlacement
  • func NewActorPlacement(serverAddr []string, clientCert *daprCredentials.CertChain, ...) *ActorPlacement
  • func (p *ActorPlacement) AddHostedActorType(actorType string) error
  • func (p *ActorPlacement) LookupActor(actorType, actorID string) (string, string)
  • func (p *ActorPlacement) Start()
  • func (p *ActorPlacement) Stop()
  • func (p *ActorPlacement) WaitUntilPlacementTableIsReady(ctx context.Context) error

Types

type ActorPlacement

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

ActorPlacement maintains membership of actor instances and consistent hash tables to discover the actor while interacting with Placement service.

func NewActorPlacement

func NewActorPlacement(
	serverAddr []string, clientCert *daprCredentials.CertChain,
	appID, runtimeHostName string, actorTypes []string,
	appHealthFn func() bool,
	afterTableUpdateFn func(),
) *ActorPlacement

NewActorPlacement initializes ActorPlacement for the actor service.

func (*ActorPlacement) AddHostedActorType

func (p *ActorPlacement) AddHostedActorType(actorType string) error

Register an actor type by adding it to the list of known actor types (if it's not already registered) The placement tables will get updated when the next heartbeat fires

func (*ActorPlacement) LookupActor

func (p *ActorPlacement) LookupActor(actorType, actorID string) (string, string)

LookupActor resolves to actor service instance address using consistent hashing table.

func (*ActorPlacement) Start

func (p *ActorPlacement) Start()

Start connects placement service to register to membership and send heartbeat to report the current member status periodically.

func (*ActorPlacement) Stop

func (p *ActorPlacement) Stop()

Stop shuts down server stream gracefully.

func (*ActorPlacement) WaitUntilPlacementTableIsReady

func (p *ActorPlacement) WaitUntilPlacementTableIsReady(ctx context.Context) error

WaitUntilPlacementTableIsReady waits until placement table is until table lock is unlocked.