llmongodb/consul.go

package main

import (
	"fmt"
	"log"
	"time"

	"github.com/hashicorp/consul/api"
)

// Consul client structure
type Consul struct {
	RedisTTL  time.Duration
	Timeout   time.Duration
	MaxError  int
	Influxdb  string
	Month     string
	Retention float64
	MongoURI  string
	Database  string
	RedisURI  string
	Client    *api.Client
}

// NewClient New consul client
func NewClient() *Consul {
	client, err := api.NewClient(api.DefaultConfig())
	if err != nil {
		log.Fatalf("Consul error: %+v\n", err)
		if opts.Debug {
			fmt.Printf("Consul error: %+v\n", err)
		}
	}

	consul := &Consul{
		Client:   client,
		RedisTTL: opts.RedisTTL,
		Timeout:  opts.Timeout,
		MaxError: opts.MaxError,
		Influxdb: opts.Influxdb,
	}

	return consul
}