The highest tagged major version is v3.

backends

package

v2.1.4 Latest Latest Go to latest Published: Mar 16, 2020 License: GPL-3.0 Imports: 8 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/gojuukaze/YTask

Links

Open Source Insights

Documentation ¶

Index ¶

type BackendInterface
type MemCacheBackend
- func NewMemCacheBackend(host, port string, poolSize int) MemCacheBackend
type MongoBackend
- func NewMongoBackend(host, port, user, password, db, collection string) MongoBackend
type RedisBackend
- func NewRedisBackend(host string, port string, password string, db int, poolSize int) RedisBackend

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type BackendInterface ¶

type BackendInterface interface {
	SetResult(result message.Result, exTime int) error
	GetResult(key string) (message.Result, error)
	// 调用Activate后才真正建立连接
	Activate()
	SetPoolSize(int)
	GetPoolSize() int
}

type MemCacheBackend ¶ added in v2.1.4

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

func NewMemCacheBackend ¶ added in v2.1.4

func NewMemCacheBackend(host, port string, poolSize int) MemCacheBackend

func (*MemCacheBackend) Activate ¶ added in v2.1.4

func (r *MemCacheBackend) Activate()

func (*MemCacheBackend) GetPoolSize ¶ added in v2.1.4

func (r *MemCacheBackend) GetPoolSize() int

func (*MemCacheBackend) GetResult ¶ added in v2.1.4

func (r *MemCacheBackend) GetResult(key string) (message.Result, error)

func (*MemCacheBackend) SetPoolSize ¶ added in v2.1.4

func (r *MemCacheBackend) SetPoolSize(n int)

func (*MemCacheBackend) SetResult ¶ added in v2.1.4

func (r *MemCacheBackend) SetResult(result message.Result, exTime int) error

type MongoBackend ¶ added in v2.1.4

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

func NewMongoBackend ¶ added in v2.1.4

func NewMongoBackend(host, port, user, password, db, collection string) MongoBackend

func (*MongoBackend) Activate ¶ added in v2.1.4

func (r *MongoBackend) Activate()

func (*MongoBackend) GetPoolSize ¶ added in v2.1.4

func (r *MongoBackend) GetPoolSize() int

func (*MongoBackend) GetResult ¶ added in v2.1.4

func (r *MongoBackend) GetResult(key string) (message.Result, error)

func (*MongoBackend) SetPoolSize ¶ added in v2.1.4

func (r *MongoBackend) SetPoolSize(n int)

func (*MongoBackend) SetResult ¶ added in v2.1.4

func (r *MongoBackend) SetResult(result message.Result, exTime int) error

type RedisBackend ¶

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

func NewRedisBackend ¶

func NewRedisBackend(host string, port string, password string, db int, poolSize int) RedisBackend

func (*RedisBackend) Activate ¶

func (r *RedisBackend) Activate()

func (*RedisBackend) GetPoolSize ¶

func (r *RedisBackend) GetPoolSize() int

func (*RedisBackend) GetResult ¶

func (r *RedisBackend) GetResult(key string) (message.Result, error)

func (*RedisBackend) SetPoolSize ¶

func (r *RedisBackend) SetPoolSize(n int)

func (*RedisBackend) SetResult ¶

func (r *RedisBackend) SetResult(result message.Result, exTime int) error

Source Files ¶

View all Source files

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