promise

package

v0.0.0-...-b044761 Latest Latest Go to latest Published: Dec 31, 2022 License: MIT Imports: 4 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/changkun/pkg

Links

Open Source Insights

Documentation ¶

Index ¶

func All(ff ...func()) (err error)
func Run(ff ...func() error) (err error)
type Attempt
- func (a *Attempt) HasNext() bool
- func (a *Attempt) Next() bool
type AttemptStrategy
- func (s AttemptStrategy) Start() *Attempt
type WaitGroup
- func NewWaitGroup() *WaitGroup

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func All ¶

func All(ff ...func()) (err error)

All a list of function to be executed

func Run ¶

func Run(ff ...func() error) (err error)

Run check and run ff return error if one return error

Types ¶

type Attempt ¶

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

Attempt defines a struct that contains attempt strategy

func (*Attempt) HasNext ¶

func (a *Attempt) HasNext() bool

HasNext returns whether another attempt will be made if the current one fails. If it returns true, the following call to Next is guaranteed to return true.

func (*Attempt) Next ¶

func (a *Attempt) Next() bool

Next waits until it is time to perform the next attempt or returns false if it is time to stop trying.

type AttemptStrategy ¶

type AttemptStrategy struct {
	Total time.Duration // total duration of attempt.
	Delay time.Duration // interval between each try in the burst.
	Min   int           // minimum number of retries; overrides Total
}

AttemptStrategy represents a strategy for waiting for an action to complete successfully. This is an internal type used by the implementation of other packages.

func (AttemptStrategy) Start ¶

func (s AttemptStrategy) Start() *Attempt

Start begins a new sequence of attempts for the given strategy.

type WaitGroup ¶

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

WaitGroup wrapper

func NewWaitGroup ¶

func NewWaitGroup() *WaitGroup

NewWaitGroup creates a new WaitGroup of sync.WaitGroup

func (*WaitGroup) Add ¶

func (wg *WaitGroup) Add(fs ...func())

Add given functions

func (*WaitGroup) Wait ¶

func (wg *WaitGroup) Wait()

Wait until group is done

func (*WaitGroup) WaitUntilTimeout ¶

func (wg *WaitGroup) WaitUntilTimeout(timeout time.Duration) bool

WaitUntilTimeout waits for the waitgroup for the specified max timeout. Returns true if waiting timed out. Note that function added to waitgroup is still running without cancellation.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL