Skip to content

Reference

gisila_queue has three libraries:

Import Contents
package:gisila_queue/gisila_queue.dart Everything below except the CLI helpers and Rose.
package:gisila_queue/gisila_queue_cli.dart WorkerCli, BeatCli, CliArgs, installShutdownHooks.
package:gisila_queue/gisila_rose.dart GisilaRose, MonitorState, TaskInfo, WorkerInfo.
Page Symbols
GisilaQueue app GisilaQueue, GisilaQueue.redis, send, worker, replayDeadLetters, resultFor, newTaskId, close
Tasks and the registry GisilaQueue.task, TaskHandler, TaskContext, Task, RateLimit, SlidingWindowLimiter
Producer API TaskRef (delay, applyAsync, sig), GisilaQueue.send (dedupeKey), queue resolution, Router
Brokers Broker, InMemoryBroker, RedisBroker, RabbitBroker, RedisOptions, connectRedis
Results and AsyncResult AsyncResult, TaskState, ResultBackend, StoredResult, InMemoryResultBackend, RedisResultBackend
Workers Worker, TaskObserver, processing order
Retries, acks and dead letters Outcome table, backoff, ack timing, time limits, dead letters, replayDeadLetters
Beat and schedules Beat, BeatEntry, Schedule, IntervalSchedule, DailySchedule, CronSchedule, BeatLock, NoopBeatLock, RedisBeatLock, BeatStateStore, NoopBeatStateStore, RedisBeatStateStore
Workflows Signature, Chain, Group, GroupResult, Chord, ChainLink, ChordBarrier
Control channel ControlChannel, ControlMessage, ControlMessageType, NoopControlChannel, InMemoryControlChannel, RedisControlChannel
Events QueueEvent, QueueEventType, QueueEventSink, NoopEventSink, MultiEventSink, QueueEventSource, InMemoryEventBus, RedisEventSink, RedisEventSource
GisilaRose dashboard GisilaRose, HTTP API, MonitorState, TaskInfo, WorkerInfo
CLI tools WorkerCli, BeatCli, CliArgs, installShutdownHooks, gisila_queue inspect|purge, rose
Messages and codec TaskMessage, MessageCodec, JsonMessageCodec, defaultMessageCodec, validateEncodable
Namespaces and logging Namespaced, defaultNamespace, checkNamespaces, defaultNamespaceWarning, QueueLogger, LogLevel, ConsoleQueueLogger, SilentQueueLogger
Errors GisilaQueueException, TaskFailureException, ResultTimeoutException, UnencodableArgumentsException, RetryTask, RejectTask, TaskTimeLimitExceededException, UnknownTaskException
gisila_redis GisilaRedis, RedisRateLimitStore, RedisCacheProvider, RedisException
Celery gisila_queue
Celery() app GisilaQueue
@app.task app.task<T>(name, handler)
.delay() / .apply_async() ref.delay() / ref.applyAsync()
self.retry() ctx.retry()
AsyncResult AsyncResult
celery worker app.worker().run() or WorkerCli
celery beat Beat(app).run() or BeatCli
chain / group / chord app.chain() / app.group() / app.chord()
task_routes Router
app.control ControlChannel
rate_limit, time_limit, soft_time_limit rateLimit, timeLimit, softTimeLimit
celery inspect / purge gisila_queue inspect / purge
Flower GisilaRose