memory

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

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) Healthy

func (this MemoryStore) Healthy(ctx context.Context) error

func (*MemoryStore) Init

func (this *MemoryStore) Init(queues []string) error

func (MemoryStore) MaxConcurrentDrainWorkers

func (this MemoryStore) MaxConcurrentDrainWorkers() int

func (*MemoryStore) Pop

func (this *MemoryStore) Pop(ctx context.Context, queueName string, handler types.Handler) error

func (*MemoryStore) Publish

func (this *MemoryStore) Publish(ctx context.Context, queueName string, payload *types.Task) (err error)

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

func (*MemoryStore) Subscribe

func (this *MemoryStore) Subscribe(ctx context.Context, queueName string, handler types.Handler) error

func (*MemoryStore) Suck

func (this *MemoryStore) Suck(ctx context.Context, queueName string, handler types.Handler) error