jobs

Documentation

Index

• type BlockWatcher
  • func (w *BlockWatcher) Execute(ctx context.Context, args any) (any, error)
  • func (BlockWatcher) RegistryKey() string
• type DbWriter
  • func (w *DbWriter) Execute(ctx context.Context, args any) (any, error)
  • func (DbWriter) RegistryKey() string
• type Listener
  • func (w *Listener) Execute(ctx context.Context, args any) (any, error)
  • func (w *Listener) RegistryKey() string
• type Poller
  • func (w *Poller) Execute(ctx context.Context, args any) (any, error)
  • func (w *Poller) IntervalTime(_ context.Context) time.Duration
  • func (Poller) RegistryKey() string

Types

type BlockWatcher

type BlockWatcher struct{}

Listener is a simple job that logs the current block when it is run.

func (*BlockWatcher) Execute

func (w *BlockWatcher) Execute(ctx context.Context, args any) (any, error)

Execute implements job.Basic.

func (BlockWatcher) RegistryKey

func (BlockWatcher) RegistryKey() string

type DbWriter

type DbWriter struct{}

Listener is a simple job that logs the current block when it is run.

func (*DbWriter) Execute

func (w *DbWriter) Execute(ctx context.Context, args any) (any, error)

Execute implements job.Basic.

func (DbWriter) RegistryKey

func (DbWriter) RegistryKey() string

type Listener

type Listener struct{}

Listener is a simple job that logs the current block when it is run.

func (*Listener) Execute

func (w *Listener) Execute(ctx context.Context, args any) (any, error)

Execute implements job.Basic.

func (*Listener) RegistryKey

func (w *Listener) RegistryKey() string

type Poller

type Poller struct {
	Interval time.Duration
}

Listener is a simple job that logs the current block when it is run.

func (*Poller) Execute

func (w *Poller) Execute(ctx context.Context, args any) (any, error)

Execute implements job.Basic.

func (*Poller) IntervalTime

func (w *Poller) IntervalTime(_ context.Context) time.Duration

func (Poller) RegistryKey

func (Poller) RegistryKey() string