redis

Documentation

Index

• Variables
• func Create(id, name string, v *Config, workers map[eosc.RequireId]eosc.IWorker) (eosc.IWorker, error)
• func NewFactory() eosc.IExtenderDriverFactory
• func Register(register eosc.IExtenderDriverRegister)
• type Cmdable
  • func (r *Cmdable) BuildVector(name string, uni, step time.Duration) (resources.Vector, error)
  • func (r *Cmdable) DecrBy(ctx context.Context, key string, decrement int64, expiration time.Duration) resources.IntResult
  • func (r *Cmdable) Del(ctx context.Context, keys ...string) resources.IntResult
  • func (r *Cmdable) Get(ctx context.Context, key string) resources.StringResult
  • func (r *Cmdable) GetDel(ctx context.Context, key string) resources.StringResult
  • func (r *Cmdable) IncrBy(ctx context.Context, key string, decrement int64, expiration time.Duration) resources.IntResult
  • func (r *Cmdable) Run(ctx context.Context, script interface{}, keys []string, args ...interface{}) resources.InterfaceResult
  • func (r *Cmdable) Set(ctx context.Context, key string, value []byte, expiration time.Duration) resources.StatusResult
  • func (r *Cmdable) SetNX(ctx context.Context, key string, value []byte, expiration time.Duration) resources.BoolResult
  • func (r *Cmdable) Tx() resources.TX
• type Config
• type Empty
  • func (e *Empty) BuildVector(name string, uni, step time.Duration) (resources.Vector, error)
  • func (e *Empty) DecrBy(ctx context.Context, key string, decrement int64, expiration time.Duration) resources.IntResult
  • func (e *Empty) Del(ctx context.Context, keys ...string) resources.IntResult
  • func (e *Empty) Exec(ctx context.Context) error
  • func (e *Empty) Get(ctx context.Context, key string) resources.StringResult
  • func (e *Empty) GetDel(ctx context.Context, key string) resources.StringResult
  • func (e *Empty) IncrBy(ctx context.Context, key string, decrement int64, expiration time.Duration) resources.IntResult
  • func (e *Empty) Run(ctx context.Context, script interface{}, keys []string, args ...interface{}) resources.InterfaceResult
  • func (e *Empty) Set(ctx context.Context, key string, value []byte, expiration time.Duration) resources.StatusResult
  • func (e *Empty) SetNX(ctx context.Context, key string, value []byte, expiration time.Duration) resources.BoolResult
  • func (e *Empty) Tx() resources.TX
• type TxPipeline
  • func (tx *TxPipeline) Exec(ctx context.Context) error
  • func (tx *TxPipeline) Tx() resources.TX
• type Vector
  • func (v *Vector) Add(key string, delta int64)
  • func (v *Vector) CompareAndAdd(key string, threshold, delta int64) bool
  • func (v *Vector) Get(key string) int64
• type Worker
  • func (w *Worker) CheckSkill(skill string) bool
  • func (w *Worker) Reset(conf interface{}, workers map[eosc.RequireId]eosc.IWorker) error
  • func (w *Worker) Start() error
  • func (w *Worker) Stop() error

Variables

var (
	ErrorNotInitRedis = errors.New("redis not init")
)

Functions

func Create

func Create(id, name string, v *Config, workers map[eosc.RequireId]eosc.IWorker) (eosc.IWorker, error)

func NewFactory

func NewFactory() eosc.IExtenderDriverFactory

NewFactory 创建service_http驱动工厂

func Register

func Register(register eosc.IExtenderDriverRegister)

Types

type Cmdable

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

func (*Cmdable) BuildVector

func (r *Cmdable) BuildVector(name string, uni, step time.Duration) (resources.Vector, error)

func (*Cmdable) DecrBy

func (r *Cmdable) DecrBy(ctx context.Context, key string, decrement int64, expiration time.Duration) resources.IntResult

func (*Cmdable) Del

func (r *Cmdable) Del(ctx context.Context, keys ...string) resources.IntResult

func (*Cmdable) Get

func (r *Cmdable) Get(ctx context.Context, key string) resources.StringResult

func (*Cmdable) GetDel

func (r *Cmdable) GetDel(ctx context.Context, key string) resources.StringResult

func (*Cmdable) IncrBy

func (r *Cmdable) IncrBy(ctx context.Context, key string, decrement int64, expiration time.Duration) resources.IntResult

func (*Cmdable) Run

func (r *Cmdable) Run(ctx context.Context, script interface{}, keys []string, args ...interface{}) resources.InterfaceResult

func (*Cmdable) Set

func (r *Cmdable) Set(ctx context.Context, key string, value []byte, expiration time.Duration) resources.StatusResult

func (*Cmdable) SetNX

func (r *Cmdable) SetNX(ctx context.Context, key string, value []byte, expiration time.Duration) resources.BoolResult

func (*Cmdable) Tx

func (r *Cmdable) Tx() resources.TX

type Config

type Config struct {
	Addrs    []string `json:"addrs" label:"redis 节点列表"`
	Username string   `json:"username"`
	Password string   `json:"password"`
	Scopes   []string `json:"scopes" label:"资源组"`
}

type Empty

type Empty struct {
}

func (*Empty) BuildVector

func (e *Empty) BuildVector(name string, uni, step time.Duration) (resources.Vector, error)

func (*Empty) DecrBy

func (e *Empty) DecrBy(ctx context.Context, key string, decrement int64, expiration time.Duration) resources.IntResult

func (*Empty) Del

func (e *Empty) Del(ctx context.Context, keys ...string) resources.IntResult

func (*Empty) Exec

func (e *Empty) Exec(ctx context.Context) error

func (*Empty) Get

func (e *Empty) Get(ctx context.Context, key string) resources.StringResult

func (*Empty) GetDel

func (e *Empty) GetDel(ctx context.Context, key string) resources.StringResult

func (*Empty) IncrBy

func (e *Empty) IncrBy(ctx context.Context, key string, decrement int64, expiration time.Duration) resources.IntResult

func (*Empty) Run

func (e *Empty) Run(ctx context.Context, script interface{}, keys []string, args ...interface{}) resources.InterfaceResult

func (*Empty) Set

func (e *Empty) Set(ctx context.Context, key string, value []byte, expiration time.Duration) resources.StatusResult

func (*Empty) SetNX

func (e *Empty) SetNX(ctx context.Context, key string, value []byte, expiration time.Duration) resources.BoolResult

func (*Empty) Tx

func (e *Empty) Tx() resources.TX

type TxPipeline

type TxPipeline struct {
	Cmdable
	// contains filtered or unexported fields
}

func (*TxPipeline) Exec

func (tx *TxPipeline) Exec(ctx context.Context) error

func (*TxPipeline) Tx

func (tx *TxPipeline) Tx() resources.TX

type Vector

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

func (*Vector) Add

func (v *Vector) Add(key string, delta int64)

func (*Vector) CompareAndAdd

func (v *Vector) CompareAndAdd(key string, threshold, delta int64) bool

func (*Vector) Get

func (v *Vector) Get(key string) int64

type Worker

type Worker struct {
	drivers.WorkerBase
	resources.ICache
	resources.IVectors
	// contains filtered or unexported fields
}

func (*Worker) CheckSkill

func (w *Worker) CheckSkill(skill string) bool

func (*Worker) Reset

func (w *Worker) Reset(conf interface{}, workers map[eosc.RequireId]eosc.IWorker) error

func (*Worker) Start

func (w *Worker) Start() error

func (*Worker) Stop

func (w *Worker) Stop() error