Documentation ¶
Index ¶
- type Provider
- 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{})
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SQLTemplateForPostgres ¶
type SQLTemplateForPostgres struct { }
func (SQLTemplateForPostgres) NewAddQueueAttributeDML ¶
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 ¶
Click to show internal directories.
Click to hide internal directories.