package store
import (
"context"
"database/sql"
)
package pool
import "context"
type Job func(ctx context.Context) error
package worker
import "context"
func (p *Pool) Submit(job Job) error {
// Reject fast if draining, otherwise enqueue with backpressure.
package metrics
import "time"
type bucket struct {
start time.Time
package metrics
import (
"net/http"
"strconv"
"time"
package flags
import (
"context"
"encoding/json"
"sync/atomic"
package export
import (
"encoding/csv"
"log"
"net/http"
package middleware
import (
"net/http"
"golang.org/x/time/rate"
package pqueue
type Job struct {
ID string
Payload interface{}
Priority int
package health
import (
"context"
"net"
"net/http"
package domain
import "time"
type DomainEvent interface {
EventName() string
package store
import (
"context"
sq "github.com/Masterminds/squirrel"