Documentation
¶
Index ¶
- type MemoryStore
- func (this *MemoryStore) Disconnect() error
- func (this MemoryStore) Healthy(ctx context.Context) error
- func (this *MemoryStore) Init(queues []string) error
- func (this MemoryStore) MaxConcurrentDrainWorkers() int
- func (this *MemoryStore) Pop(ctx context.Context, queueName string, handler types.Handler) error
- func (this *MemoryStore) Publish(ctx context.Context, queueName string, payload *types.Task) (err error)
- func (this *MemoryStore) Purge(ctx context.Context, queueName string) error
- func (this *MemoryStore) PurgeMatching(ctx context.Context, queueName, substr string) error
- func (this *MemoryStore) Subscribe(ctx context.Context, queueName string, handler types.Handler) error
- func (this *MemoryStore) Suck(ctx context.Context, queueName string, handler types.Handler) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MemoryStore ¶
type MemoryStore struct {
// contains filtered or unexported fields
}
MemoryStore is intended for use in test suites. No data is persisted, so as soon as the process exits all the tasks vanish It's written for simplicity over efficiency, so don't expect it to be performant
func (*MemoryStore) Disconnect ¶
func (this *MemoryStore) Disconnect() error
func (*MemoryStore) Init ¶
func (this *MemoryStore) Init(queues []string) error
func (MemoryStore) MaxConcurrentDrainWorkers ¶ added in v3.0.9
func (this MemoryStore) MaxConcurrentDrainWorkers() int
func (*MemoryStore) Purge ¶
func (this *MemoryStore) Purge(ctx context.Context, queueName string) error
func (*MemoryStore) PurgeMatching ¶
func (this *MemoryStore) PurgeMatching(ctx context.Context, queueName, substr string) error
Source Files
Click to show internal directories.
Click to hide internal directories.