example_test.go

package oplogc_test

import (
	"log"

	"github.com/dailymotion/oplogc"
)

func Example() {
	myOplogURL := "http://oplog.mydomain.com"
	c := oplogc.Subscribe(myOplogURL, oplogc.Options{})

	ops, errs, done := c.Start()

	for {
		select {
		case op := <-ops:
			// Got the next operation
			switch op.Event {
			case "reset":
				// reset the data store
			case "live":
				// put the service back in production
			default:
				// Do something with the operation
				//url := fmt.Sprintf("http://api.domain.com/%s/%s", op.Data.Type, op.Data.ID)
				//data := MyAPIGetter(url)
				//MyDataSyncer(data)
			}

			// Ack the fact you handled the operation
			op.Done()
		case err := <-errs:
			switch err {
			case oplogc.ErrAccessDenied, oplogc.ErrWritingState:
				c.Stop()
				log.Fatal(err)
			case oplogc.ErrResumeFailed:
				log.Print("Resume failed, forcing full replication")
				c.SetLastID("0")
			default:
				log.Print(err)
			}
		case <-done:
			return
		}
	}
}