Documentation
¶
Index ¶
- type Options
- func (o Options) GetConnectTimeout() time.Duration
- func (o Options) GetIdleTimeout() time.Duration
- func (o Options) GetMaxConnections() int
- func (o Options) GetMaxIdle() int
- func (o Options) GetReadTimeout() time.Duration
- func (o Options) GetTLSCertPath() string
- func (o Options) GetTLSSkipVerify() bool
- func (o Options) GetURI() string
- func (o Options) GetUseTLS() bool
- func (o Options) GetWriteTimeout() time.Duration
- type ResqueStatistics
- func (r *ResqueStatistics) Close() error
- func (r *ResqueStatistics) Connect(ctx context.Context) error
- func (r *ResqueStatistics) GetGlobalStats(ctx context.Context) (core.GlobalStats, error)
- func (r *ResqueStatistics) GetQueueStats(ctx context.Context, queue string) (core.QueueStats, error)
- func (r *ResqueStatistics) GetWorkerStats(ctx context.Context, workerID string) (core.WorkerStats, error)
- func (r *ResqueStatistics) Health() error
- func (r *ResqueStatistics) RecordJobCompleted(ctx context.Context, job job.Job, worker core.WorkerInfo, ...) error
- func (r *ResqueStatistics) RecordJobFailed(ctx context.Context, job job.Job, worker core.WorkerInfo, err error, ...) error
- func (r *ResqueStatistics) RecordJobStarted(ctx context.Context, job job.Job, worker core.WorkerInfo) error
- func (r *ResqueStatistics) RegisterWorker(ctx context.Context, worker core.WorkerInfo) error
- func (r *ResqueStatistics) Type() string
- func (r *ResqueStatistics) UnregisterWorker(ctx context.Context, workerID string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Options ¶
type Options struct {
// URI is the Redis connection URI
URI string
// Namespace is the key prefix in Redis
Namespace string
// MaxConnections is the maximum number of connections in the pool
MaxConnections int
// MaxIdle is the maximum number of idle connections
MaxIdle int
// IdleTimeout is the timeout for idle connections
IdleTimeout time.Duration
// ConnectTimeout is the timeout for establishing connections
ConnectTimeout time.Duration
// ReadTimeout is the timeout for read operations
ReadTimeout time.Duration
// WriteTimeout is the timeout for write operations
WriteTimeout time.Duration
// TLS options
UseTLS bool
TLSSkipVerify bool
TLSCertPath string
}
Options for Resque statistics
func DefaultOptions ¶
func DefaultOptions() Options
DefaultOptions returns default Resque statistics options
func (Options) GetConnectTimeout ¶
func (Options) GetIdleTimeout ¶
func (Options) GetMaxConnections ¶
func (Options) GetMaxIdle ¶
func (Options) GetReadTimeout ¶
func (Options) GetTLSCertPath ¶
func (Options) GetTLSSkipVerify ¶
func (Options) GetWriteTimeout ¶
type ResqueStatistics ¶
type ResqueStatistics struct {
// contains filtered or unexported fields
}
ResqueStatistics implements the Statistics interface for Resque
func NewStatistics ¶
func NewStatistics(options Options) *ResqueStatistics
NewStatistics creates a new Resque statistics backend
func (*ResqueStatistics) Close ¶
func (r *ResqueStatistics) Close() error
Close closes the Redis connection pool
func (*ResqueStatistics) Connect ¶
func (r *ResqueStatistics) Connect(ctx context.Context) error
Connect establishes connection to Redis
func (*ResqueStatistics) GetGlobalStats ¶
func (r *ResqueStatistics) GetGlobalStats(ctx context.Context) (core.GlobalStats, error)
GetGlobalStats returns global statistics
func (*ResqueStatistics) GetQueueStats ¶
func (r *ResqueStatistics) GetQueueStats(ctx context.Context, queue string) (core.QueueStats, error)
GetQueueStats returns statistics for a queue
func (*ResqueStatistics) GetWorkerStats ¶
func (r *ResqueStatistics) GetWorkerStats(ctx context.Context, workerID string) (core.WorkerStats, error)
GetWorkerStats returns statistics for a specific worker
func (*ResqueStatistics) Health ¶
func (r *ResqueStatistics) Health() error
Health checks the Redis connection health
func (*ResqueStatistics) RecordJobCompleted ¶
func (r *ResqueStatistics) RecordJobCompleted(ctx context.Context, job job.Job, worker core.WorkerInfo, duration time.Duration) error
RecordJobCompleted records successful job completion
func (*ResqueStatistics) RecordJobFailed ¶
func (r *ResqueStatistics) RecordJobFailed(ctx context.Context, job job.Job, worker core.WorkerInfo, err error, duration time.Duration) error
RecordJobFailed records job failure
func (*ResqueStatistics) RecordJobStarted ¶
func (r *ResqueStatistics) RecordJobStarted(ctx context.Context, job job.Job, worker core.WorkerInfo) error
RecordJobStarted records that a job has started
func (*ResqueStatistics) RegisterWorker ¶
func (r *ResqueStatistics) RegisterWorker(ctx context.Context, worker core.WorkerInfo) error
RegisterWorker registers a worker in Redis
func (*ResqueStatistics) Type ¶
func (r *ResqueStatistics) Type() string
Type returns the statistics backend type
func (*ResqueStatistics) UnregisterWorker ¶
func (r *ResqueStatistics) UnregisterWorker(ctx context.Context, workerID string) error
UnregisterWorker removes a worker from Redis
Source Files
Click to show internal directories.
Click to hide internal directories.