queue

Feb 12, 2026

Changes in this version

+ type ExecutionResult struct

+ Confidence float64

+ Cost float64

+ Metadata map[string]interface{}

+ Response string

+ Success bool

+ TokensUsed int

+ type Provider interface

+ Execute func(ctx context.Context, request map[string]interface{}) (*ExecutionResult, error)

+ GetModels func(ctx context.Context) ([]string, error)

+ GetName func() string

+ type ProviderManager interface

+ GetProvider func(providerType core.ProviderType) (Provider, error)

+ ListProviders func() []string

Jun 20, 2025

Changes in this version

+ const JobTypeAttack

+ const JobTypeBatchAttack

+ const JobTypeComplianceCheck

+ const JobTypeProviderTest

+ const JobTypeTemplateValidation

+ type AttackConfiguration struct

+ CollectMetrics bool

+ ConcurrentLimit int

+ MaxRetries int

+ RateLimit int

+ StopOnSuccess bool

+ Timeout time.Duration

+ type AttackJobHandler struct

+ func NewAttackJobHandler(providerManager interfaces.ProviderManager, ...) *AttackJobHandler

+ func (h *AttackJobHandler) GetJobTypes() []string

+ func (h *AttackJobHandler) ProcessJob(ctx context.Context, job *Job) error

+ type AttackJobPayload struct

+ Configuration AttackConfiguration

+ Metadata map[string]interface{}

+ Model string

+ Parameters map[string]interface{}

+ ProviderType core.ProviderType

+ TemplateID string

+ type AttackResult struct

+ AttackType string

+ Confidence float64

+ Cost float64

+ Error string

+ ExecutionTime time.Duration

+ JobID string

+ Metadata map[string]interface{}

+ Model string

+ ProviderType core.ProviderType

+ Response string

+ Success bool

+ Timestamp time.Time

+ TokensUsed int

+ type BatchAttackPayload struct

+ Attacks []*AttackJobPayload

+ Configuration AttackConfiguration

+ type DefaultLogger struct

+ func NewDefaultLogger() *DefaultLogger

+ func (l *DefaultLogger) Debug(msg string, args ...interface{})

+ func (l *DefaultLogger) Error(msg string, args ...interface{})

+ func (l *DefaultLogger) Info(msg string, args ...interface{})

+ func (l *DefaultLogger) Warn(msg string, args ...interface{})

+ type Job struct

+ Attempts int

+ CompletedAt *time.Time

+ CreatedAt time.Time

+ Error string

+ FailedAt *time.Time

+ ID string

+ MaxRetries int

+ Payload map[string]interface{}

+ Priority int

+ Queue string

+ Result interface{}

+ ScheduledAt time.Time

+ StartedAt *time.Time

+ Status JobStatus

+ Type string

+ type JobHandler interface

+ GetJobTypes func() []string

+ ProcessJob func(ctx context.Context, job *Job) error

+ type JobStatus string

+ const JobStatusCancelled

+ const JobStatusCompleted

+ const JobStatusFailed

+ const JobStatusPending

+ const JobStatusProcessing

+ const JobStatusRetrying

+ type Logger interface

+ Debug func(msg string, args ...interface{})

+ Error func(msg string, args ...interface{})

+ Info func(msg string, args ...interface{})

+ Warn func(msg string, args ...interface{})

+ type QueueMetrics struct

+ ActiveWorkers int64

+ AverageLatency time.Duration

+ JobsEnqueued int64

+ JobsFailed int64

+ JobsProcessed int64

+ JobsRetried int64

+ QueueLength int64

+ ThroughputRPS float64

+ type RedisJobQueue struct

+ func NewRedisJobQueue(config RedisQueueConfig, logger Logger) (*RedisJobQueue, error)

+ func (q *RedisJobQueue) AddWorker(handler JobHandler) (*Worker, error)

+ func (q *RedisJobQueue) CompleteJob(job *Job, result interface{}) error

+ func (q *RedisJobQueue) Dequeue(queueName string) (*Job, error)

+ func (q *RedisJobQueue) Enqueue(job *Job) error

+ func (q *RedisJobQueue) FailJob(job *Job, err error) error

+ func (q *RedisJobQueue) GetJob(jobID string) (*Job, error)

+ func (q *RedisJobQueue) GetMetrics() *QueueMetrics

+ func (q *RedisJobQueue) GetQueueLength(queueName string) (int64, error)

+ func (q *RedisJobQueue) GetWorkerMetrics() []*WorkerMetrics

+ func (q *RedisJobQueue) Start() error

+ func (q *RedisJobQueue) Stop() error

+ type RedisQueueConfig struct

+ BatchSize int

+ DefaultPriority int

+ EnableMetrics bool

+ EnablePipelining bool

+ JobTimeout time.Duration

+ MaxConnAge time.Duration

+ MaxRetries int

+ MetricsInterval time.Duration

+ MinIdleConns int

+ PollInterval time.Duration

+ PoolSize int

+ QueuePrefix string

+ RedisAddr string

+ RedisDB int

+ RedisPassword string

+ RetryDelay time.Duration

+ VisibilityTimeout time.Duration

+ WorkerCount int

+ func DefaultQueueConfig() RedisQueueConfig

+ type Worker struct

+ func (w *Worker) Start() error

+ func (w *Worker) Stop()

+ type WorkerMetrics struct

+ AverageLatency time.Duration

+ JobsFailed int64

+ JobsProcessed int64

+ LastActive time.Time

+ Status string

+ WorkerID string