pgnotifier

Documentation

Index

• Constants
• func CheckForPGNotifierEnvVars() bool
• func GetCurrentSQLTimestamp() string
• func GetPGNotifierConnectionString() string
• func GetSQLTimestamp(t time.Time) string
• type ClaimResponseT
• type ClaimT
• type MessageT
• type NotificationT
• type PgNotifierT
  • func New(workspaceIdentifier string, fallbackConnectionInfo string) (notifier PgNotifierT, err error)
  • func (notifier PgNotifierT) AddTopic(topic string) (err error)
  • func (notifier *PgNotifierT) Claim(workerID string) (claim ClaimT, claimed bool)
  • func (notifier PgNotifierT) GetDBHandle() *sql.DB
  • func (notifier *PgNotifierT) Publish(topic string, messages []MessageT, priority int) (ch chan []ResponseT, err error)
  • func (notifier *PgNotifierT) Subscribe(topic string, channelSize int) (ch chan NotificationT, err error)
• type ResponseT

Constants

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

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 GetSQLTimestamp

func GetSQLTimestamp(t time.Time) string

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

Types

type ClaimResponseT

type ClaimResponseT struct {
	Payload json.RawMessage
	Err     error
}

type ClaimT

type ClaimT struct {
	ID                int64
	BatchID           string
	Status            string
	Payload           json.RawMessage
	ClaimResponseChan chan ClaimResponseT
}

type MessageT

type MessageT struct {
	Payload json.RawMessage
}

type NotificationT

type NotificationT struct {
	ID      int64
	BatchID string `json:"batch_id"`
	Status  string
}

type PgNotifierT

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

func New

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

New Given default connection info return pg notifiew object from it

func (PgNotifierT) AddTopic

func (notifier PgNotifierT) AddTopic(topic string) (err error)

func (*PgNotifierT) Claim

func (notifier *PgNotifierT) Claim(workerID string) (claim ClaimT, claimed bool)

func (PgNotifierT) GetDBHandle

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

func (*PgNotifierT) Publish

func (notifier *PgNotifierT) Publish(topic string, messages []MessageT, priority int) (ch chan []ResponseT, err error)

func (*PgNotifierT) Subscribe

func (notifier *PgNotifierT) Subscribe(topic string, channelSize int) (ch chan NotificationT, err error)

type ResponseT

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