cmd_cluster.go

package redisson

import "context"

type ClusterCmdable interface {
	// ClusterAddSlots
	// Available since: 3.0.0
	// Time complexity: O(N) where N is the total number of hash slot arguments
	// ACL categories: @admin @slow @dangerous
	// RESP2 / RESP3 Reply:
	// 	- Simple string reply: OK if the command was successful. Otherwise an error is returned.
	ClusterAddSlots(ctx context.Context, slots ...int64) StatusCmd

	// ClusterAddSlotsRange
	// Available since: 7.0.0
	// Time complexity: O(N) where N is the total number of the slots between the start slot and end slot arguments.
	// ACL categories: @admin @slow @dangerous
	// RESP2 / RESP3 Reply:
	// 	- Simple string reply: OK if the command was successful. Otherwise an error is returned.
	ClusterAddSlotsRange(ctx context.Context, min, max int64) StatusCmd

	// ClusterCountFailureReports
	// Available since: 3.0.0
	// Time complexity: O(N) where N is the number of failure reports
	// ACL categories: @admin @slow @dangerous
	// RESP2 / RESP3 Reply:
	// 	- Integer reply: the number of active failure reports for the node.
	ClusterCountFailureReports(ctx context.Context, nodeID string) IntCmd

	// ClusterCountKeysInSlot
	// Available since: 3.0.0
	// Time complexity: O(1)
	// ACL categories: @slow
	// RESP2 / RESP3 Reply:
	// 	- Integer reply: The number of keys in the specified hash slot, or an error if the hash slot is invalid.
	ClusterCountKeysInSlot(ctx context.Context, slot int64) IntCmd

	// ClusterDelSlots
	// Available since: 3.0.0
	// Time complexity: O(N) where N is the total number of hash slot arguments
	// ACL categories: @admin @slow @dangerous
	// RESP2 / RESP3 Reply:
	// 	- Simple string reply: OK if the command was successful. Otherwise an error is returned.
	ClusterDelSlots(ctx context.Context, slots ...int64) StatusCmd

	// ClusterDelSlotsRange
	// Available since: 7.0.0
	// Time complexity: O(N) where N is the total number of the slots between the start slot and end slot arguments.
	// ACL categories: @admin @slow @dangerous
	// RESP2 / RESP3 Reply:
	// 	- Simple string reply: OK if the command was successful. Otherwise an error is returned.
	ClusterDelSlotsRange(ctx context.Context, min, max int64) StatusCmd

	// ClusterFailover
	// Available since: 3.0.0
	// Time complexity: O(1)
	// ACL categories: @admin @slow @dangerous
	// RESP2 / RESP3 Reply:
	// 	- Simple string reply: OK if the command was accepted and a manual failover is going to be attempted.
	//		An error if the operation cannot be executed, for example if the client is connected to a node that is already a master.
	ClusterFailover(ctx context.Context) StatusCmd

	// ClusterForget
	// Available since: 3.0.0
	// Time complexity: O(1)
	// ACL categories: @admin @slow @dangerous
	// RESP2 / RESP3 Reply:
	// 	- Simple string reply: OK if the command was executed successfully. Otherwise an error is returned.
	ClusterForget(ctx context.Context, nodeID string) StatusCmd

	// ClusterGetKeysInSlot
	// Available since: 3.0.0
	// Time complexity: O(N) where N is the number of requested keys
	// ACL categories: @slow
	// RESP2 / RESP3 Reply:
	// 	- Array reply: an array with up to count elements.
	ClusterGetKeysInSlot(ctx context.Context, slot int64, count int64) StringSliceCmd

	// ClusterInfo
	// Available since: 3.0.0
	// Time complexity: O(1)
	// ACL categories: @slow
	// RESP2 Reply:
	//	- Bulk string reply: A map between named fields and values in the form of <field>:<value> lines separated by newlines composed by the two bytes CRLF.
	// RESP3 Reply:
	//	- Bulk string reply: A map between named fields and values in the form of : lines separated by newlines composed by the two bytes CRLF
	ClusterInfo(ctx context.Context) StringCmd

	// ClusterKeySlot
	// Available since: 3.0.0
	// Time complexity: O(N) where N is the number of bytes in the key
	// ACL categories: @slow
	// RESP2 / RESP3 Reply:
	// 	- Integer reply: The hash slot number for the specified key
	ClusterKeySlot(ctx context.Context, key string) IntCmd

	// ClusterMeet
	// Available since: 3.0.0
	// Time complexity: O(1)
	// ACL categories: @admin @slow @dangerous
	// RESP2 / RESP3 Reply:
	//	- Simple string reply: OK if the command was successful. If the address or port specified are invalid an error is returned.
	// History:
	//	- Starting with Redis version 4.0.0: Added the optional cluster_bus_port argument.
	ClusterMeet(ctx context.Context, host string, port int64) StatusCmd

	// ClusterNodes
	// Available since: 3.0.0
	// Time complexity: O(N) where N is the total number of Cluster nodes
	// ACL categories: @slow
	// RESP2 / RESP3 Reply:
	// 	- Bulk string reply: the serialized cluster configuration.
	ClusterNodes(ctx context.Context) StringCmd

	// ClusterReplicas
	// Available since: 5.0.0
	// Time complexity: O(N) where N is the number of replicas.
	// ACL categories: @admin @slow @dangerous
	// RESP2 / RESP3 Reply:
	// 	- Array reply: a list of replica nodes replicating from the specified master node provided in the same format used by CLUSTER NODES.
	ClusterReplicas(ctx context.Context, nodeID string) StringSliceCmd

	// ClusterReplicate
	// Available since: 3.0.0
	// Time complexity: O(1)
	// ACL categories: @admin @slow @dangerous
	// RESP2 / RESP3 Reply:
	// 	- Simple string reply: OK if the command was successful. Otherwise an error is returned.
	ClusterReplicate(ctx context.Context, nodeID string) StatusCmd

	// ClusterResetSoft
	// Available since: 3.0.0
	// Time complexity: O(N) where N is the number of known nodes. The command may execute a FLUSHALL as a side effect.
	// ACL categories: @admin @slow @dangerous
	// RESP2 / RESP3 Reply:
	// 	- Simple string reply: OK if the command was successful. Otherwise an error is returned.
	ClusterResetSoft(ctx context.Context) StatusCmd
	ClusterResetHard(ctx context.Context) StatusCmd

	// ClusterSaveConfig
	// Available since: 3.0.0
	// Time complexity: O(1)
	// ACL categories: @admin @slow @dangerous
	// RESP2 / RESP3 Reply:
	// 	- Simple string reply: OK if the command was successful. Otherwise an error is returned.
	ClusterSaveConfig(ctx context.Context) StatusCmd

	// ClusterSlaves
	// Available since: 3.0.0
	// Time complexity: O(N) where N is the number of replicas.
	// ACL categories: @admin @slow @dangerous
	// RESP2 / RESP3 Reply:
	// 	- Array reply: a list of replica nodes replicating from the specified master node provided in the same format used by CLUSTER NODES.
	ClusterSlaves(ctx context.Context, nodeID string) StringSliceCmd

	// ClusterSlots
	// Available since: 3.0.0
	// Time complexity: O(N) where N is the total number of Cluster nodes
	// ACL categories: @slow
	// RESP2 / RESP3 Reply:
	// 	- Array reply: nested list of slot ranges with networking information.
	// History:
	//	- Starting with Redis version 4.0.0: Added node IDs.
	//	- Starting with Redis version 7.0.0: Added additional networking metadata field.
	ClusterSlots(ctx context.Context) ClusterSlotsCmd

	// ClusterShards
	// Available since: 7.0.0
	// Time complexity: O(N) where N is the total number of cluster nodes
	// ACL categories: @slow
	// RESP2 Reply:
	//	- Array reply: a nested list of a map of hash ranges and shard nodes describing individual shards.
	// RESP3 Reply:
	//	- Array reply: a nested list of Map reply of hash ranges and shard nodes describing individual shards.
	ClusterShards(ctx context.Context) ClusterShardsCmd

	// ReadOnly
	// Available since: 3.0.0
	// Time complexity: O(1)
	// ACL categories: @fast @connection
	// RESP2 / RESP3 Reply:
	// 	- Simple string reply: OK.
	ReadOnly(ctx context.Context) StatusCmd

	// ReadWrite
	// Available since: 3.0.0
	// Time complexity: O(1)
	// ACL categories: @fast @connection
	// RESP2 / RESP3 Reply:
	// 	- Simple string reply: OK.
	ReadWrite(ctx context.Context) StatusCmd
}

func (c *client) ClusterAddSlots(ctx context.Context, slots ...int64) StatusCmd {
	ctx = c.handler.before(ctx, CommandClusterAddSlots)
	r := c.adapter.ClusterAddSlots(ctx, slots...)
	c.handler.after(ctx, r.Err())
	return r
}

func (c *client) ClusterAddSlotsRange(ctx context.Context, min, max int64) StatusCmd {
	ctx = c.handler.before(ctx, CommandClusterAddSlotsRange)
	r := c.adapter.ClusterAddSlotsRange(ctx, min, max)
	c.handler.after(ctx, r.Err())
	return r
}

func (c *client) ClusterCountFailureReports(ctx context.Context, nodeID string) IntCmd {
	ctx = c.handler.before(ctx, CommandClusterCountFailureReports)
	r := c.adapter.ClusterCountFailureReports(ctx, nodeID)
	c.handler.after(ctx, r.Err())
	return r
}

func (c *client) ClusterCountKeysInSlot(ctx context.Context, slot int64) IntCmd {
	ctx = c.handler.before(ctx, CommandClusterCountKeysInSlot)
	r := c.adapter.ClusterCountKeysInSlot(ctx, slot)
	c.handler.after(ctx, r.Err())
	return r
}

func (c *client) ClusterDelSlots(ctx context.Context, slots ...int64) StatusCmd {
	ctx = c.handler.before(ctx, CommandClusterDelSlots)
	r := c.adapter.ClusterDelSlots(ctx, slots...)
	c.handler.after(ctx, r.Err())
	return r
}

func (c *client) ClusterDelSlotsRange(ctx context.Context, min, max int64) StatusCmd {
	ctx = c.handler.before(ctx, CommandClusterDelSlotsRange)
	r := c.adapter.ClusterDelSlotsRange(ctx, min, max)
	c.handler.after(ctx, r.Err())
	return r
}

func (c *client) ClusterFailover(ctx context.Context) StatusCmd {
	ctx = c.handler.before(ctx, CommandClusterFailover)
	r := c.adapter.ClusterFailover(ctx)
	c.handler.after(ctx, r.Err())
	return r
}

func (c *client) ClusterForget(ctx context.Context, nodeID string) StatusCmd {
	ctx = c.handler.before(ctx, CommandClusterForget)
	r := c.adapter.ClusterForget(ctx, nodeID)
	c.handler.after(ctx, r.Err())
	return r
}

func (c *client) ClusterGetKeysInSlot(ctx context.Context, slot int64, count int64) StringSliceCmd {
	ctx = c.handler.before(ctx, CommandClusterGetKeysInSlot)
	r := wrapStringSliceCmd(c.adapter.ClusterGetKeysInSlot(ctx, slot, count))
	c.handler.after(ctx, r.Err())
	return r
}

func (c *client) ClusterInfo(ctx context.Context) StringCmd {
	ctx = c.handler.before(ctx, CommandClusterInfo)
	r := wrapStringCmd(c.adapter.ClusterInfo(ctx))
	c.handler.after(ctx, r.Err())
	return r
}

func (c *client) ClusterKeySlot(ctx context.Context, key string) IntCmd {
	ctx = c.handler.before(ctx, CommandClusterKeySlot)
	r := c.adapter.ClusterKeySlot(ctx, key)
	c.handler.after(ctx, r.Err())
	return r
}

func (c *client) ClusterMeet(ctx context.Context, host string, port int64) StatusCmd {
	ctx = c.handler.before(ctx, CommandClusterMeet)
	r := c.adapter.ClusterMeet(ctx, host, port)
	c.handler.after(ctx, r.Err())
	return r
}

func (c *client) ClusterNodes(ctx context.Context) StringCmd {
	ctx = c.handler.before(ctx, CommandClusterNodes)
	r := wrapStringCmd(c.adapter.ClusterNodes(ctx))
	c.handler.after(ctx, r.Err())
	return r
}

func (c *client) ClusterReplicas(ctx context.Context, nodeID string) StringSliceCmd {
	ctx = c.handler.before(ctx, CommandClusterReplicas)
	r := newStringSliceCmd(c.Do(ctx, c.builder.ClusterReplicasCompleted(nodeID)))
	c.handler.after(ctx, r.Err())
	return r
}

func (c *client) ClusterReplicate(ctx context.Context, nodeID string) StatusCmd {
	ctx = c.handler.before(ctx, CommandClusterReplicate)
	r := c.adapter.ClusterReplicate(ctx, nodeID)
	c.handler.after(ctx, r.Err())
	return r
}

func (c *client) ClusterResetSoft(ctx context.Context) StatusCmd {
	ctx = c.handler.before(ctx, CommandClusterResetSoft)
	r := c.adapter.ClusterResetSoft(ctx)
	c.handler.after(ctx, r.Err())
	return r
}

func (c *client) ClusterResetHard(ctx context.Context) StatusCmd {
	ctx = c.handler.before(ctx, CommandClusterResetHard)
	r := c.adapter.ClusterResetHard(ctx)
	c.handler.after(ctx, r.Err())
	return r
}

func (c *client) ClusterSaveConfig(ctx context.Context) StatusCmd {
	ctx = c.handler.before(ctx, CommandClusterSaveConfig)
	r := c.adapter.ClusterSaveConfig(ctx)
	c.handler.after(ctx, r.Err())
	return r
}

func (c *client) ClusterSlaves(ctx context.Context, nodeID string) StringSliceCmd {
	ctx = c.handler.before(ctx, CommandClusterSlaves)
	r := wrapStringSliceCmd(c.adapter.ClusterSlaves(ctx, nodeID))
	c.handler.after(ctx, r.Err())
	return r
}

func (c *client) ClusterSlots(ctx context.Context) ClusterSlotsCmd {
	ctx = c.handler.before(ctx, CommandClusterSlots)
	r := c.adapter.ClusterSlots(ctx)
	c.handler.after(ctx, r.Err())
	return r
}

func (c *client) ClusterShards(ctx context.Context) ClusterShardsCmd {
	ctx = c.handler.before(ctx, CommandClusterShards)
	r := c.adapter.ClusterShards(ctx)
	c.handler.after(ctx, r.Err())
	return r
}

func (c *client) ReadOnly(ctx context.Context) StatusCmd {
	ctx = c.handler.before(ctx, CommandReadOnly)
	r := c.adapter.ReadOnly(ctx)
	c.handler.after(ctx, r.Err())
	return r
}

func (c *client) ReadWrite(ctx context.Context) StatusCmd {
	ctx = c.handler.before(ctx, CommandReadWrite)
	r := c.adapter.ReadWrite(ctx)
	c.handler.after(ctx, r.Err())
	return r
}