watermill

package
v0.0.0-...-a671794 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 22, 2020 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewPubSub

func NewPubSub(logger logur.Logger) (message.Publisher, message.Subscriber)

NewPubSub returns a new PubSub.

func NewRouter

func NewRouter(config RouterConfig, logger logur.Logger) (*message.Router, error)

NewRouter returns a new message router for message subscription logic.

Types

type RouterConfig

type RouterConfig struct {
	CloseTimeout time.Duration
}

RouterConfig holds information for configuring Watermill router.

Jump to

Keyboard shortcuts

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