machine

Nov 8, 2020

Changes in this version

type Machine

+ func (m *Machine) PubSub() pubsub.PubSub

Oct 21, 2020

Changes in this version

type Opt

+ func WithClosers(closers ...func()) Opt

Oct 21, 2020

Changes in this version

type Routine

+ SubscribeFilter func(channel string, filter func(msg interface{}) bool, ...) error

Oct 21, 2020

Changes in this version

type Routine

+ PublishN func(channel string, obj interface{}, n int) error

+ SubscribeN func(channel string, n int, handler func(msg interface{})) error

+ SubscribeUntil func(channel string, decider func() bool, handler func(msg interface{})) error

+ SubscribeWhile func(channel string, decider func() bool, handler func(msg interface{})) error

Oct 19, 2020

Changes in this version

type Machine

+ func (m *Machine) Graph() graph.Graph

type Opt

+ func WithGraph(graph graph.Graph) Opt

Oct 18, 2020

Changes in this version

type Cache

+ Clear func(namespace string)

Oct 18, 2020

Changes in this version

type Cache

+ Map func(namespace string) Map

+ Namespaces func() []string

+ SetAll func(namespace string, m Map)

type Map

+ func (m Map) Union(other Map) Map

Oct 18, 2020

Changes in this version

type Cache

+ Copy func(namespace string) Map

+ Exists func(namespace string, key interface{}) bool

+ Filter func(namespace string, filter func(k, v interface{}) bool) Map

+ Intersection func(namespace1, namespace2 string) Map

+ Raw func(namespace string) Map

+ Union func(namespace1, namespace2 string) Map

+ type Map map[interface{}]interface

+ func (m Map) Copy() Map

+ func (m Map) Del(k interface{})

+ func (m Map) Exists(key interface{}) bool

+ func (m Map) Filter(filter func(k, v interface{}) bool) Map

+ func (m Map) Get(k interface{}) (interface{}, bool)

+ func (m Map) Intersection(k interface{}) (interface{}, bool)

+ func (m Map) Marshal() ([]byte, error)

+ func (m Map) Range(iterator func(k, v interface{}) bool)

+ func (m Map) Set(k, v interface{})

Oct 17, 2020

Changes in this version

type Routine

+ TraceLog func(message string)

Oct 16, 2020

Changes in this version

type Opt

+ func WithProfiling(w io.Writer) Opt

Oct 16, 2020

Changes in this version

type Cache

+ Delete func(namespace string, key interface{})

+ Len func(namespace string) int

Oct 15, 2020

Changes in this version

type GoOpt

+ func GoWithDeadline(deadline time.Time) GoOpt

type Machine

+ func (m *Machine) CancelRoutine(id string)

+ func (m *Machine) HasRoutine(id string) bool

+ func (m *Machine) ID() string

type Middleware

+ func While(deciderFunc func(routine Routine) bool) Middleware

type Opt

+ func WithDeadline(deadline time.Time) Opt

+ func WithID(id string) Opt

+ func WithValue(key, val interface{}) Opt

type Stats

+ Children []*Stats

+ Deadline *time.Time

+ ID string

+ Timeout *time.Duration

+ TotalMiddlewares int

Oct 14, 2020

Changes in this version

type GoOpt

+ func GoWithValues(data map[interface{}]interface{}) GoOpt

type Opt

+ func WithValues(data map[interface{}]interface{}) Opt

Oct 13, 2020

Changes in this version

+ const DefaultMaxRoutines

Oct 12, 2020

Changes in this version

type Machine

+ func (p *Machine) Tags() []string

type Middleware

+ func PanicRecover() Middleware

type Stats

+ Tags []string

Oct 12, 2020

Changes in this version

type GoOpt

+ func GoWithMiddlewares(middlewares ...Middleware) GoOpt

+ func GoWithPID(id int) GoOpt

+ func GoWithTags(tags ...string) GoOpt

+ func GoWithTimeout(to time.Duration) GoOpt

type Machine

+ func (m *Machine) Parent() *Machine

+ func (m *Machine) Sub(opts ...Opt) *Machine

+ func (p *Machine) Active() int

type Opt

+ func WithChildren(children ...*Machine) Opt

+ func WithParent(parent *Machine) Opt

type Stats

+ ActiveRoutines int

+ HasParent bool

+ TotalChildren int

+ TotalRoutines int

Oct 10, 2020

Changes in this version

type Cache

+ Close func() error

type Machine

+ func (m *Machine) Close() error

type Opt

+ func WithPubSub(pubsub PubSub) Opt

+ type PubSub interface

+ Close func() error

+ Publish func(channel string, obj interface{}) error

+ Subscribe func(ctx context.Context, channel string, handler func(obj interface{})) error

Oct 10, 2020

Changes in this version

type Middleware

+ func After(afterFunc func(routine Routine)) Middleware

+ func Before(beforeFunc func(routine Routine)) Middleware

+ func Decider(deciderFunc func(routine Routine) bool) Middleware

Oct 10, 2020

Changes in this version

type Func

+ func Every(ticker *time.Ticker, fn Func) Func

+ func HourOfDay(hourOfDay int, fn Func) Func

Oct 10, 2020

Changes in this version

+ var ErrNoExist = errors.New("machine: does not exit")

+ type Cache interface

+ Del func(key string) error

+ Get func(key string) (interface{}, error)

+ Range func(fn func(k string, val interface{}) bool) error

+ Set func(key string, val interface{}) error

+ type Func func(routine Routine)

+ type GoOpt func(o *goOpts)

+ func WithMiddlewares(middlewares ...Middleware) GoOpt

+ func WithPID(id int) GoOpt

+ func WithTags(tags ...string) GoOpt

+ func WithTimeout(to time.Duration) GoOpt

+ type Machine struct

+ func New(ctx context.Context, options ...Opt) *Machine

+ func (m *Machine) Cache() Cache

+ func (m *Machine) Go(fn Func, opts ...GoOpt)

+ func (m *Machine) Stats() Stats

+ func (m *Machine) Wait()

+ func (p *Machine) Cancel()

+ func (p *Machine) Current() int

+ func (p *Machine) Total() int

+ type Middleware func(fn Func) Func

+ func Cron(ticker *time.Ticker) Middleware

+ type Opt func(o *option)

+ func WithCache(cache Cache) Opt

+ func WithMaxRoutines(max int) Opt

+ func WithSubscribeChannelBuffer(length int) Opt

+ type Routine interface

+ Cancel func()

+ Context func() context.Context

+ Duration func() time.Duration

+ Machine func() *Machine

+ PID func() int

+ Publish func(channel string, obj interface{})

+ Start func() time.Time

+ Subscribe func(channel string, handler func(obj interface{}))

+ Tags func() []string

+ type RoutineStats struct

+ Duration time.Duration

+ PID int

+ Start time.Time

+ Tags []string

+ type Stats struct

+ Count int

+ Routines []RoutineStats

+ func (s Stats) String() string