repo_webhooks

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

type CreateParams struct {
	Kind     models.WebhookKind   `db:"kind" json:"kind"`
	Status   models.WebhookStatus `db:"status" json:"status"`
	Payload  []byte               `db:"payload" json:"payload"`
	ClientID uuid.UUID            `db:"client_id" json:"client_id"`
}

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
	SendBatch(context.Context, *pgx.Batch) pgx.BatchResults
}

type Querier interface {
	Cleanup(ctx context.Context, createdAt pgtype.Timestamptz) (int64, error)
	Create(ctx context.Context, arg []CreateParams) *CreateBatchResults
	DeleteByID(ctx context.Context, id uuid.UUID) error
	Exists(ctx context.Context, payload []byte, payload_2 []byte) (bool, error)
	GetByID(ctx context.Context, id uuid.UUID) (*models.WebhookView, error)
	GetUnsent(ctx context.Context, status models.WebhookStatus, limit int32) ([]*models.WebhookView, error)
	IncrementAttempt(ctx context.Context, iD uuid.UUID, response pgtype.Text) error
	SetSentAtNow(ctx context.Context, iD uuid.UUID, response pgtype.Text) error
}

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