funnel

Mar 27, 2023

Changes in this version

type Option

+ func WithShouldCachePredicate(p func(interface{}, error) bool) Option

Mar 19, 2020

Changes in this version

+ type Config struct

+ type Funnel struct

+ func New(option ...Option) *Funnel

+ func (f *Funnel) Execute(operationId string, opExeFunc func() (interface{}, error)) (res interface{}, err error)

+ func (f *Funnel) ExecuteAndCopyResult(operationId string, opExeFunc func() (interface{}, error)) (res interface{}, err error)

+ func (f *Funnel) IsOpInProgress(operationId string) bool

+ type Option func(*Config)

+ func WithCacheTtl(cTtl time.Duration) Option

+ func WithTimeout(t time.Duration) Option