example_appupdate_test.go

package fargo_test

// MIT Licensed (see README.md) - Copyright (c) 2013 Hudl <@Hudl>

import (
	"fmt"
	"time"

	"github.com/billnote/fargo"
)

func ExampleEurekaConnection_ScheduleAppUpdates() {
	e := makeConnection()
	done := make(chan struct{})
	time.AfterFunc(2*time.Minute, func() {
		close(done)
	})
	name := "my_app"
	fmt.Printf("Monitoring application %q.\n", name)
	for update := range e.ScheduleAppUpdates(name, true, done) {
		if update.Err != nil {
			fmt.Printf("Most recent request for application %q failed: %v\n", name, update.Err)
			continue
		}
		fmt.Printf("Application %q has %d instances.\n", name, len(update.App.Instances))
	}
	fmt.Printf("Done monitoring application %q.\n", name)
}

func ExampleEurekaConnection_ScheduleAppInstanceUpdates() {
	e := makeConnection()
	done := make(chan struct{})
	time.AfterFunc(2*time.Minute, func() {
		close(done)
	})
	name := "my_app"
	updates, err := e.ScheduleAppInstanceUpdates(name, true, done, fargo.ThatAreUp, fargo.Shuffled)
	if err != nil {
		fmt.Println(err)
		return
	}
	fmt.Printf("Monitoring instances of application %q.\n", name)
	for update := range updates {
		if update.Err != nil {
			fmt.Printf("Most recent request for application %q failed: %v\n", name, update.Err)
			continue
		}
		fmt.Printf("Application %q has %d instances available.\n", name, len(update.Instances))
	}
	fmt.Printf("Done monitoring instances of application %q.\n", name)
}

func ExampleAppSource_Latest() {
	e := makeConnection()
	name := "my_app"
	source := e.NewAppSource(name, false)
	defer source.Stop()
	time.Sleep(30 * time.Second)
	if app := source.Latest(); app != nil {
		fmt.Printf("Application %q has %d instances.\n", name, len(app.Instances))
	}
	time.Sleep(time.Minute)
	if app := source.Latest(); app == nil {
		fmt.Printf("No application named %q is available.\n", name)
	}
}

func ExampleAppSource_CopyLatestTo() {
	e := makeConnection()
	name := "my_app"
	source := e.NewAppSource(name, true)
	defer source.Stop()
	var app fargo.Application
	if !source.CopyLatestTo(&app) {
		fmt.Printf("No application named %q is available.\n", name)
	}
	time.Sleep(time.Minute)
	if source.CopyLatestTo(&app) {
		fmt.Printf("Application %q has %d instances.\n", name, len(app.Instances))
	}
}