broker

package

v0.1.0 Latest Latest Go to latest Published: Jul 6, 2020 License: MIT Imports: 4 Imported by: 0

Details

View Source

const (
	DefaultName = "mkit.broker.default"
)

This section is empty.

This section is empty.

type Broker interface {
	CeClient() cloudevents.Client
	Options() Options
}

func NewBroker(opts ...Option) Broker

NewService creates and returns a new Service based on the packages within.

type Option func(*Options)

func Context(ctx context.Context) Option

Context specifies a context for the service. Can be used to signal shutdown of the service Can be used for extra option values.

func Name(n string) Option

Name of the service

func WithEndpoint(endpoint string) Option

type Options struct {
	Name string

	Endpoint string

	// Alternative options
	Context context.Context
}

Path	Synopsis
cloudevents module
pubsub module