loop

README

Usage

Looper executes the provided function once in while and collects any errors.

Example

package main 

import (
	"github.com/donutloop/toolkit/looper"
	"log"
)


func main() {
	l := loop.NewLooper(1*time.Millisecond, func() error {
		// do things
		return nil
	})

	for err := range l.Error() {
		log.Println(err)
	}
	
	// stop call is missing
}

Documentation

Index

• type Looper
  • func NewLooper(rate time.Duration, event func() error) *Looper
  • func (l *Looper) Error() <-chan error
  • func (l *Looper) Stop()
• type RecoverError
  • func (e *RecoverError) Error() string

Examples

• Looper

Types

type Looper

type Looper struct {
	// contains filtered or unexported fields
}

Example

package main

import (
	"fmt"
	"time"

	"github.com/donutloop/toolkit/loop"
)

func main() {
	loop.NewLooper(1*time.Second, func() error {
		// do after one second things
		return nil
	})

	// error and stop handling is missing for simplicity

	fmt.Println("successfully")
}

Output:

successfully

func NewLooper

func NewLooper(rate time.Duration, event func() error) *Looper

func (*Looper) Error

func (l *Looper) Error() <-chan error

func (*Looper) Stop

func (l *Looper) Stop()

type RecoverError

type RecoverError struct {
	Err   interface{}
	Stack []byte
}

func (*RecoverError) Error

func (e *RecoverError) Error() string