sqlite3

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

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

func (SQLTemplateForSQLite3) NewCreateQueueAttributeDDL() string

func (SQLTemplateForSQLite3) NewCreateQueueDDL(queueRawName string) string

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

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

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

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

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

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

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

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

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