strand

Documentation

Index

• Variables
• func Strand(logger *logging.Logger, c chan Request, name string, f func() error, ...) error
• type Request

Variables

var (
	// Debug enables debug logging
	Debug = false
)

Functions

func Strand

func Strand(logger *logging.Logger, c chan Request, name string, f func() error, quit chan struct{}, quitErr error) error

Strand linearizes concurrent method calls through a single channel, to avoid concurrency issues when conflicting methods are called from multiple goroutines. Methods passed to Strand() will block until completed. Strand accepts a quit channel and will return quitErr if the quit channel closes.

Types

type Request

type Request struct {
	Name string
	Func func() error
}

Request is sent to the channel provided to Strand