Pipeline for IRedisNative Client

Greatsamps · June 30, 2020, 10:01am

can someone point me in the right direction on how to create pipeline for this client? We have a number of commands we use in byte[] format such a LPUSH and would like to use a pipeline for them

mythz · June 30, 2020, 2:54pm

You should be able to cast the redis parameter into a IRedisNativeClient to access the low-level byte[] APIs, e.g:

github.com

ServiceStack/ServiceStack.Redis/blob/a11d835c2a5da2e77813ef45f14c82e08c0844a4/src/ServiceStack.Redis/Support/Locking/DistributedLock.cs#L54-L59


using (var pipe = localClient.CreatePipeline())
{
    long lockValue = 0;
    pipe.QueueCommand(r => ((RedisNativeClient)r).Watch(key));
    pipe.QueueCommand(r => ((RedisNativeClient)r).Get(key), x => lockValue = (x != null) ? BitConverter.ToInt64(x, 0) : 0);
    pipe.Flush();