remon

package module

Go to main page

Versions in this module

v0

v0.1.9

May 29, 2023

Changes in this version

type Mail

+ func (m Mail) GetImportance() uint8

v0.1.8

May 15, 2023

Changes in this version

+ var ErrMailBoxFull = errors.New("remon: mail box full")

+ var ErrNotExists = errors.New("remon: not exists")

type Client

+ func (cli *Client) List(ctx context.Context, key string) (_ []*Mail, err error)

+ func (cli *Client) Pull(ctx context.Context, key string, ids ...int64) (pulled []int64, err error)

+ func (cli *Client) Push(ctx context.Context, key, val string, opts ...PushOption) (id int64, err error)

+ func (cli *Client) Sync(ctx context.Context)

type GetOption

+ func AddIfNotExists(v string) GetOption

+ type KeyMappingFunc func(key string) (db, collection, _id string)

+ type OnSyncFailFunc func(err error) time.Duration

type Option

+ func OnSyncFail(f OnSyncFailFunc) Option

type PushOption

+ func WithImportance(v uint8) PushOption

+ func WithRing() PushOption

v0.1.7

Jan 24, 2022

v0.1.6

Aug 26, 2021

v0.1.5

Jul 1, 2021

v0.1.4

May 12, 2021

Changes in this version

+ var ErrAlreadyExists = errors.New("already exists")

+ var ErrMailFull = errors.New("mail full")

+ var ErrNotFound = errors.New("not found")

+ type Client interface

+ Add func(ctx context.Context, key, val string) (err error)

+ Get func(ctx context.Context, key string, opts ...GetOption) (rev int64, val string, err error)

+ Metrics func() *Metrics

+ Set func(ctx context.Context, key, val string) (rev int64, err error)

+ func NewClient(rdb RedisClient, mdb *mongo.Client, opts ...Option) Client

+ type GetOption interface

+ func AddIfNotFound(v string) GetOption

+ type Mail struct

+ Id int64

+ Val string

+ type MailClient interface

+ Clean func(ctx context.Context, key string) (err error)

+ List func(ctx context.Context, key string) (_ []*Mail, err error)

+ Pull func(ctx context.Context, key string, ids ...int64) (pulled []int64, err error)

+ Push func(ctx context.Context, key, val string, opts ...PushOption) (id int64, err error)

+ func NewMailClient(rm Client) MailClient

+ type MapKeyFunc func(key string) (db, collection, _id string)

+ type Metrics struct

+ func (m *Metrics) CacheHit() int64

+ func (m *Metrics) CacheMiss() int64

+ func (m *Metrics) DataError() int64

+ func (m *Metrics) MongoError() int64

+ func (m *Metrics) RedisError() int64

+ func (m *Metrics) Reset()

+ type OnSyncErrorFunc func(err error) time.Duration

+ type OnSyncIdleFunc func() time.Duration

+ type OnSyncSaveFunc func(key string) time.Duration

type Option

+ func OnSyncError(f OnSyncErrorFunc) Option

+ func OnSyncIdle(f OnSyncIdleFunc) Option

+ func OnSyncSave(f OnSyncSaveFunc) Option

+ func WithKeyMap(f MapKeyFunc) Option

type PushOption

+ func WithPushStrategy(v PushStrategy) PushOption

+ type PushStrategy int

+ const PullOldestOnFull

+ const RejectOnFull

type RedisClient

+ EvalSha func(ctx context.Context, sha1 string, keys []string, args ...interface{}) *redis.Cmd

+ ScriptLoad func(ctx context.Context, script string) *redis.StringCmd

+ type Syncer struct

+ func NewSyncer(rdb RedisClient, mdb *mongo.Client, opts ...Option) *Syncer

+ func (s *Syncer) Serve()

+ func (s *Syncer) Stop()

v0.1.3

Nov 9, 2020

Changes in this version

+ var ErrClosed = errors.New("remon: closed")

+ var ErrNotExist = errors.New("remon: not exist")

+ func ScriptLoad(r scripter) (err error)

+ type DB = ReMon

+ type Data struct

+ List struct{ ... }

+ Value string

+ Version int64

+ func (d Data) String() string

+ type Elem struct

+ Id string

+ Value string

+ type KeyMappingStrategy interface

+ MapKey func(string) (_, _, _ string)

+ type Option interface

+ func WithKeyMappingStrategy(v KeyMappingStrategy) Option

+ func WithKeyMappingStrategyFunc(v func(string) (_, _, _ string)) Option

+ func WithSyncLimit(v int) Option

+ func WithVolatileTTL(v time.Duration) Option

+ type PushOption interface

+ func WithCapacity(capacity int) PushOption

+ type ReMon struct

+ func New(r RedisClient, m *mongo.Client, opts ...Option) (x *ReMon)

+ func (x *ReMon) EvalVarJSON(ctx context.Context, key, src string) (ret int, value string, err error)

+ func (x *ReMon) Get(ctx context.Context, key string) (value string, err error)

+ func (x *ReMon) GetList(ctx context.Context, key string) (list []Elem, err error)

+ func (x *ReMon) Pull(ctx context.Context, key string, ids []string) (n int, err error)

+ func (x *ReMon) Push(ctx context.Context, key string, values []string, opts ...PushOption) (err error)

+ func (x *ReMon) Set(ctx context.Context, key, value string) (err error)

+ func (x *ReMon) Stat() *Stat

+ type RedisClient interface

+ Pipeline func() redis.Pipeliner

+ ProcessContext func(context.Context, redis.Cmder) error

+ type Stat struct

+ DataError int64

+ MongoError int64

+ RedisError int64

+ RedisHit int64

+ RedisMiss int64

+ type Sync struct

+ func NewSync(r RedisClient, m *mongo.Client, opts ...Option) *Sync

+ func (x *Sync) Close()

+ func (x *Sync) Hook(hookers ...SyncHooker)

+ func (x *Sync) Serve() (err error)

+ func (x *Sync) Shutdown(ctx context.Context) (err error)

+ type SyncHooker interface

+ func SyncOnError(f SyncOnErrorFunc) SyncHooker

+ func SyncOnSave(f SyncOnSaveFunc) SyncHooker

+ type SyncOnErrorFunc func(err error) error

+ type SyncOnSaveFunc func(key string, version int64)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL