Versions in this module Expand all Collapse all v0 v0.1.0 Jan 18, 2020 Changes in this version + type Provider struct + func (Provider) Open(attrs map[string]interface{}) (jobworker.Connector, error) + type SQLTemplateForPostgres struct + func (SQLTemplateForPostgres) NewAddQueueAttributeDML(queueName, queueRawName string, ...) (string, []interface{}) + func (SQLTemplateForPostgres) NewCreateQueueAttributeDDL() string + func (SQLTemplateForPostgres) NewCreateQueueDDL(queueRawName string) string + func (SQLTemplateForPostgres) NewDeleteJobDML(queueRawName, jobID string) (stmt string, args []interface{}) + func (SQLTemplateForPostgres) NewEnqueueJobDML(queueRawName, jobID, class, args string, deduplicationID, groupID *string, ...) (string, []interface{}) + func (SQLTemplateForPostgres) NewEnqueueJobWithTimeDML(queueRawName, jobID, class, args string, deduplicationID, groupID *string, ...) (string, []interface{}) + func (SQLTemplateForPostgres) NewFindJobDML(queueRawName string, jobID string) (string, []interface{}) + func (SQLTemplateForPostgres) NewFindJobsDML(queueRawName string, limit int64) (stmt string, args []interface{}) + func (SQLTemplateForPostgres) NewFindQueueAttributeDML(queueName string) (stmt string, args []interface{}) + func (SQLTemplateForPostgres) NewHideJobDML(queueRawName string, jobID string, ...) (stmt string, args []interface{}) + func (SQLTemplateForPostgres) NewUpdateJobByVisibilityTimeoutDML(queueRawName string, jobID string, visibilityTimeout int64) (stmt string, args []interface{}) + func (SQLTemplateForPostgres) NewUpdateQueueAttributeDML(...) (string, []interface{})