diff options
| author | Mitja Felicijan <mitja.felicijan@gmail.com> | 2026-01-21 22:52:54 +0100 |
|---|---|---|
| committer | Mitja Felicijan <mitja.felicijan@gmail.com> | 2026-01-21 22:52:54 +0100 |
| commit | dcacc00e3750300617ba6e16eb346713f91a783a (patch) | |
| tree | 38e2d4fb5ed9d119711d4295c6eda4b014af73fd /examples/redis-unstable/src/cluster_asm.h | |
| parent | 58dac10aeb8f5a041c46bddbeaf4c7966a99b998 (diff) | |
| download | crep-dcacc00e3750300617ba6e16eb346713f91a783a.tar.gz | |
Remove testing data
Diffstat (limited to 'examples/redis-unstable/src/cluster_asm.h')
| -rw-r--r-- | examples/redis-unstable/src/cluster_asm.h | 57 |
1 files changed, 0 insertions, 57 deletions
diff --git a/examples/redis-unstable/src/cluster_asm.h b/examples/redis-unstable/src/cluster_asm.h deleted file mode 100644 index 841a55d..0000000 --- a/examples/redis-unstable/src/cluster_asm.h +++ /dev/null @@ -1,57 +0,0 @@ -/* cluster_asm.h -- Atomic slot migration implementation for cluster - * - * Copyright (c) 2025-Present, Redis Ltd. - * All rights reserved. - * - * Licensed under your choice of (a) the Redis Source Available License 2.0 - * (RSALv2); or (b) the Server Side Public License v1 (SSPLv1); or (c) the - * GNU Affero General Public License v3 (AGPLv3). - */ - -#ifndef CLUSTER_ASM_H -#define CLUSTER_ASM_H - -struct asmTask; -struct slotRangeArray; -struct slotRange; - -void asmInit(void); -void asmBeforeSleep(void); -void asmCron(void); -void asmSlotSnapshotAndStreamStart(struct asmTask *task); -void asmSlotSnapshotSucceed(struct asmTask *task); -void asmSlotSnapshotFailed(struct asmTask *task); -void asmCallbackOnFreeClient(client *c); -int asmMigrateInProgress(void); -int asmImportInProgress(void); -void asmFeedMigrationClient(robj **argv, int argc); -int asmDebugSetFailPoint(char * channel, char *state); -int asmDebugSetTrimMethod(const char *method, int active_trim_delay); - -void asmImportIncrAppliedBytes(struct asmTask *task, size_t bytes); -struct slotRangeArray *asmTaskGetSlotRanges(const char *task_id); -int asmNotifyConfigUpdated(struct asmTask *task, sds *err); -size_t asmGetPeakSyncBufferSize(void); -size_t asmGetImportInputBufferSize(void); -size_t asmGetMigrateOutputBufferSize(void); -int clusterAsmCancel(const char *task_id, const char *reason); -int clusterAsmCancelBySlot(int slot, const char *reason); -int clusterAsmCancelBySlotRangeArray(struct slotRangeArray *slots, const char *reason); -int clusterAsmCancelByNode(void *node, const char *reason); -int isSlotInAsmTask(int slot); -int isSlotInTrimJob(int slot); -sds asmCatInfoString(sds info); -void clusterMigrationCommand(client *c); -void clusterSyncSlotsCommand(client *c); -struct asmTask *asmLookupTaskBySlotRangeArray(struct slotRangeArray *slots); -void asmCancelTrimJobs(void); -sds asmDumpActiveImportTask(void); -int asmReplicaHandleMasterTask(sds task_info); -void asmFinalizeMasterTask(void); -int asmIsTrimInProgress(void); -int asmGetTrimmingSlotForCommand(struct redisCommand *cmd, robj **argv, int argc); -void asmActiveTrimCycle(void); -int asmIsKeyInTrimJob(sds keyname); -int asmModulePropagateBeforeSlotSnapshot(struct redisCommand *cmd, robj **argv, int argc); -#endif - |
