queries

type Config struct {
	InitialAckTimeout     int64   `json:"initial_ack_timeout"`
	SubsequentAckTimeouts []int64 `json:"subsequent_ack_timeouts"`
}

type DBTX interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
}

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

type Queue struct {
	QueueID          string
	ChannelID        string
	ChannelName      string
	TeamDomain       string
	TeamID           string
	UserList         string
	RequireAckBefore int64
	AckedBy          string
	Config           Config
}

type SaveQueueParams struct {
	ChannelID        string
	ChannelName      string
	TeamDomain       string
	TeamID           string
	UserList         string
	RequireAckBefore int64
	AckedBy          string
	Config           Config
	QueueID          string
}

type UpsertQueueParams struct {
	QueueID     string
	ChannelID   string
	ChannelName string
	TeamDomain  string
	TeamID      string
	UserList    string
	Config      Config
}

type UserAlreadyInQueueError string