type GoRoutineMap …
func NewGoRoutineMap(exponentialBackOffOnError bool) GoRoutineMap { … }
type goRoutineMap …
type operation …
func (grm *goRoutineMap) Run(
operationName string,
operationFunc func() error) error { … }
func (grm *goRoutineMap) operationComplete(
operationName string, err *error) { … }
func (grm *goRoutineMap) IsOperationPending(operationName string) bool { … }
func (grm *goRoutineMap) Wait() { … }
func (grm *goRoutineMap) WaitForCompletion() { … }
func (grm *goRoutineMap) nothingPending() bool { … }
func NewAlreadyExistsError(operationName string) error { … }
func IsAlreadyExists(err error) bool { … }
type alreadyExistsError …
var _ …
func (err alreadyExistsError) Error() string { … }