Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MemJobQueue ¶
type MemJobQueue struct {
// contains filtered or unexported fields
}
MemJobQueue implements engine.AsyncJobQueue with an in-memory channel. Suitable for single-process (local) usage.
func NewMemJobQueue ¶
func NewMemJobQueue(bufferSize int) *MemJobQueue
type MemoryLock ¶
type MemoryLock struct {
// contains filtered or unexported fields
}
MemoryLock implements lock.DistributedLock with an in-memory mutex. Suitable for single-process (local) usage where Redis is not available. Only one goroutine can hold the lock at a time.
func NewMemoryLock ¶
func NewMemoryLock() *MemoryLock
type MemoryQueue ¶
type MemoryQueue struct {
// contains filtered or unexported fields
}
MemoryQueue implements repository.TaskQueue with an in-memory channel. Suitable for single-process (local) usage where Redis is not available.
func NewMemoryQueue ¶
func NewMemoryQueue(bufferSize int) *MemoryQueue
NewMemoryQueue creates a queue with the given buffer size.
func (*MemoryQueue) MoveToDead ¶
func (q *MemoryQueue) MoveToDead(_ context.Context, taskID int64) error
func (*MemoryQueue) PopAndReserve ¶
func (q *MemoryQueue) PopAndReserve(ctx context.Context) (int64, error)
Source Files
Click to show internal directories.
Click to hide internal directories.