kewpie

Jul 4, 2024

Changes in this version

type Kewpie

+ RenameFunc func(string) string

Mar 25, 2021

Changes in this version

type Backend

+ MaxConcurrentDrainWorkers func() int

+ Suck func(ctx context.Context, queueName string, handler types.Handler) error

+ type HTTPError = types.HTTPError

+ type Handler = types.Handler

type Kewpie

+ func (this *Kewpie) AddPublishMiddleware(f func(context.Context, *Task, string) error)

+ func (this Kewpie) Buffer(ctx context.Context, queueName string, payload *Task) error

+ func (this Kewpie) Drain(ctx context.Context) error

+ func (this Kewpie) PrepareContext(ctx context.Context) context.Context

+ func (this Kewpie) SubscribeHTTP(secret string, handler types.Handler, ...) func(w http.ResponseWriter, r *http.Request)

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

Jun 1, 2020

Changes in this version

+ type Backend interface

+ Disconnect func() error

+ Healthy func(ctx context.Context) error

+ Init func(queues []string) error

+ Pop func(ctx context.Context, queueName string, handler types.Handler) error

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

+ Purge func(ctx context.Context, queueName string) error

+ PurgeMatching func(ctx context.Context, queueName, substr string) error

+ Subscribe func(ctx context.Context, queueName string, handler types.Handler) error

+ type Kewpie struct

+ func (this *Kewpie) Connect(backend string, queues []string, connection interface{}) error

+ func (this Kewpie) Disconnect() error

+ func (this Kewpie) Healthy(ctx context.Context) error

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

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

+ func (this Kewpie) Purge(ctx context.Context, queueName string) error

+ func (this Kewpie) PurgeMatching(ctx context.Context, queueName, substr string) error

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

+ type Tags = types.Tags

+ type Task = types.Task