queue

type Consumer ¶

type Consumer func(...broker.Message)

type Queue ¶

type Queue interface {
	Consume(callback func(...broker.Message)) error
	PushRaw(ctx context.Context, message broker.Message) error
	Push(ctx context.Context, msg proto.Message) error
}

func OpenQueue(ctx context.Context, urlstr string) (Queue, error)

type TypeWithContext ¶

type TypeWithContext[T any] struct {
	Original T
	Ctx      context.Context
}

TypeWithContext composes a generic type and a context

type URLMux ¶

type URLMux struct {
	// contains filtered or unexported fields
}

URLMux is a URL opener multiplexer. It matches the scheme of the URLs against a set of registered schemes and calls the opener that matches the URL's scheme. See https://gocloud.dev/concepts/urls/ for more information.

The zero value is a multiplexer with no registered schemes.

func DefaultURLMux() *URLMux

func (mux *URLMux) OpenQueue(ctx context.Context, urlstr string) (Queue, error)

func (mux *URLMux) Register(scheme string, opener URLOpener)

func (mux *URLMux) Schemes() []string

func (mux *URLMux) ValidScheme(scheme string) bool

type URLOpener ¶

type URLOpener interface {
	OpenURL(ctx context.Context, u *url.URL) (Queue, error)
}

URLOpener represents types than can open Registries based on a URL. The opener must not modify the URL argument. OpenURL must be safe to call from multiple goroutines.

This interface is generally implemented by types in driver packages.