slavedriver

Documentation

Index

• type Slave
  • func (slave *Slave) Destroy()
  • func (slave *Slave) GetClient() *srpc.Client
  • func (slave *Slave) GetClientAddress() string
  • 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) GetSlaveWithTimeout(timeout time.Duration) (*Slave, error)
  • func (driver *SlaveDriver) ReplaceIdle(immediateGetNew bool)
  • func (driver *SlaveDriver) WriteHtml(writer io.Writer)
• type SlaveDriverOptions
• type SlaveInfo
  • func (si SlaveInfo) String() string
• type SlaveTrader
• type SlaveTraderAcknowledger

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) GetClientAddress

func (slave *Slave) GetClientAddress() string

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) GetSlaveWithTimeout

func (driver *SlaveDriver) GetSlaveWithTimeout(timeout time.Duration) (
	*Slave, error)

func (*SlaveDriver) ReplaceIdle

func (driver *SlaveDriver) ReplaceIdle(immediateGetNew bool)

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
}

func (SlaveInfo) String

func (si SlaveInfo) String() string

type SlaveTrader

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

type SlaveTraderAcknowledger

type SlaveTraderAcknowledger interface {
	CreateSlaveWithAcknowledger(<-chan chan<- error) (SlaveInfo, error)
}