runtime

type FunctionRetry ¶ added in v0.5.1

type FunctionRetry struct {
	Ticker *time.Ticker
	// contains filtered or unexported fields
}

ResettableFunctionTicker will reset the user state as soon as tick is delivered.

func NewRetryTicker(ctx context.Context, name string, option ...FunctionRetryOption) *FunctionRetry

func (t *FunctionRetry) Do(f func(), cancel_f func(), deadline_f func())

type FunctionRetryOption ¶ added in v0.5.1

type FunctionRetryOption func(*FunctionRetry)

func WithRetryDuration(d time.Duration) FunctionRetryOption

type ResettableFunctionTicker ¶ added in v0.5.1

type ResettableFunctionTicker struct {
	Ticker    *time.Ticker
	ResetChan chan struct{} // channel used to reset the ticker

	Started bool
	// contains filtered or unexported fields
}

ResettableFunctionTicker will reset the user state as soon as tick is delivered.

func GetTicker(name string, option ...ResettableFunctionTickerOption) *ResettableFunctionTicker

func NewResettableFunctionTicker(name string, option ...ResettableFunctionTickerOption) *ResettableFunctionTicker

func (t *ResettableFunctionTicker) Do(f func())

type ResettableFunctionTickerOption ¶ added in v0.5.1

type ResettableFunctionTickerOption func(*ResettableFunctionTicker)

func WithDuration(d time.Duration) ResettableFunctionTickerOption