clusterdns

Documentation

Index

• type ClusterDNS
  • func New(domain string, rr rrstore.RRWriter, cl ClusterDriver) *ClusterDNS
  • func (c *ClusterDNS) StartRefreshing(interval, timeout time.Duration, cancel <-chan struct{}) (<-chan error, <-chan struct{})
  • func (c *ClusterDNS) SyncRecords() error
• type ClusterDriver

Types

type ClusterDNS

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

ClusterDNS keeps the DNS records in sync with Cluster state.

func New

func New(domain string, rr rrstore.RRWriter, cl ClusterDriver) *ClusterDNS

func (*ClusterDNS) StartRefreshing

func (c *ClusterDNS) StartRefreshing(interval, timeout time.Duration, cancel <-chan struct{}) (<-chan error, <-chan struct{})

func (*ClusterDNS) SyncRecords

func (c *ClusterDNS) SyncRecords() error

SyncRecords syncs the DNS records in the RR table with the cluster by querying the cluster and updating the RR table.

type ClusterDriver

type ClusterDriver interface {
	// Tasks gives the active tasks in the cluster which may or may not be
	// eligible for load balancing due to various reasons such as  having no
	// ports exposed or invalid characters in service/domain names.
	Tasks() (task.ClusterState, error)
}

ClusterDriver describes a distributed task execution environment.