type github.com/go-redis/redis/v8.ClusterClient

51 uses

	github.com/go-redis/redis/v8 (current package)
		cluster.go#L678: type ClusterClient struct {
		cluster.go#L687: func NewClusterClient(opt *ClusterOptions) *ClusterClient {
		cluster.go#L690: 	c := &ClusterClient{
		cluster.go#L708: func (c *ClusterClient) Context() context.Context {
		cluster.go#L712: func (c *ClusterClient) WithContext(ctx context.Context) *ClusterClient {
		cluster.go#L724: func (c *ClusterClient) Options() *ClusterOptions {
		cluster.go#L730: func (c *ClusterClient) ReloadState(ctx context.Context) {
		cluster.go#L738: func (c *ClusterClient) Close() error {
		cluster.go#L743: func (c *ClusterClient) Do(ctx context.Context, args ...interface{}) *Cmd {
		cluster.go#L749: func (c *ClusterClient) Process(ctx context.Context, cmd Cmder) error {
		cluster.go#L753: func (c *ClusterClient) process(ctx context.Context, cmd Cmder) error {
		cluster.go#L762: func (c *ClusterClient) _process(ctx context.Context, cmd Cmder) error {
		cluster.go#L845: func (c *ClusterClient) ForEachMaster(
		cluster.go#L883: func (c *ClusterClient) ForEachSlave(
		cluster.go#L921: func (c *ClusterClient) ForEachShard(
		cluster.go#L964: func (c *ClusterClient) PoolStats() *PoolStats {
		cluster.go#L997: func (c *ClusterClient) loadState(ctx context.Context) (*clusterState, error) {
		cluster.go#L1049: func (c *ClusterClient) reaper(idleCheckFrequency time.Duration) {
		cluster.go#L1068: func (c *ClusterClient) Pipeline() Pipeliner {
		cluster.go#L1077: func (c *ClusterClient) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) {
		cluster.go#L1081: func (c *ClusterClient) processPipeline(ctx context.Context, cmds []Cmder) error {
		cluster.go#L1085: func (c *ClusterClient) _processPipeline(ctx context.Context, cmds []Cmder) error {
		cluster.go#L1133: func (c *ClusterClient) mapCmdsByNode(ctx context.Context, cmdsMap *cmdsMap, cmds []Cmder) error {
		cluster.go#L1162: func (c *ClusterClient) cmdsAreReadOnly(cmds []Cmder) bool {
		cluster.go#L1172: func (c *ClusterClient) _processPipelineNode(
		cluster.go#L1191: func (c *ClusterClient) pipelineReadCmds(
		cluster.go#L1219: func (c *ClusterClient) checkMovedErr(
		cluster.go#L1247: func (c *ClusterClient) TxPipeline() Pipeliner {
		cluster.go#L1256: func (c *ClusterClient) TxPipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) {
		cluster.go#L1260: func (c *ClusterClient) processTxPipeline(ctx context.Context, cmds []Cmder) error {
		cluster.go#L1264: func (c *ClusterClient) _processTxPipeline(ctx context.Context, cmds []Cmder) error {
		cluster.go#L1321: func (c *ClusterClient) mapCmdsBySlot(cmds []Cmder) map[int][]Cmder {
		cluster.go#L1330: func (c *ClusterClient) _processTxPipelineNode(
		cluster.go#L1362: func (c *ClusterClient) txPipelineReadQueued(
		cluster.go#L1403: func (c *ClusterClient) cmdsMoved(
		cluster.go#L1432: func (c *ClusterClient) Watch(ctx context.Context, fn func(*Tx) error, keys ...string) error {
		cluster.go#L1492: func (c *ClusterClient) pubSub() *PubSub {
		cluster.go#L1535: func (c *ClusterClient) Subscribe(ctx context.Context, channels ...string) *PubSub {
		cluster.go#L1545: func (c *ClusterClient) PSubscribe(ctx context.Context, channels ...string) *PubSub {
		cluster.go#L1553: func (c *ClusterClient) retryBackoff(attempt int) time.Duration {
		cluster.go#L1557: func (c *ClusterClient) cmdsInfo() (map[string]*CommandInfo, error) {
		cluster.go#L1599: func (c *ClusterClient) cmdInfo(name string) *CommandInfo {
		cluster.go#L1612: func (c *ClusterClient) cmdSlot(cmd Cmder) int {
		cluster.go#L1630: func (c *ClusterClient) cmdNode(
		cluster.go#L1656: func (c *ClusterClient) slotMasterNode(ctx context.Context, slot int) (*clusterNode, error) {
		cluster_commands.go#L8: func (c *ClusterClient) DBSize(ctx context.Context) *IntCmd {
		commands.go#L342: 	_ Cmdable = (*ClusterClient)(nil)
		script.go#L21: 	_ scripter = (*ClusterClient)(nil)
		sentinel.go#L683: func NewFailoverClusterClient(failoverOpt *FailoverOptions) *ClusterClient {
		universal.go#L188: 	_ UniversalClient = (*ClusterClient)(nil)