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) 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) 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
- type Vector
- type Worker
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrorNotInitRedis = errors.New("redis not init")
)
Functions ¶
func NewFactory ¶ added in v0.9.0
func NewFactory() eosc.IExtenderDriverFactory
NewFactory 创建service_http驱动工厂
func Register ¶
func Register(register eosc.IExtenderDriverRegister)
Types ¶
type Cmdable ¶ added in v0.9.0
type Cmdable struct {
// contains filtered or unexported fields
}
func (*Cmdable) BuildVector ¶ added in v0.9.0
type Empty ¶ added in v0.9.0
type Empty struct { }
func (*Empty) BuildVector ¶ added in v0.9.0
type TxPipeline ¶ added in v0.9.0
type TxPipeline struct { Cmdable // contains filtered or unexported fields }
func (*TxPipeline) Tx ¶ added in v0.9.0
func (tx *TxPipeline) Tx() resources.TX
type Vector ¶ added in v0.9.0
type Vector struct {
// contains filtered or unexported fields
}
func (*Vector) CompareAndAdd ¶ added in v0.9.0
Click to show internal directories.
Click to hide internal directories.