schema_forwarder

Documentation

Index

• type Forwarder
  • func NewAbortingForwarder(terminalErrFn func(error), schemaDB jobsdb.JobsDB, log logger.Logger, ...) Forwarder
  • func NewForwarder(terminalErrFn func(error), schemaDB jobsdb.JobsDB, client *pulsar.Client, ...) Forwarder

Types

type Forwarder

type Forwarder interface {
	Start() error
	Stop()
}

func NewAbortingForwarder

func NewAbortingForwarder(terminalErrFn func(error), schemaDB jobsdb.JobsDB, log logger.Logger, conf *config.Config, stat stats.Stats) Forwarder

NewAbortingForwarder creates a new aborting forwarder that marks jobs as aborted without trying to forward them

func NewForwarder

func NewForwarder(terminalErrFn func(error), schemaDB jobsdb.JobsDB, client *pulsar.Client, backendConfig backendConfig.BackendConfig, log logger.Logger, conf *config.Config, stat stats.Stats) Forwarder

NewJobsForwarder creates a new jobs forwarder that transforms and forwards jobs to pulsar