mysql

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

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

func (SQLTemplateForMySQL) NewCreateQueueAttributeDDL() string

func (SQLTemplateForMySQL) NewCreateQueueDDL(queueRawName string) string

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

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

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

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

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

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

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

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

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