internal

Documentation

Index

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

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) 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()

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