migrationproxy

Documentation

Index

• Constants
• func ConstructProxyKey(id string, port int) string
• func GetMigrationPortsList(isBlockMigration bool) (ports []int)
• func NewSourceProxy(unixSocketPath string, tcpTargetAddress string) *migrationProxy
• func NewTargetProxy(tcpBindAddress string, tcpBindPort int, libvirtdSocketPath string) *migrationProxy
• func SourceUnixFile(virtShareDir string, key string) string
• type ProxyManager
  • func NewMigrationProxyManager(virtShareDir string) ProxyManager

Constants

const (
	LibvirtDirectMigrationPort = 49152
	LibvirtBlockMigrationPort  = 49153
)

Functions

func ConstructProxyKey

func ConstructProxyKey(id string, port int) string

func GetMigrationPortsList

func GetMigrationPortsList(isBlockMigration bool) (ports []int)

func NewSourceProxy

func NewSourceProxy(unixSocketPath string, tcpTargetAddress string) *migrationProxy

Source proxy exposes a unix socket server and pipes to an outbound TCP connection.

func NewTargetProxy

func NewTargetProxy(tcpBindAddress string, tcpBindPort int, libvirtdSocketPath string) *migrationProxy

Target proxy listens on a tcp socket and pipes to a libvirtd unix socket

func SourceUnixFile

func SourceUnixFile(virtShareDir string, key string) string

Types

type ProxyManager

type ProxyManager interface {
	StartTargetListener(key string, targetUnixFiles []string) error
	GetTargetListenerPorts(key string) map[int]int
	StopTargetListener(key string)

	StartSourceListener(key string, targetAddress string, destSrcPortMap map[int]int) error
	GetSourceListenerFiles(key string) []string
	StopSourceListener(key string)
}

func NewMigrationProxyManager

func NewMigrationProxyManager(virtShareDir string) ProxyManager