strategy

Documentation

Overview

Package strategy defines different route strategy mode.

Index

• Constants
• func IsWriteCommand(funcName string, args []interface{}) bool
• type CommandType
• type DoubleWriteStrategy
  • func (d *DoubleWriteStrategy) AfterProcess(ctx context.Context, cmd redis.Cmder) error
  • func (d *DoubleWriteStrategy) AfterProcessPipeline(ctx context.Context, cmds []redis.Cmder) error
  • func (d *DoubleWriteStrategy) BeforeProcess(ctx context.Context, cmd redis.Cmder) (context.Context, error)
  • func (d *DoubleWriteStrategy) BeforeProcessPipeline(ctx context.Context, cmds []redis.Cmder) (context.Context, error)
  • func (a *DoubleWriteStrategy) Close() error
  • func (d *DoubleWriteStrategy) RouteClient(opType CommandType) redis.UniversalClient
  • func (d *DoubleWriteStrategy) Watch(ctx context.Context, fn func(*redis.Tx) error, keys ...string) error
• type LocalReadSingleWriteStrategy
  • func (a *LocalReadSingleWriteStrategy) AfterProcess(ctx context.Context, cmd redis.Cmder) error
  • func (a *LocalReadSingleWriteStrategy) AfterProcessPipeline(ctx context.Context, cmds []redis.Cmder) error
  • func (a *LocalReadSingleWriteStrategy) BeforeProcess(ctx context.Context, cmd redis.Cmder) (context.Context, error)
  • func (a *LocalReadSingleWriteStrategy) BeforeProcessPipeline(ctx context.Context, cmds []redis.Cmder) (context.Context, error)
  • func (a *LocalReadSingleWriteStrategy) Close() error
  • func (l *LocalReadSingleWriteStrategy) RouteClient(opType CommandType) redis.UniversalClient
  • func (l *LocalReadSingleWriteStrategy) Watch(ctx context.Context, fn func(*redis.Tx) error, keys ...string) error
• type SingelReadDoubleWriteStrategy
  • func (d *SingelReadDoubleWriteStrategy) AfterProcess(ctx context.Context, cmd redis.Cmder) error
  • func (d *SingelReadDoubleWriteStrategy) AfterProcessPipeline(ctx context.Context, cmds []redis.Cmder) error
  • func (d *SingelReadDoubleWriteStrategy) BeforeProcess(ctx context.Context, cmd redis.Cmder) (context.Context, error)
  • func (d *SingelReadDoubleWriteStrategy) BeforeProcessPipeline(ctx context.Context, cmds []redis.Cmder) (context.Context, error)
  • func (a *SingelReadDoubleWriteStrategy) Close() error
  • func (d *SingelReadDoubleWriteStrategy) RouteClient(opType CommandType) redis.UniversalClient
  • func (d *SingelReadDoubleWriteStrategy) Watch(ctx context.Context, fn func(*redis.Tx) error, keys ...string) error
• type SingleReadWriteStrategy
  • func (a *SingleReadWriteStrategy) AfterProcess(ctx context.Context, cmd redis.Cmder) error
  • func (a *SingleReadWriteStrategy) AfterProcessPipeline(ctx context.Context, cmds []redis.Cmder) error
  • func (a *SingleReadWriteStrategy) BeforeProcess(ctx context.Context, cmd redis.Cmder) (context.Context, error)
  • func (a *SingleReadWriteStrategy) BeforeProcessPipeline(ctx context.Context, cmds []redis.Cmder) (context.Context, error)
  • func (a *SingleReadWriteStrategy) Close() error
  • func (s *SingleReadWriteStrategy) RouteClient(opType CommandType) redis.UniversalClient
  • func (s *SingleReadWriteStrategy) Watch(ctx context.Context, fn func(*redis.Tx) error, keys ...string) error
• type StrategyMode
  • func NewStrategy(configuration *config.Configuration) StrategyMode

Constants

const (
	SingleReadWriteMode       = "single-read-write"
	LocalReadSingleWriteMode  = "local-read-single-write"
	SingleReadDoubleWriteMode = "single-read-async-double-write"
	LocalReadDoubleWriteMode  = "local-read-async-double-write"
)

Functions

func IsWriteCommand

func IsWriteCommand(funcName string, args []interface{}) bool

Types

type CommandType

type CommandType int32

const (
	CommandTypeRead CommandType = iota
	CommandTypeWrite
	CommandTypeMulti
	CommandTypeOther
)

type DoubleWriteStrategy

type DoubleWriteStrategy struct {
	// contains filtered or unexported fields
}

func (*DoubleWriteStrategy) AfterProcess

func (d *DoubleWriteStrategy) AfterProcess(ctx context.Context, cmd redis.Cmder) error

func (*DoubleWriteStrategy) AfterProcessPipeline

func (d *DoubleWriteStrategy) AfterProcessPipeline(ctx context.Context, cmds []redis.Cmder) error

func (*DoubleWriteStrategy) BeforeProcess

func (d *DoubleWriteStrategy) BeforeProcess(ctx context.Context, cmd redis.Cmder) (context.Context, error)

func (*DoubleWriteStrategy) BeforeProcessPipeline

func (d *DoubleWriteStrategy) BeforeProcessPipeline(ctx context.Context, cmds []redis.Cmder) (context.Context, error)

func (*DoubleWriteStrategy) Close

func (a *DoubleWriteStrategy) Close() error

func (*DoubleWriteStrategy) RouteClient

func (d *DoubleWriteStrategy) RouteClient(opType CommandType) redis.UniversalClient

func (*DoubleWriteStrategy) Watch

func (d *DoubleWriteStrategy) Watch(ctx context.Context, fn func(*redis.Tx) error, keys ...string) error

type LocalReadSingleWriteStrategy

type LocalReadSingleWriteStrategy struct {
	// contains filtered or unexported fields
}

func (*LocalReadSingleWriteStrategy) AfterProcess

func (a *LocalReadSingleWriteStrategy) AfterProcess(ctx context.Context, cmd redis.Cmder) error

func (*LocalReadSingleWriteStrategy) AfterProcessPipeline

func (a *LocalReadSingleWriteStrategy) AfterProcessPipeline(ctx context.Context, cmds []redis.Cmder) error

func (*LocalReadSingleWriteStrategy) BeforeProcess

func (a *LocalReadSingleWriteStrategy) BeforeProcess(ctx context.Context, cmd redis.Cmder) (context.Context, error)

func (*LocalReadSingleWriteStrategy) BeforeProcessPipeline

func (a *LocalReadSingleWriteStrategy) BeforeProcessPipeline(ctx context.Context, cmds []redis.Cmder) (context.Context, error)

func (*LocalReadSingleWriteStrategy) Close

func (a *LocalReadSingleWriteStrategy) Close() error

func (*LocalReadSingleWriteStrategy) RouteClient

func (l *LocalReadSingleWriteStrategy) RouteClient(opType CommandType) redis.UniversalClient

func (*LocalReadSingleWriteStrategy) Watch

func (l *LocalReadSingleWriteStrategy) Watch(ctx context.Context, fn func(*redis.Tx) error, keys ...string) error

type SingelReadDoubleWriteStrategy

type SingelReadDoubleWriteStrategy struct {
	DoubleWriteStrategy
}

func (*SingelReadDoubleWriteStrategy) AfterProcess

func (d *SingelReadDoubleWriteStrategy) AfterProcess(ctx context.Context, cmd redis.Cmder) error

func (*SingelReadDoubleWriteStrategy) AfterProcessPipeline

func (d *SingelReadDoubleWriteStrategy) AfterProcessPipeline(ctx context.Context, cmds []redis.Cmder) error

func (*SingelReadDoubleWriteStrategy) BeforeProcess

func (d *SingelReadDoubleWriteStrategy) BeforeProcess(ctx context.Context, cmd redis.Cmder) (context.Context, error)

func (*SingelReadDoubleWriteStrategy) BeforeProcessPipeline

func (d *SingelReadDoubleWriteStrategy) BeforeProcessPipeline(ctx context.Context, cmds []redis.Cmder) (context.Context, error)

func (*SingelReadDoubleWriteStrategy) Close

func (a *SingelReadDoubleWriteStrategy) Close() error

func (*SingelReadDoubleWriteStrategy) RouteClient

func (d *SingelReadDoubleWriteStrategy) RouteClient(opType CommandType) redis.UniversalClient

func (*SingelReadDoubleWriteStrategy) Watch

func (d *SingelReadDoubleWriteStrategy) Watch(ctx context.Context, fn func(*redis.Tx) error, keys ...string) error

type SingleReadWriteStrategy

type SingleReadWriteStrategy struct {
	// contains filtered or unexported fields
}

func (*SingleReadWriteStrategy) AfterProcess

func (a *SingleReadWriteStrategy) AfterProcess(ctx context.Context, cmd redis.Cmder) error

func (*SingleReadWriteStrategy) AfterProcessPipeline

func (a *SingleReadWriteStrategy) AfterProcessPipeline(ctx context.Context, cmds []redis.Cmder) error

func (*SingleReadWriteStrategy) BeforeProcess

func (a *SingleReadWriteStrategy) BeforeProcess(ctx context.Context, cmd redis.Cmder) (context.Context, error)

func (*SingleReadWriteStrategy) BeforeProcessPipeline

func (a *SingleReadWriteStrategy) BeforeProcessPipeline(ctx context.Context, cmds []redis.Cmder) (context.Context, error)

func (*SingleReadWriteStrategy) Close

func (a *SingleReadWriteStrategy) Close() error

func (*SingleReadWriteStrategy) RouteClient

func (s *SingleReadWriteStrategy) RouteClient(opType CommandType) redis.UniversalClient

func (*SingleReadWriteStrategy) Watch

func (s *SingleReadWriteStrategy) Watch(ctx context.Context, fn func(*redis.Tx) error, keys ...string) error

type StrategyMode

type StrategyMode interface {
	RouteClient(opType CommandType) redis.UniversalClient
	Close() error
	Watch(ctx context.Context, fn func(*redis.Tx) error, keys ...string) error
}

func NewStrategy

func NewStrategy(configuration *config.Configuration) StrategyMode