pgnotifier

package

v0.0.0-...-0ade494 Latest Latest Go to latest Published: Aug 26, 2022 License: AGPL-3.0 Imports: 18 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/serviceexchange/server

Documentation ¶

Index ¶

Constants
func CheckForPGNotifierEnvVars() bool
func GetCurrentSQLTimestamp() string
func GetPGNotifierConnectionString() string
func Init()
type ClaimResponseT
type ClaimT
type JobPayload
type PgNotifierT
- func New(workspaceIdentifier, fallbackConnectionInfo string) (notifier PgNotifierT, err error)
type ResponseT

Constants ¶

View Source

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

Variables ¶

This section is empty.

Functions ¶

func CheckForPGNotifierEnvVars ¶

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 ¶

func GetPGNotifierConnectionString() string

GetPGNotifierConnectionString Returns PG Notifier DB Connection Configuration

func Init ¶

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 ¶

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 ¶

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

func (PgNotifierT) GetDBHandle ¶

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

func (*PgNotifierT) Publish ¶

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

func (*PgNotifierT) RunMaintenanceWorker ¶

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 (notifier *PgNotifierT) Subscribe(ctx context.Context, workerId string, jobsBufferSize int) chan ClaimT

func (*PgNotifierT) UpdateClaimedEvent ¶

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

type ResponseT ¶

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

Source Files ¶

View all Source files

pgnotifier.go

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