dbconnector

type ChangeJobVisibilityInput struct {
	Job               *jobworker.Job
	VisibilityTimeout int64
}

type ChangeJobVisibilityOutput struct{}

type Config struct {
	Name                  string
	DB                    *sql.DB
	NumMaxRetries         int
	QueueAttributesExpire time.Duration

	SQLTemplate        SQLTemplate
	IsUniqueViolation  func(err error) bool
	IsDeadlockDetected func(err error) bool
}

type Connector struct {
	// contains filtered or unexported fields
}

type CreateQueueInput struct {
	Name              string
	DelaySeconds      int64
	VisibilityTimeout int64
	MaxReceiveCount   int64
	DeadLetterTarget  string
}

type CreateQueueOutput struct{}

type DeleteJobBatchInput struct {
	Jobs []*jobworker.Job
}

type DeleteJobBatchOutput struct {
}

type GetQueueAttributesInput struct {
	QueueName string
}

type GetQueueAttributesOutput struct {
	Attributes *QueueAttributes
}

type GrabJobsInput struct {
	QueueName         string
	MaxNumberOfJobs   int64
	VisibilityTimeout int64
}

type GrabJobsOutput struct {
	Jobs []*jobworker.Job
}

type MoveJobBatchInput struct {
	Jobs []*jobworker.Job
	To   string
}

type MoveJobBatchOutput struct {
}

type QueueAttributes struct {
	Name              string
	RawName           string
	DelaySeconds      int64
	VisibilityTimeout int64
	MaxReceiveCount   int64 // If the value is zero, retry infinitely
	DeadLetterTarget  *string
}

type SQLTemplate interface {
	NewFindJobDML(queueRawName string, jobID string) (string, []interface{})
	NewFindJobsDML(queueRawName string, limit int64) (string, []interface{})
	NewHideJobDML(queueRawName string, jobID string, oldReceiveCount, oldInvisibleUntil, invisibleTime int64) (string, []interface{})
	NewEnqueueJobDML(queueRawName, jobID, content string, deduplicationID, groupID *string, delaySeconds int64) (string, []interface{})
	NewEnqueueJobWithTimeDML(queueRawName, jobID, content string, deduplicationID, groupID *string, enqueueAt int64) (string, []interface{})
	NewDeleteJobDML(queueRawName, jobID string) (string, []interface{})
	NewUpdateJobByVisibilityTimeoutDML(queueRawName string, jobID string, visibilityTimeout int64) (string, []interface{})
	NewAddQueueAttributesDML(queueName, queueRawName string, delaySeconds, maxReceiveCount, visibilityTimeout int64, deadLetterTarget *string) (string, []interface{})
	NewUpdateQueueAttributesDML(queueRawName string, visibilityTimeout, delaySeconds, maxReceiveCount *int64, deadLetterTarget *string) (string, []interface{})
	NewFindQueueAttributesDML(queueName string) (string, []interface{})
	NewCreateQueueAttributesDDL() string
	NewCreateQueueDDL(queueRawName string) string
}

type SetQueueAttributesInput struct {
	QueueName         string
	DelaySeconds      *int64
	VisibilityTimeout *int64
	MaxReceiveCount   *int64
	DeadLetterTarget  *string
}

type SetQueueAttributesOutput struct{}