governor

Sep 9, 2022

Changes in this version

type Option

+ func WithoutLeavingOnCompletion() Option

Jul 22, 2021

Changes in this version

+ const DefaultInterval

+ func StreamName(governor string) string

+ type Backoff interface

+ Duration func(n int) time.Duration

+ type Finisher func() error

+ type Governor interface

+ Start func(ctx context.Context, name string) (fin Finisher, seq uint64, err error)

+ func NewJSGovernor(name string, mgr *jsm.Manager, opts ...Option) Governor

+ type Logger interface

+ Debugf func(format string, a ...interface{})

+ Errorf func(format string, a ...interface{})

+ Infof func(format string, a ...interface{})

+ Warnf func(format string, a ...interface{})

+ type Manager interface

+ Active func() (uint64, error)

+ Evict func(entry uint64) (name string, err error)

+ LastActive func() (time.Time, error)

+ Limit func() int64

+ MaxAge func() time.Duration

+ Name func() string

+ Replicas func() int

+ Reset func() error

+ SetLimit func(uint64) error

+ SetMaxAge func(time.Duration) error

+ SetSubject func(subj string) error

+ Stream func() *jsm.Stream

+ Subject func() string

+ func NewJSGovernorManager(name string, limit uint64, maxAge time.Duration, replicas uint, ...) (Manager, error)

+ type Option func(mgr *jsGMgr)

+ func WithBackoff(p Backoff) Option

+ func WithInterval(i time.Duration) Option

+ func WithLogger(log Logger) Option

+ func WithSubject(s string) Option