rt

Jan 14, 2022

Changes in this version

type Reactr

+ func (r *Reactr) ListenAndRun(pod *grav.Pod, msgType string, run func(grav.Message, interface{}, error))

Nov 17, 2021

Changes in this version

type Capabilities

+ Database rcap.DatabaseCapability

+ RequestConfig *rcap.RequestHandlerConfig

type Ctx

+ func (c *Ctx) AddVar(name, value string)

+ func (c *Ctx) HasFFIResult() bool

+ func (c *Ctx) SetFFIResult(result []byte, err error) (*FFIResult, error)

+ func (c *Ctx) UseFFIResult() (*FFIResult, error)

+ func (c *Ctx) UseVars() ([]FFIVariable, error)

+ type FFIResult struct

+ Err error

+ Result []byte

+ func (r *FFIResult) FFISize() int32

+ type FFIVariable struct

+ Name string

+ Value interface{}

Sep 3, 2021

Changes in this version

type ChangeEvent

+ const ChangeTypeStop

type Option

+ func Autoscale(max int) Option

type Reactr

+ func (r *Reactr) DeRegister(jobType string) error

+ func (r *Reactr) Metrics() ScalerMetrics

+ type ScalerMetrics struct

+ TotalJobCount int

+ TotalThreadCount int

+ Workers map[string]WorkerMetrics

+ type WorkerMetrics struct

+ JobCount int

+ JobRate float64

+ TargetThreadCount int

+ ThreadCount int

Aug 12, 2021

Changes in this version

type Capabilities

+ func CapabilitiesFromConfig(config rcap.CapabilityConfig) Capabilities

+ func DefaultCapabilities(logger *vlog.Logger) Capabilities

+ func (c Capabilities) Config() rcap.CapabilityConfig

type Reactr

+ func NewWithConfig(config rcap.CapabilityConfig) *Reactr

Jul 29, 2021

Changes in this version

+ var ErrCapabilityNotAvailable = errors.New("capability not available")

+ type Capabilities struct

+ Auth rcap.AuthProvider

+ Cache rcap.Cache

+ FileSource rcap.FileSource

+ GraphQLClient rcap.GraphQLClient

+ HTTPClient rcap.HTTPClient

+ LoggerSource rcap.LoggerSource

+ RequestHandler *rcap.RequestHandler

type Ctx

+ func (c *Ctx) UseRequest(req *request.CoordinatedRequest)

type Job

+ func (j Job) Req() *request.CoordinatedRequest

type Reactr

+ func (r *Reactr) DefaultCaps() Capabilities

+ func (r *Reactr) DoWithCaps(job Job, caps Capabilities) *Result

+ func (r *Reactr) RegisterWithCaps(jobType string, runner Runnable, caps Capabilities, options ...Option)

Jun 15, 2021

Changes in this version

type Job

+ func (j Job) UUID() string

type Reactr

+ func (h *Reactr) Register(jobType string, runner Runnable, options ...Option) JobFunc

+ func (r *Reactr) IsRegistered(jobType string) bool

Mar 10, 2021

Changes in this version

+ const MsgTypeReactrRunErr

+ type RunErr struct

+ Code int

+ Message string

+ func (r RunErr) Error() string

+ func (r RunErr) ToVKErr() vk.Error

Feb 24, 2021

Changes in this version

type Reactr

+ func (h *Reactr) Schedule(s Schedule)

+ type Schedule interface

+ Check func() *Job

+ Done func() bool

+ func After(seconds int, jobFunc func() Job) Schedule

+ func Every(seconds int, jobFunc func() Job) Schedule

Feb 8, 2021

Changes in this version

+ const MsgTypeReactrJobErr

+ const MsgTypeReactrNilResult

+ const MsgTypeReactrResult

+ var ErrCacheKeyNotFound = errors.New("key not found")

+ var ErrJobNotFound = errors.New("job not found in storage")

+ var ErrJobTimeout = errors.New("job timeout")

+ type Cache interface

+ Delete func(key string) error

+ Get func(key string) ([]byte, error)

+ Set func(key string, val []byte, ttl int) error

+ type ChangeEvent int

+ const ChangeTypeStart

+ type Ctx struct

+ Cache Cache

+ func (c *Ctx) Do(job Job) *Result

+ type DoFunc func(Job) *Result

+ type Group struct

+ func NewGroup() *Group

+ func (g *Group) Add(result *Result)

+ func (g *Group) Wait() error

+ type Job struct

+ func NewJob(jobType string, data interface{}) Job

+ func (j Job) Bytes() []byte

+ func (j Job) Data() interface{}

+ func (j Job) Int() int

+ func (j Job) Reference() JobReference

+ func (j Job) String() string

+ func (j Job) Unmarshal(target interface{}) error

+ type JobFunc func(interface{}) *Result

+ type JobReference struct

+ func (j JobReference) UUID() string

+ type MemoryStorage struct

+ func (m *MemoryStorage) Add(job Job) error

+ func (m *MemoryStorage) AddResult(uuid string, data interface{}, err error) error

+ func (m *MemoryStorage) Get(uuid string) (Job, error)

+ func (m *MemoryStorage) Remove(uuid string) error

+ type Option func(workerOpts) workerOpts

+ func MaxRetries(count int) Option

+ func PoolSize(size int) Option

+ func PreWarm() Option

+ func RetrySeconds(secs int) Option

+ func TimeoutSeconds(timeout int) Option

+ type Reactr struct

+ func New() *Reactr

+ func (h *Reactr) Do(job Job) *Result

+ func (h *Reactr) Handle(jobType string, runner Runnable, options ...Option) JobFunc

+ func (h *Reactr) HandleMsg(pod *grav.Pod, msgType string, runner Runnable, options ...Option)

+ func (h *Reactr) Job(jobType string, data interface{}) Job

+ func (h *Reactr) Listen(pod *grav.Pod, msgType string)

+ type Result struct

+ func (r *Result) Discard()

+ func (r *Result) Then() (interface{}, error)

+ func (r *Result) ThenDo(do ResultFunc)

+ func (r *Result) ThenInt() (int, error)

+ func (r *Result) ThenJSON(out interface{}) error

+ func (r *Result) UUID() string

+ type ResultFunc func(interface{}, error)

+ type Runnable interface

+ OnChange func(ChangeEvent) error

+ Run func(Job, *Ctx) (interface{}, error)

+ type Storage interface

+ Add func(Job) error

+ AddResult func(string, interface{}, error) error

+ Get func(string) (Job, error)

+ Remove func(string) error