pgnotifier

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 6, 2022 License: AGPL-3.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source
const (
	WaitingState   = "waiting"
	ExecutingState = "executing"
	SucceededState = "succeeded"
	FailedState    = "failed"
	AbortedState   = "aborted"
)

Variables

This section is empty.

Functions

func CheckForPGNotifierEnvVars added in v0.1.10

func CheckForPGNotifierEnvVars() bool

CheckForPGNotifierEnvVars Checks if all the required Env Variables for PG Notifier are present

func GetCurrentSQLTimestamp

func GetCurrentSQLTimestamp() string

GetCurrentSQLTimestamp to get sql complaint current datetime string

func GetPGNotifierConnectionString added in v0.1.10

func GetPGNotifierConnectionString() string

GetPGNotifierConnectionString Returns PG Notifier DB Connection Configuration

func GetSQLTimestamp

func GetSQLTimestamp(t time.Time) string

GetSQLTimestamp to get sql complaint current datetime string from the given duration

func Init added in v0.1.10

func Init()

Types

type ClaimResponseT

type ClaimResponseT struct {
	Payload json.RawMessage
	Err     error
}

type ClaimT

type ClaimT struct {
	ID        int64
	BatchID   string
	Status    string
	Workspace string
	Payload   json.RawMessage
	Attempt   int
}

type JobPayload added in v0.1.10

type JobPayload json.RawMessage

type PgNotifierT

type PgNotifierT struct {
	URI string
	// contains filtered or unexported fields
}

func New

func New(workspaceIdentifier, fallbackConnectionInfo string) (notifier PgNotifierT, err error)

New Given default connection info return pg notifiew object from it

func (PgNotifierT) ClearJobs added in v0.1.10

func (notifier PgNotifierT) ClearJobs(ctx context.Context) (err error)

func (PgNotifierT) GetDBHandle added in v0.1.10

func (notifier PgNotifierT) GetDBHandle() *sql.DB

func (*PgNotifierT) Publish

func (notifier *PgNotifierT) Publish(jobs []JobPayload, priority int) (ch chan []ResponseT, err error)

func (*PgNotifierT) RunMaintenanceWorker added in v0.1.10

func (notifier *PgNotifierT) RunMaintenanceWorker(ctx context.Context) error

RunMaintenanceWorker (blocking - to be called from go routine) retriggers zombie jobs which were left behind by dead workers in executing state

func (*PgNotifierT) Subscribe

func (notifier *PgNotifierT) Subscribe(ctx context.Context, workerId string, jobsBufferSize int) chan ClaimT

func (*PgNotifierT) UpdateClaimedEvent added in v0.1.10

func (notifier *PgNotifierT) UpdateClaimedEvent(claim *ClaimT, response *ClaimResponseT)

type ResponseT

type ResponseT struct {
	JobID  int64
	Status string
	Output json.RawMessage
	Error  string
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL