|
@ -495,6 +495,7 @@ type RedisService interface { |
|
|
LRpush(in *LSetRequest, out *LSetResponse) error |
|
|
LRpush(in *LSetRequest, out *LSetResponse) error |
|
|
LRange(in *LRangeRequest, out *HGetListResponse) error |
|
|
LRange(in *LRangeRequest, out *HGetListResponse) error |
|
|
LLen(in *LLenRequest, out *LSetResponse) error |
|
|
LLen(in *LLenRequest, out *LSetResponse) error |
|
|
|
|
|
ReduceStock(in *SetRequest, out *SetResponse) error |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
// AcceptRedisServiceClient accepts connections on the listener and serves requests
|
|
|
// AcceptRedisServiceClient accepts connections on the listener and serves requests
|
|
@ -620,6 +621,9 @@ func (c *RedisServiceClient) LRange(in *LRangeRequest, out *HGetListResponse) er |
|
|
func (c *RedisServiceClient) LLen(in *LLenRequest, out *LSetResponse) error { |
|
|
func (c *RedisServiceClient) LLen(in *LLenRequest, out *LSetResponse) error { |
|
|
return c.Call("RedisService.LLen", in, out) |
|
|
return c.Call("RedisService.LLen", in, out) |
|
|
} |
|
|
} |
|
|
|
|
|
func (c *RedisServiceClient) ReduceStock(in *SetRequest, out *SetResponse) error { |
|
|
|
|
|
return c.Call("RedisService.ReduceStock", in, out) |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
// DialRedisService connects to an RedisService at the specified network address.
|
|
|
// DialRedisService connects to an RedisService at the specified network address.
|
|
|
func DialRedisService(network, addr string) (*RedisServiceClient, *rpc.Client, error) { |
|
|
func DialRedisService(network, addr string) (*RedisServiceClient, *rpc.Client, error) { |
|
|