slavedriver

Documentation

Index

• type Slave
  • func (slave *Slave) Destroy()
  • func (slave *Slave) GetClient() *srpc.Client
  • func (slave *Slave) Release()
  • func (slave *Slave) String() string
• type SlaveDriver
  • func NewSlaveDriver(options SlaveDriverOptions, slaveTrader SlaveTrader, logger log.DebugLogger) (*SlaveDriver, error)
  • func (driver *SlaveDriver) GetSlave() (*Slave, error)
  • func (driver *SlaveDriver) WriteHtml(writer io.Writer)
• type SlaveDriverOptions
• type SlaveInfo
• type SlaveTrader

Types

type Slave

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

func (*Slave) Destroy

func (slave *Slave) Destroy()

func (*Slave) GetClient

func (slave *Slave) GetClient() *srpc.Client

func (*Slave) Release

func (slave *Slave) Release()

func (*Slave) String

func (slave *Slave) String() string

type SlaveDriver

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

func NewSlaveDriver

func NewSlaveDriver(options SlaveDriverOptions, slaveTrader SlaveTrader,
	logger log.DebugLogger) (*SlaveDriver, error)

func (*SlaveDriver) GetSlave

func (driver *SlaveDriver) GetSlave() (*Slave, error)

func (*SlaveDriver) WriteHtml

func (driver *SlaveDriver) WriteHtml(writer io.Writer)

type SlaveDriverOptions

type SlaveDriverOptions struct {
	DatabaseFilename  string
	MaximumIdleSlaves uint
	MinimumIdleSlaves uint
	PortNumber        uint
	Purpose           string
}

type SlaveInfo

type SlaveInfo struct {
	Identifier string
	IpAddress  net.IP
}

type SlaveTrader

type SlaveTrader interface {
	Close() error
	CreateSlave() (SlaveInfo, error)
	DestroySlave(identifier string) error
}