mqs

package

v0.3.688 Latest Latest Go to latest Published: Apr 5, 2019 License: Apache-2.0 Imports: 6 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/fnproject/fn

Links

Open Source Insights

Documentation ¶

Index ¶

func AddProvider(p Provider)
func New(mqURL string) (models.MessageQueue, error)
type Mock
type Provider

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AddProvider ¶

func AddProvider(p Provider)

AddProvider registers a new global message queue provider

func New ¶

func New(mqURL string) (models.MessageQueue, error)

New will parse the URL and return the correct MQ implementation.

Types ¶

type Mock ¶

type Mock struct {
	FakeApp *models.App
	Apps    []*models.App
}

func (*Mock) Close ¶

func (mock *Mock) Close() error

func (*Mock) Delete ¶

func (mock *Mock) Delete(context.Context, *models.Call) error

func (*Mock) Push ¶

func (mock *Mock) Push(context.Context, *models.Call) (*models.Call, error)

func (*Mock) Reserve ¶

func (mock *Mock) Reserve(context.Context) (*models.Call, error)

type Provider ¶

type Provider interface {
	fmt.Stringer
	//Supports indicates if this provider can handle a specific URL scheme
	Supports(url *url.URL) bool
	//New creates a new message queue from a given URL
	New(url *url.URL) (models.MessageQueue, error)
}

Provider for message queue extensions

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
bolt
memory
redis

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL