registry

Documentation

Index

• Constants
• Variables
• func MigrateTo(ctx context.Context, openedDevices []OpenedRegistryDevice, concurrency int, ...) (errs error)
• type CustomEventType
• type MigrateToHooks
• type OpenDevicesHooks
• type OpenedRegistryDevice
  • func OpenDevices(devices []RegistryDevice, hooks OpenDevicesHooks) ([]OpenedRegistryDevice, []func() error, error)
• type RegistryDevice

Constants

const (
	EventCustomAllDevicesSent    = CustomEventType(0)
	EventCustomTransferAuthority = CustomEventType(1)
)

Variables

var (
	ErrCouldNotGetInputDeviceStatistics   = errors.New("could not get input device statistics")
	ErrCouldNotCreateNewDevice            = errors.New("could not create new device")
	ErrCouldNotSendDeviceInfo             = errors.New("could not send device info")
	ErrCouldNotSendEvent                  = errors.New("could not send event")
	ErrCouldNotMigrate                    = errors.New("could not migrate")
	ErrCouldNotContinueWithMigration      = errors.New("could not continue with migration")
	ErrCouldNotHandleProtocol             = errors.New("could not handle protocol")
	ErrCouldNotHandleNeedAt               = errors.New("could not handle NeedAt")
	ErrCouldNotHandleDontNeedAt           = errors.New("could not handle DontNeedAt")
	ErrCouldNotCreateMigrator             = errors.New("could not create migrator")
	ErrCouldNotWaitForMigrationCompletion = errors.New("could not wait for migration completion")
)

Functions

func MigrateTo

func MigrateTo(
	ctx context.Context,

	openedDevices []OpenedRegistryDevice,
	concurrency int,

	readers []io.Reader,
	writers []io.Writer,

	hooks MigrateToHooks,
) (errs error)

Types

type CustomEventType

type CustomEventType byte

type MigrateToHooks

type MigrateToHooks struct {
	OnDeviceSent               func(deviceID uint32)
	OnDeviceAuthoritySent      func(deviceID uint32)
	OnDeviceMigrationProgress  func(deviceID uint32, ready int, total int)
	OnDeviceMigrationCompleted func(deviceID uint32)

	OnAllDevicesSent         func()
	OnAllMigrationsCompleted func()
}

type OpenDevicesHooks

type OpenDevicesHooks struct {
	OnDeviceOpened func(deviceID uint32, name string)
}

type OpenedRegistryDevice

type OpenedRegistryDevice struct {
	RegistryDevice RegistryDevice
	// contains filtered or unexported fields
}

func OpenDevices

func OpenDevices(
	devices []RegistryDevice,

	hooks OpenDevicesHooks,
) ([]OpenedRegistryDevice, []func() error, error)

type RegistryDevice

type RegistryDevice struct {
	Name      string `json:"name"`
	Input     string `json:"input"`
	BlockSize uint32 `json:"blockSize"`
}