Versions in this module Expand all Collapse all v0 v0.14.0 Dec 18, 2024 Changes in this version + type RelayQueue interface + DeleteQueueEntries func(ctx context.Context, txn *sql.Tx, serverName spec.ServerName, jsonNIDs []int64) error + InsertQueueEntry func(ctx context.Context, txn *sql.Tx, ...) error + SelectQueueEntries func(ctx context.Context, txn *sql.Tx, serverName spec.ServerName, limit int) ([]int64, error) + SelectQueueEntryCount func(ctx context.Context, txn *sql.Tx, serverName spec.ServerName) (int64, error) + type RelayQueueJSON interface + DeleteQueueJSON func(ctx context.Context, txn *sql.Tx, nids []int64) error + InsertQueueJSON func(ctx context.Context, txn *sql.Tx, json string) (int64, error) + SelectQueueJSON func(ctx context.Context, txn *sql.Tx, jsonNIDs []int64) (map[int64][]byte, error)
Go to main page