etcdresolver.go

/*
 * (C) Copyright 2014 Nuxeo SA (http://nuxeo.com/) and contributors.
 *
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Apache License Version 2.0
 * which accompanies this distribution, and is available at
 * http://www.apache.org/licenses/
 *
 * See the Apache Licence for more details.
 *
 * Contributors:
 *     nuxeo.io Team
 */

package main

import "time"

const (
	SERVICE_DOMAINTYTPE = "service"
	URI_DOMAINTYPE      = "uri"
	TIME_FORMAT         = "2006-01-02 15:04:05"
)

type Service struct {
	index      string
	nodeKey    string
	domain     string
	name       string
	status     *Status
	lastAccess *time.Time
}

type EtcdResolver struct {
	config     *Config
	watcher    *watcher
	watchIndex uint64
	etcdcron   *EtcdCron
}

func NewEtcdResolver(config *Config) (*EtcdResolver, error) {
	watcher, error := NewEtcdWatcher(config)
	if error != nil {
		return nil, error
	}
	etcdcron, error := NewEtcdCron(config)
	if error != nil {
		return nil, error
	}
	return &EtcdResolver{config, watcher, 0, etcdcron}, nil
}

func (resolver *EtcdResolver) init() {
	go resolver.etcdcron.init()
	resolver.watcher.init()
}