whiz

README

whiz

Documentation

Index

• func ErrorCeiling(t time.Duration) func(*Worker) error
• func ExternalPolling() func(*Worker) error
• func LockName(s string) func(*Worker) error
• func PollingInterval(t time.Duration) func(*Worker) error
• func ReadOnlyDatabase(dbRO *sql.DB) func(*Worker) error
• type ErrorWithCause
• type SubscriberEvents
  • func (se SubscriberEvents) Len() int
  • func (se SubscriberEvents) Less(i, j int) bool
  • func (se SubscriberEvents) Swap(i, j int)
• type Worker
  • func NewWorker(dbRW *sql.DB, reg subscribers.Registry, loggeroutput io.Writer, ...) (*Worker, error)
  • func (w *Worker) PollNow()
  • func (w *Worker) ReProcessSubscriberEvent(eventid string, timeout int)
  • func (w *Worker) Shutdown()
  • func (w *Worker) StartPolling()
  • func (w Worker) Status() WorkerStatus
• type WorkerStatus

Functions

func ErrorCeiling

func ErrorCeiling(t time.Duration) func(*Worker) error

func ExternalPolling

func ExternalPolling() func(*Worker) error

func LockName

func LockName(s string) func(*Worker) error

func PollingInterval

func PollingInterval(t time.Duration) func(*Worker) error

func ReadOnlyDatabase

func ReadOnlyDatabase(dbRO *sql.DB) func(*Worker) error

option for providing a read replica

Types

type ErrorWithCause

type ErrorWithCause interface {
	error
	Cause() error
}

type SubscriberEvents

type SubscriberEvents []models.Eventz

func (SubscriberEvents) Len

func (se SubscriberEvents) Len() int

func (SubscriberEvents) Less

func (se SubscriberEvents) Less(i, j int) bool

func (SubscriberEvents) Swap

func (se SubscriberEvents) Swap(i, j int)

type Worker

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

func NewWorker

func NewWorker(dbRW *sql.DB, reg subscribers.Registry, loggeroutput io.Writer, options ...func(*Worker) error) (*Worker, error)

func (*Worker) PollNow

func (w *Worker) PollNow()

func (*Worker) ReProcessSubscriberEvent

func (w *Worker) ReProcessSubscriberEvent(eventid string, timeout int)

func (*Worker) Shutdown

func (w *Worker) Shutdown()

func (*Worker) StartPolling

func (w *Worker) StartPolling()

func (Worker) Status

func (w Worker) Status() WorkerStatus

type WorkerStatus

type WorkerStatus struct {
	Started         time.Time
	PollingInterval time.Duration
	LastPolled      time.Time
	LastRun         time.Time
	DBRW            string
	DBRO            string
}