Documentation
¶
Index ¶
- Variables
- type LocalDrive
- func (d LocalDrive) Close()
- func (d LocalDrive) Get(key string) ([]byte, error)
- func (d LocalDrive) Init()
- func (d LocalDrive) LPop(queueName string) ([]byte, error)
- func (d LocalDrive) LPush(queueName string, value []byte) error
- func (d LocalDrive) RPush(queueName string, value []byte) error
- func (d LocalDrive) Set(key string, value []byte, exTime int) error
- type UnsafeFileLock
Constants ¶
This section is empty.
Variables ¶
View Source
var EmptyQueueError = errors.New("empty queue")
View Source
var NilResultError = errors.New("nil result")
Functions ¶
This section is empty.
Types ¶
type LocalDrive ¶
type LocalDrive struct {
// contains filtered or unexported fields
}
func NewLocalDrive ¶
func NewLocalDrive(isBroker bool) LocalDrive
func (LocalDrive) Close ¶
func (d LocalDrive) Close()
func (LocalDrive) Init ¶
func (d LocalDrive) Init()
type UnsafeFileLock ¶
type UnsafeFileLock struct {
// contains filtered or unexported fields
}
func NewFileLock ¶
func NewFileLock(s string) UnsafeFileLock
func (UnsafeFileLock) Init ¶
func (l UnsafeFileLock) Init()
func (UnsafeFileLock) Lock ¶
func (l UnsafeFileLock) Lock() error
func (UnsafeFileLock) Unlock ¶
func (l UnsafeFileLock) Unlock()
Source Files
Click to show internal directories.
Click to hide internal directories.