Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type MemoryStore ¶
type MemoryStore struct {
// contains filtered or unexported fields
}
A MemoryStore stores all records data into the memory
func (*MemoryStore) Finish ¶
func (m *MemoryStore) Finish(d []byte) error
Finish marks a task as finished
func (*MemoryStore) HouseKeeping ¶
func (m *MemoryStore) HouseKeeping() error
HouseKeeping handles dead jobs, putting them back in the queue
func (*MemoryStore) Length ¶
func (m *MemoryStore) Length(q string) (int, error)
Length returns the number of elements in the in-memory array
func (*MemoryStore) Retrieve ¶
func (m *MemoryStore) Retrieve() ([]byte, error)
Retrieve pops the latest data from the in-memory array
func (*MemoryStore) Store ¶
func (m *MemoryStore) Store(d []byte) error
Store add the provided data to the in-memory array
type RedisStore ¶
type RedisStore struct {
// contains filtered or unexported fields
}
A RedisStore stores all records data into redis
func (*RedisStore) Finish ¶
func (r *RedisStore) Finish(d []byte) error
Finish marks a task as finished
func (*RedisStore) HouseKeeping ¶
func (r *RedisStore) HouseKeeping() error
HouseKeeping handles dead job, putting them back in the queue
func (*RedisStore) Length ¶
func (r *RedisStore) Length(q string) (int, error)
Length returns the number of elements in the in-memory array
func (*RedisStore) Retrieve ¶
func (r *RedisStore) Retrieve() ([]byte, error)
Retrieve pops the latest data from the in-memory array
func (*RedisStore) Store ¶
func (r *RedisStore) Store(d []byte) error
Store add the provided data to the in-memory array
Source Files
Click to show internal directories.
Click to hide internal directories.