topologytransmogrifier

package
v0.0.0-...-53b40aa Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 22, 2018 License: AGPL-3.0, AGPL-3.0-only Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Task 

type Task interface {
	Tick() (bool, error)
	TargetConfig() *configuration.Configuration
	TargetVerClock() types.VerClock
	Abandon()
}

type TopologyTransmogrifier 

type TopologyTransmogrifier struct {
	*actor.Mailbox
	*actor.BasicServerOuter
	// contains filtered or unexported fields
}

func NewTopologyTransmogrifier 

func NewTopologyTransmogrifier(self common.RMId, db *db.Databases, router *router.Router, cm connectionmanager.ConnectionManager, lc *localconnection.LocalConnection, listenPort uint16, ss actor.ShutdownableActor, config *configuration.Configuration, logger log.Logger) (*TopologyTransmogrifier, <-chan struct{})

func (*TopologyTransmogrifier) ConnectedRMs 

func (tt *TopologyTransmogrifier) ConnectedRMs(conns map[common.RMId]sconn.ServerConnection)

func (*TopologyTransmogrifier) ConnectionEstablished 

func (tt *TopologyTransmogrifier) ConnectionEstablished(conn sconn.ServerConnection, conns map[common.RMId]sconn.ServerConnection, done func())

func (*TopologyTransmogrifier) ConnectionLost 

func (tt *TopologyTransmogrifier) ConnectionLost(rmId common.RMId, conns map[common.RMId]sconn.ServerConnection)

func (*TopologyTransmogrifier) EnsureTopologyVerClock 

func (tt *TopologyTransmogrifier) EnsureTopologyVerClock(sender common.RMId, vc types.VerClock)

func (*TopologyTransmogrifier) ImmigrationCompleteReceived 

func (tt *TopologyTransmogrifier) ImmigrationCompleteReceived(sender common.RMId, migrationComplete msgs.MigrationComplete)

func (*TopologyTransmogrifier) ImmigrationReceived 

func (tt *TopologyTransmogrifier) ImmigrationReceived(sender common.RMId, migration msgs.Migration)

func (*TopologyTransmogrifier) RequestConfigurationChange 

func (tt *TopologyTransmogrifier) RequestConfigurationChange(sender common.RMId, config *configuration.Configuration)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.