Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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.
Click to show internal directories.
Click to hide internal directories.