riverui

Aug 16, 2025

retracted

Changes in this version

+ func NewEndpoints[TTx any](client *river.Client[TTx], opts *EndpointsOpts[TTx]) uiendpoints.Bundle

+ type EndpointsOpts struct

+ Tx *TTx

+ type Handler struct

+ func NewHandler(opts *HandlerOpts) (*Handler, error)

+ func (h *Handler) ServeHTTP(rw http.ResponseWriter, req *http.Request)

+ func (h *Handler) Start(ctx context.Context) error

+ type HandlerOpts struct

+ DevMode bool

+ Endpoints uiendpoints.Bundle

+ JobListHideArgsByDefault bool

+ LiveFS bool

+ Logger *slog.Logger

+ Prefix string

May 13, 2025

Changes in this version

+ type RiverJobMinimal struct

+ Args json.RawMessage

+ Attempt int

+ AttemptedAt *time.Time

+ AttemptedBy []string

+ CreatedAt time.Time

+ FinalizedAt *time.Time

+ ID int64

+ Kind string

+ MaxAttempts int

+ Priority int

+ Queue string

+ ScheduledAt time.Time

+ State string

+ Tags []string

type ServerOpts

+ JobListHideArgsByDefault bool

Apr 9, 2025

Changes in this version

+ func NewNotFoundJob(jobID int64) *apierror.NotFound

+ func NewNotFoundQueue(name string) *apierror.NotFound

+ func NewNotFoundWorkflow(id string) *apierror.NotFound

+ type ConcurrencyConfig struct

+ GlobalLimit int32

+ LocalLimit int32

+ Partition PartitionConfig

+ type PartitionConfig struct

+ ByArgs []string

+ ByKind bool

+ type RiverProducer struct

+ ClientID string

+ Concurrency *ConcurrencyConfig

+ CreatedAt time.Time

+ ID int64

+ MaxWorkers int

+ PausedAt *time.Time

+ QueueName string

+ Running int32

+ UpdatedAt time.Time

type RiverQueue

+ Concurrency *ConcurrencyConfig

Aug 29, 2024

Changes in this version

+ var FrontendIndex embed.FS

+ func NormalizePathPrefix(prefix string) string

+ type DB interface

+ Begin func(ctx context.Context) (pgx.Tx, error)

+ Exec func(ctx context.Context, query string, args ...interface{}) (pgconn.CommandTag, error)

+ Query func(ctx context.Context, query string, args ...interface{}) (pgx.Rows, error)

+ QueryRow func(ctx context.Context, query string, args ...interface{}) pgx.Row

+ type RiverJob struct

+ Args json.RawMessage

+ Attempt int

+ AttemptedAt *time.Time

+ AttemptedBy []string

+ CreatedAt time.Time

+ Errors []rivertype.AttemptError

+ FinalizedAt *time.Time

+ ID int64

+ Kind string

+ MaxAttempts int

+ Metadata json.RawMessage

+ Priority int

+ Queue string

+ ScheduledAt time.Time

+ State string

+ Tags []string

+ type RiverQueue struct

+ CountAvailable int

+ CountRunning int

+ CreatedAt time.Time

+ Metadata json.RawMessage

+ Name string

+ PausedAt *time.Time

+ UpdatedAt time.Time

+ type Server struct

+ func NewServer(opts *ServerOpts) (*Server, error)

+ func (s *Server) ServeHTTP(rw http.ResponseWriter, req *http.Request)

+ func (s *Server) Start(ctx context.Context) error

+ type ServerOpts struct

+ Client *river.Client[pgx.Tx]

+ DB DB

+ DevMode bool

+ LiveFS bool

+ Logger *slog.Logger

+ Prefix string