endpoints

Documentation

Index

• func Transporters(ctx *broker.Context, endpoints specs.EndpointList, ...) (transport.EndpointList, error)
• type EndpointOption
  • func WithCore(conf semaphore.Options) EndpointOption
  • func WithFunctions(stack functions.Collection) EndpointOption
  • func WithServiceDiscoveries(discoveries specs.ServiceDiscoveryClients) EndpointOption
  • func WithServices(services specs.ServiceList) EndpointOption
• type ErrUnknownService
  • func (e ErrUnknownService) Error() string
  • func (e ErrUnknownService) Prettify() prettyerr.Error
• type Options
  • func NewOptions(opts ...EndpointOption) Options

Functions

func Transporters

func Transporters(ctx *broker.Context, endpoints specs.EndpointList, flows specs.FlowListInterface, opts ...EndpointOption) (transport.EndpointList, error)

Transporters constructs a new transport Endpoints list from the given endpoints and options

Types

type EndpointOption

type EndpointOption func(*Options)

EndpointOption applies the given options to the apply options object.

func WithCore

func WithCore(conf semaphore.Options) EndpointOption

WithCore sets the given core options

func WithFunctions

func WithFunctions(stack functions.Collection) EndpointOption

WithFunctions sets the given functions

func WithServiceDiscoveries

func WithServiceDiscoveries(discoveries specs.ServiceDiscoveryClients) EndpointOption

WithServiceDiscoveries sets the given discovery clients

func WithServices

func WithServices(services specs.ServiceList) EndpointOption

WithServices sets the given services

type ErrUnknownService

type ErrUnknownService struct {
	Service string
}

ErrUnknownService occurs when there is no defined service for the requested method

func (ErrUnknownService) Error

func (e ErrUnknownService) Error() string

func (ErrUnknownService) Prettify

func (e ErrUnknownService) Prettify() prettyerr.Error

Prettify returns the prettified version of the given error

type Options

type Options struct {
	semaphore.Options
	// contains filtered or unexported fields
}

Options represents a collection of options which are used construct and endpoints.

func NewOptions

func NewOptions(opts ...EndpointOption) Options

NewOptions constructs a new endpoint option object from the passed options