redisadmin

package

v1.3.0 Latest Latest Go to latest Published: Nov 9, 2026 License: AGPL-3.0 Imports: 9 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/CarlSinclair/csuit-libs

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func AtoiDefault(s string, def int) int
func ClampPage(p int) int
func ClearQueues(queues ...string) error
func DeleteItem(queue, raw string) error
func EmailTasks(queue string, page, pageSize int) ([]redis.EmailTask, error)
func ErrorRecords(page, pageSize int) ([]redis.EmailErrorRecord, error)
func Inspect(queue string, limit int64) ([]string, error)
func ListLen(queue string) (int64, error)
func LogLen(name string) (int64, error)
func MoveItem(from, to, raw string) error
func Pattern(prefixless string) string
func ResendTask(rawTask string) error
func RetryTasks(page, pageSize int) ([]redis.EmailTask, error)
func RunOne(send func(redis.EmailTask) error) (bool, error)
func SentRecords(page, pageSize int) ([]redis.EmailSentRecord, error)
func SetLen(queue string) (int64, error)
type KeySummary
- func KeysPage(pattern string, page, pageSize int) ([]KeySummary, int, error)
- func ScanKeys(pattern string, startCursor uint64, want int) ([]KeySummary, uint64, error)
- func Summary(key string) KeySummary
type Pager
- func NewPager(total int64, page, pageSize int) Pager

Constants ¶

View Source

const DefaultPageSize = 10

Variables ¶

This section is empty.

Functions ¶

func AtoiDefault ¶

func AtoiDefault(s string, def int) int

func ClampPage ¶

func ClampPage(p int) int

func ClearQueues ¶

func ClearQueues(queues ...string) error

func DeleteItem ¶

func DeleteItem(queue, raw string) error

func EmailTasks ¶

func EmailTasks(queue string, page, pageSize int) ([]redis.EmailTask, error)

func ErrorRecords ¶

func ErrorRecords(page, pageSize int) ([]redis.EmailErrorRecord, error)

func Inspect ¶

func Inspect(queue string, limit int64) ([]string, error)

func ListLen ¶

func ListLen(queue string) (int64, error)

func LogLen ¶

func LogLen(name string) (int64, error)

func MoveItem ¶

func MoveItem(from, to, raw string) error

func Pattern ¶

func Pattern(prefixless string) string

func ResendTask ¶

func ResendTask(rawTask string) error

func RetryTasks ¶

func RetryTasks(page, pageSize int) ([]redis.EmailTask, error)

func RunOne ¶

func RunOne(send func(redis.EmailTask) error) (bool, error)

func SentRecords ¶

func SentRecords(page, pageSize int) ([]redis.EmailSentRecord, error)

func SetLen ¶

func SetLen(queue string) (int64, error)

Types ¶

type KeySummary ¶

type KeySummary struct {
	Name string
	Type string
	Size int64
}

func KeysPage ¶

func KeysPage(pattern string, page, pageSize int) ([]KeySummary, int, error)

func ScanKeys ¶

func ScanKeys(pattern string, startCursor uint64, want int) ([]KeySummary, uint64, error)

func Summary ¶

func Summary(key string) KeySummary

type Pager struct {
	Total int64
	Page  int
	Pages int
	Prev  int
	Next  int
}

func NewPager ¶

func NewPager(total int64, page, pageSize int) Pager

Source Files ¶

View all Source files

admin.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL

Documentation ¶

Index ¶

Constants ¶

Variables ¶

Functions ¶

func AtoiDefault ¶

func ClampPage ¶

func ClearQueues ¶

func DeleteItem ¶

func EmailTasks ¶

func ErrorRecords ¶

func Inspect ¶

func ListLen ¶

func LogLen ¶

func MoveItem ¶

func Pattern ¶

func ResendTask ¶

func RetryTasks ¶

func RunOne ¶

func SentRecords ¶

func SetLen ¶

Types ¶

type KeySummary ¶

func KeysPage ¶

func ScanKeys ¶

func Summary ¶

type Pager ¶

func NewPager ¶

Source Files ¶