pq

Documentation

Index

• type Provider
  • func (Provider) Open(attrs map[string]interface{}) (jobworker.Connector, error)
• type SQLTemplateForPostgres
  • 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{})

Types

type Provider

type Provider struct {
}

func (Provider) Open

func (Provider) Open(attrs map[string]interface{}) (jobworker.Connector, error)

type SQLTemplateForPostgres

type SQLTemplateForPostgres struct {
}

func (SQLTemplateForPostgres) NewAddQueueAttributeDML

func (SQLTemplateForPostgres) NewAddQueueAttributeDML(queueName, queueRawName string, delaySeconds, maximumMessageSize, messageRetentionPeriod int64, deadLetterTarget string, maxReceiveCount, visibilityTimeout int64) (string, []interface{})

func (SQLTemplateForPostgres) NewCreateQueueAttributeDDL

func (SQLTemplateForPostgres) NewCreateQueueAttributeDDL() string

func (SQLTemplateForPostgres) NewCreateQueueDDL

func (SQLTemplateForPostgres) NewCreateQueueDDL(queueRawName string) string

func (SQLTemplateForPostgres) NewDeleteJobDML

func (SQLTemplateForPostgres) NewDeleteJobDML(queueRawName, jobID string) (stmt string, args []interface{})

func (SQLTemplateForPostgres) NewEnqueueJobDML

func (SQLTemplateForPostgres) NewEnqueueJobDML(queueRawName, jobID, class, args string, deduplicationID, groupID *string, delaySeconds int64) (string, []interface{})

func (SQLTemplateForPostgres) NewEnqueueJobWithTimeDML

func (SQLTemplateForPostgres) NewEnqueueJobWithTimeDML(queueRawName, jobID, class, args string, deduplicationID, groupID *string, enqueueAt int64) (string, []interface{})

func (SQLTemplateForPostgres) NewFindJobDML

func (SQLTemplateForPostgres) NewFindJobDML(queueRawName string, jobID string) (string, []interface{})

func (SQLTemplateForPostgres) NewFindJobsDML

func (SQLTemplateForPostgres) NewFindJobsDML(queueRawName string, limit int64) (stmt string, args []interface{})

func (SQLTemplateForPostgres) NewFindQueueAttributeDML

func (SQLTemplateForPostgres) NewFindQueueAttributeDML(queueName string) (stmt string, args []interface{})

func (SQLTemplateForPostgres) NewHideJobDML

func (SQLTemplateForPostgres) NewHideJobDML(queueRawName string, jobID string, oldRetryCount, oldInvisibleUntil, invisibleTime int64) (stmt string, args []interface{})

func (SQLTemplateForPostgres) NewUpdateJobByVisibilityTimeoutDML

func (SQLTemplateForPostgres) NewUpdateJobByVisibilityTimeoutDML(queueRawName string, jobID string, visibilityTimeout int64) (stmt string, args []interface{})

func (SQLTemplateForPostgres) NewUpdateQueueAttributeDML

func (SQLTemplateForPostgres) NewUpdateQueueAttributeDML(visibilityTimeout, delaySeconds, maximumMessageSize, messageRetentionPeriod *int64, deadLetterTarget *string, maxReceiveCount *int64, queueName string) (string, []interface{})