background

Documentation

Overview

Simple skeleton for background processes

Example

package main

import (
	"fmt"
	"time"

	"github.com/bitmark-inc/bitmarkd/background"
)

type theState struct {
	count int
}

func main() {

	proc := &theState{
		count: 10,
	}

	// list of background processes to start
	processes := background.Processes{
		proc,
	}

	p := background.Start(processes, nil)
	time.Sleep(time.Second)
	p.Stop()
}

func (state *theState) Run(args interface{}, shutdown <-chan struct{}) {

	fmt.Printf("initialise\n")

loop:
	for {
		select {
		case <-shutdown:
			break loop
		default:
		}

		state.count += 1
		time.Sleep(time.Millisecond)
	}

	fmt.Printf("finalise\n")
}

Index

• type Process
• type Processes
• type T
  • func Start(processes Processes, args interface{}) *T
  • func (t *T) Stop()

Examples

• Package

Types

type Process

type Process interface {
	Run(args interface{}, shutdown <-chan struct{})
}

type signature for background process and type that implements this Run is a process

type Processes

type Processes []Process

list of processes to start

type T

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

handle type for the stop

func Start

func Start(processes Processes, args interface{}) *T

start up a set of background processes all with the same arg value

func (*T) Stop

func (t *T) Stop()

stop a set of background processes