disthash

Documentation

Index

• Constants
• func New() cluster.IdentityLookup
• type GrainMeta
• type IdentityLookup
  • func (p *IdentityLookup) Get(clusterIdentity *cluster.ClusterIdentity) *actor.PID
  • func (p *IdentityLookup) RemovePid(clusterIdentity *cluster.ClusterIdentity, pid *actor.PID)
  • func (p *IdentityLookup) Setup(cluster *cluster.Cluster, kinds []string, isClient bool)
  • func (p *IdentityLookup) Shutdown()
• type Manager
  • func (pm *Manager) Get(identity *clustering.ClusterIdentity) *actor.PID
  • func (pm *Manager) PidOfActivatorActor(addr string) *actor.PID
  • func (pm *Manager) Start()
  • func (pm *Manager) Stop()

Constants

const (
	PartitionActivatorActorName = "partition-activator"
)

Functions

func New

func New() cluster.IdentityLookup

Types

type GrainMeta

type GrainMeta struct {
	ID  *clustering.ClusterIdentity
	PID *actor.PID
}

type IdentityLookup

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

func (*IdentityLookup) Get

func (p *IdentityLookup) Get(clusterIdentity *cluster.ClusterIdentity) *actor.PID

func (*IdentityLookup) RemovePid

func (p *IdentityLookup) RemovePid(clusterIdentity *cluster.ClusterIdentity, pid *actor.PID)

func (*IdentityLookup) Setup

func (p *IdentityLookup) Setup(cluster *cluster.Cluster, kinds []string, isClient bool)

func (*IdentityLookup) Shutdown

func (p *IdentityLookup) Shutdown()

type Manager

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

func (*Manager) Get

func (pm *Manager) Get(identity *clustering.ClusterIdentity) *actor.PID

func (*Manager) PidOfActivatorActor

func (pm *Manager) PidOfActivatorActor(addr string) *actor.PID

func (*Manager) Start

func (pm *Manager) Start()

func (*Manager) Stop

func (pm *Manager) Stop()