sync

Documentation

Index

• type IPAddressPoller
  • func NewIPAddressPoller(pollInterval time.Duration) *IPAddressPoller
  • func (p *IPAddressPoller) Channel() <-chan string
  • func (i *IPAddressPoller) Run(stopCh <-chan struct{}) error
• type Record
• type Syncer
  • func NewSyncer(records []Record, pollInterval, apiTimeout time.Duration) *Syncer
  • func (s *Syncer) Run(stopCh <-chan struct{}) error
  • func (s *Syncer) UpdateRecord(dnsName, dnsType string, ttl int64, data []string) error

Types

type IPAddressPoller

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

IPAddressPoller is a poller used to check the value of the current public internet IP address.

func NewIPAddressPoller

func NewIPAddressPoller(pollInterval time.Duration) *IPAddressPoller

func (*IPAddressPoller) Channel

func (p *IPAddressPoller) Channel() <-chan string

Channel() returns a channel that receives data whenever an IP address value is received.

func (*IPAddressPoller) Run

func (i *IPAddressPoller) Run(stopCh <-chan struct{}) error

Run() starts the main loop for the poller.

type Record

type Record struct {
	Record  backend.DNSRecord
	Backend backend.DNSBackend
}

type Syncer

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

func NewSyncer

func NewSyncer(records []Record, pollInterval, apiTimeout time.Duration) *Syncer

func (*Syncer) Run

func (s *Syncer) Run(stopCh <-chan struct{}) error

Run() starts the sync and poll loops

func (*Syncer) UpdateRecord

func (s *Syncer) UpdateRecord(dnsName, dnsType string, ttl int64, data []string) error

UpdateRecord() updates a managed record so that it can be synced by the sync loop.