-
Notifications
You must be signed in to change notification settings - Fork 19
/
ack.h
15 lines (12 loc) · 608 Bytes
/
ack.h
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
/* Copyright (c) 2014-2019, Salvatore Sanfilippo <antirez at gmail dot com>
* All rights reserved. This code is under the AGPL license, check the
* LICENSE file for more info. */
#ifndef __DISQUE_ACK_H
#define __DISQUE_ACK_H
void acknowledgeJob(RedisModuleCtx *ctx, job *j);
void tryJobGC(RedisModuleCtx *ctx, job *job);
void gotAckReceived(RedisModuleCtx *ctx, const char *sender, job *job, int known);
mstime_t getNextGCRetryTime(job *job);
int ackjobCommand(RedisModuleCtx *ctx, RedisModuleString **argv, int argc);
int fastackCommand(RedisModuleCtx *ctx, RedisModuleString **argv, int argc);
#endif