Versions in this module Expand all Collapse all v1 v1.0.0 Jul 14, 2026 Changes in this version + var ErrStopped = errors.New("stopped while a handler was running") + type Event struct + AccountSeq *int + Channel string + Origin string + Payload []byte + ServerTime int64 + Source string + Symbol string + Type string + type Options struct + API *ops.API + APIKeyID string + AccountSeqs []int + CredsErr string + DBPath string + Init string + Inline bool + KeyManager *keys.Manager + KeyName string + Log *slog.Logger + MaxConcurrency int + NoFsync bool + Now func() int64 + On string + ServerNow func() int64 + SignalCtx context.Context + Sleep func(time.Duration) + Stateful bool + Stderr io.Writer + Surface string + Where string + type Runtime struct + func New(opts Options) (*Runtime, error) + func (r *Runtime) Close() + func (r *Runtime) Fatal() <-chan error + func (r *Runtime) Ingest(ev stream.Event) + func (r *Runtime) Match(ev Event) (bool, error) + func (r *Runtime) RunHandler(ev Event) error + func (r *Runtime) WatchInterrupt(ctx context.Context)
Go to main page