core

package
v0.0.0-...-6fa9711 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 11, 2021 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DHCPPacketFactory

type DHCPPacketFactory struct {
	Config DHCPConfig
}

func (*DHCPPacketFactory) Decline

func (f *DHCPPacketFactory) Decline(ack DHCPPacket) (*DHCPPacket, TxId)

func (*DHCPPacketFactory) Discover

func (f *DHCPPacketFactory) Discover() (*DHCPPacket, TxId)

func (*DHCPPacketFactory) RequestForOffer

func (f *DHCPPacketFactory) RequestForOffer(offer DHCPPacket) (*DHCPPacket, TxId)

func (*DHCPPacketFactory) RequestForRebind

func (f *DHCPPacketFactory) RequestForRebind(lease DHCPLease) (*DHCPPacket, TxId)

func (*DHCPPacketFactory) RequestForReboot

func (f *DHCPPacketFactory) RequestForReboot(lease DHCPLease) (*DHCPPacket, TxId)

func (*DHCPPacketFactory) RequestForRenew

func (f *DHCPPacketFactory) RequestForRenew(lease DHCPLease) (*DHCPPacket, TxId)

type ProcessingEngine

type ProcessingEngine struct {
	Client *UdpClient
	Config configuration.DHCPConfig
	Lease  DHCPLease
	// contains filtered or unexported fields
}

func NewProcessingEngine

func NewProcessingEngine(initProps ProcessingEngineInitProps) *ProcessingEngine

func (*ProcessingEngine) AddLeaseReceivedListener

func (p *ProcessingEngine) AddLeaseReceivedListener(listener func(lease DHCPLease))

func (*ProcessingEngine) AddLeaseRenewedListener

func (p *ProcessingEngine) AddLeaseRenewedListener(listener func(lease DHCPLease))

func (*ProcessingEngine) Discover

func (p *ProcessingEngine) Discover()

func (*ProcessingEngine) FinalizeOffer

func (p *ProcessingEngine) FinalizeOffer(ack *packet.DHCPPacket, requestTime time.Time) error

func (*ProcessingEngine) GetLease

func (p *ProcessingEngine) GetLease() DHCPLease

func (*ProcessingEngine) ProcessOffers

func (p *ProcessingEngine) ProcessOffers(offers lists.List) error

func (*ProcessingEngine) RebindLease

func (p *ProcessingEngine) RebindLease() (State, bool)

func (*ProcessingEngine) RenewAfterReboot

func (p *ProcessingEngine) RenewAfterReboot()

func (*ProcessingEngine) RenewLease

func (p *ProcessingEngine) RenewLease() (State, bool)

func (*ProcessingEngine) RenewOrRebindLease

func (p *ProcessingEngine) RenewOrRebindLease()

func (*ProcessingEngine) Start

func (p *ProcessingEngine) Start() error

func (*ProcessingEngine) Stop

func (p *ProcessingEngine) Stop()

func (*ProcessingEngine) UpdateState

func (p *ProcessingEngine) UpdateState(newState State)

func (*ProcessingEngine) WaitForEvent

func (p *ProcessingEngine) WaitForEvent(tx transaction.TxId, timeout time.Duration) (packet.DHCPPacket, error)

func (*ProcessingEngine) WaitForEventUntil

func (p *ProcessingEngine) WaitForEventUntil(tx transaction.TxId, timeout time.Time) (packet.DHCPPacket, error)

type ProcessingEngineInitProps

type ProcessingEngineInitProps struct {
	Client *UdpClient
	Config *configuration.DHCPConfig
	Lease  *DHCPLease
}

type UdpClient

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

func (*UdpClient) Listen

func (c *UdpClient) Listen() error

func (*UdpClient) Send

func (c *UdpClient) Send(packet DHCPPacket, addr net.IP) error

func (*UdpClient) Stop

func (c *UdpClient) Stop()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL