smallstack

Documentation

Index

• type SlaveTrader
  • func NewSlaveTrader(createRequest hyper_proto.CreateVmRequest, logger log.DebugLogger) (*SlaveTrader, error)
  • func NewSlaveTraderWithOptions(options SlaveTraderOptions, logger log.DebugLogger) (*SlaveTrader, error)
  • func (trader *SlaveTrader) Close() error
  • func (trader *SlaveTrader) CreateSlave() (slavedriver.SlaveInfo, error)
  • func (trader *SlaveTrader) CreateSlaveWithAcknowledger(acknowledgeChannel <-chan chan<- error) (slavedriver.SlaveInfo, error)
  • func (trader *SlaveTrader) DestroySlave(identifier string) error
• type SlaveTraderOptions

Types

type SlaveTrader

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

func NewSlaveTrader

func NewSlaveTrader(createRequest hyper_proto.CreateVmRequest,
	logger log.DebugLogger) (*SlaveTrader, error)

func NewSlaveTraderWithOptions

func NewSlaveTraderWithOptions(options SlaveTraderOptions,
	logger log.DebugLogger) (*SlaveTrader, error)

func (*SlaveTrader) Close

func (trader *SlaveTrader) Close() error

func (*SlaveTrader) CreateSlave

func (trader *SlaveTrader) CreateSlave() (slavedriver.SlaveInfo, error)

func (*SlaveTrader) CreateSlaveWithAcknowledger

func (trader *SlaveTrader) CreateSlaveWithAcknowledger(
	acknowledgeChannel <-chan chan<- error) (slavedriver.SlaveInfo, error)

func (*SlaveTrader) DestroySlave

func (trader *SlaveTrader) DestroySlave(identifier string) error

type SlaveTraderOptions

type SlaveTraderOptions struct {
	CreateRequest     hyper_proto.CreateVmRequest
	CreateTimeout     time.Duration // Default: 5 minutes.
	DestroyTimeout    time.Duration // Default: 1 minute.
	HypervisorAddress string        // Default: local Hypervisor.
}