partition

Documentation

Index

• Constants
• func New() cluster.IdentityLookup
• func SetLogLevel(level log.Level)
• 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) PidOfIdentityActor(addr string) *actor.PID
  • func (pm *Manager) Start()
  • func (pm *Manager) Stop()

Constants

const (
	ActorNameIdentity  = "partition"
	ActorNamePlacement = "partition-activator"
)

Functions

func New

func New() cluster.IdentityLookup

func SetLogLevel

func SetLogLevel(level log.Level)

SetLogLevel sets the log level for the logger.

SetLogLevel is safe to call concurrently

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

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

func (*Manager) Start

func (pm *Manager) Start()

func (*Manager) Stop

func (pm *Manager) Stop()