local

Documentation

Index

• type LocalRunner
  • func NewLocalRunner() *LocalRunner
  • func (r *LocalRunner) DeleteLoop(namespacedName types.NamespacedName) error
  • func (r *LocalRunner) Has(namespacedName types.NamespacedName) (bool, error)
  • func (r *LocalRunner) LoopsCount() int
  • func (r *LocalRunner) NamespaceCount() int
  • func (r *LocalRunner) UpsertLoop(loop *v1.Loop) error
• type Script
  • func NewScript() *Script
  • func (script *Script) Exec(ctx context.Context) (*warp10.Response, error)
  • func (script *Script) SetEvery(d time.Duration)
  • func (script *Script) SetObject(o *loops.Loop)
  • func (script *Script) Start()
  • func (script *Script) Stop()

Types

type LocalRunner

type LocalRunner struct {
	// contains filtered or unexported fields
}

func NewLocalRunner

func NewLocalRunner() *LocalRunner

func (*LocalRunner) DeleteLoop

func (r *LocalRunner) DeleteLoop(namespacedName types.NamespacedName) error

func (*LocalRunner) Has

func (r *LocalRunner) Has(namespacedName types.NamespacedName) (bool, error)

func (*LocalRunner) LoopsCount

func (r *LocalRunner) LoopsCount() int

func (*LocalRunner) NamespaceCount

func (r *LocalRunner) NamespaceCount() int

func (*LocalRunner) UpsertLoop

func (r *LocalRunner) UpsertLoop(loop *v1.Loop) error

type Script

type Script struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewScript

func NewScript() *Script

func (*Script) Exec

func (script *Script) Exec(ctx context.Context) (*warp10.Response, error)

Exec execute the given script

func (*Script) SetEvery

func (script *Script) SetEvery(d time.Duration)

func (*Script) SetObject

func (script *Script) SetObject(o *loops.Loop)

func (*Script) Start

func (script *Script) Start()

func (*Script) Stop

func (script *Script) Stop()