gg_promise

Documentation

Index

• Variables
• func WaitFileExists(filename string, waitFor time.Duration) (exists bool, err error)
• type ActionMethod
• type ActionReturnType
• type Delegator
  • func NewDelegator() (instance *Delegator)
  • func (instance *Delegator) Register(funcName string, f FnSolve)
  • func (instance *Delegator) Run(funcName string, args ...interface{}) (response interface{}, err error)
  • func (instance *Delegator) RunTimed(funcName string, execTimeout time.Duration, args ...interface{}) (response interface{}, err error)
• type FnSolve
• type TimeoutAction
  • func NewTimeout[T ActionReturnType](timeout time.Duration) *TimeoutAction[T]
  • func (instance *TimeoutAction[T]) IsPaused() bool
  • func (instance *TimeoutAction[T]) IsRunning() bool
  • func (instance *TimeoutAction[T]) Pause()
  • func (instance *TimeoutAction[T]) Resume()
  • func (instance *TimeoutAction[T]) Run(method ActionMethod[T], args ...interface{}) (response T, err error)
  • func (instance *TimeoutAction[T]) Stop()

Variables

var (
	SystemError  = errors.New("system_error")
	TimeOutError = errors.New("timeout_error")
)

Functions

func WaitFileExists

func WaitFileExists(filename string, waitFor time.Duration) (exists bool, err error)

Types

type ActionMethod

type ActionMethod[T ActionReturnType] func(args ...interface{}) (response T, err error)

type ActionReturnType

type ActionReturnType interface {
	interface{}
}

type Delegator

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

func NewDelegator

func NewDelegator() (instance *Delegator)

func (*Delegator) Register

func (instance *Delegator) Register(funcName string, f FnSolve)

Register add a function

func (*Delegator) Run

func (instance *Delegator) Run(funcName string, args ...interface{}) (response interface{}, err error)

Run execute a function

func (*Delegator) RunTimed

func (instance *Delegator) RunTimed(funcName string, execTimeout time.Duration, args ...interface{}) (response interface{}, err error)

type FnSolve

type FnSolve func(args ...interface{}) (response interface{}, err error)

type TimeoutAction

type TimeoutAction[T ActionReturnType] struct {
	// contains filtered or unexported fields
}

func NewTimeout

func NewTimeout[T ActionReturnType](timeout time.Duration) *TimeoutAction[T]

func (*TimeoutAction[T]) IsPaused

func (instance *TimeoutAction[T]) IsPaused() bool

func (*TimeoutAction[T]) IsRunning

func (instance *TimeoutAction[T]) IsRunning() bool

func (*TimeoutAction[T]) Pause

func (instance *TimeoutAction[T]) Pause()

func (*TimeoutAction[T]) Resume

func (instance *TimeoutAction[T]) Resume()

func (*TimeoutAction[T]) Run

func (instance *TimeoutAction[T]) Run(method ActionMethod[T], args ...interface{}) (response T, err error)

func (*TimeoutAction[T]) Stop

func (instance *TimeoutAction[T]) Stop()

Stop ... stops the task