discovery

Jun 17, 2020

Changes in this version

type Discover

+ func (d *Discover) Discover(addr string) (*types.Service, error)

Dec 9, 2019

Changes in this version

type AutomateAdapter

+ ExecuteWithOpts func(service *types.Service, request types.Request, opts types.Options) (*types.Response, error)

type Discover

+ func (d *Discover) AutomateWithOpts(signature string, request types.Request, opts types.Options) (*types.Response, error)

+ func (d *Discover) CallWithOpts(service types.ServiceRequest, opts types.Options) (*types.Response, error)

+ func (d *Discover) ListenWithOpts(signature string, opts types.Options) (<-chan *types.Response, error)

+ func (d *Discover) PublishWithOpts(signature string, request types.Request, opts types.Options) error

+ func (d *Discover) QueueWithOpts(signature string, request types.Request, opts types.Options) (string, error)

+ func (d *Discover) RequestWithOpts(signature string, request types.Request, opts types.Options) (*types.Response, error)

+ func (d *Discover) SubscribeWithOpts(signature string, opts types.Options) (<-chan *types.Response, error)

type FunctionAdapter

+ CallWithOpts func(service *types.Service, request types.Request, opts types.Options) (*types.Response, error)

type Option

+ func WithAWSBackend() Option

type PubsubAdapter

+ PublishWithOpts func(service *types.Service, request types.Request, opts types.Options) error

+ SubscribeWithOpts func(service *types.Service, opts types.Options) (<-chan *types.Response, error)

type QueueAdapter

+ ListenWithOpts func(service *types.Service, opts types.Options) (<-chan *types.Response, error)

+ QueueWithOpts func(service *types.Service, request types.Request, opts types.Options) (string, error)

Oct 11, 2019

Changes in this version

+ type AutomateAdapter interface

+ Execute func(service *types.Service, request types.Request, opts types.Options) (*types.Response, error)

+ type Discover struct

+ func NewDiscovery(opts ...Option) *Discover

+ func (d *Discover) Automate(signature string, request types.Request, opts types.Options) (*types.Response, error)

+ func (d *Discover) Call(service types.ServiceRequest, opts types.Options) (*types.Response, error)

+ func (d *Discover) Listen(signature string, opts types.Options) (<-chan *types.Response, error)

+ func (d *Discover) Publish(signature string, request types.Request, opts types.Options) error

+ func (d *Discover) Queue(signature string, request types.Request, opts types.Options) (string, error)

+ func (d *Discover) Request(signature string, request types.Request, opts types.Options) (*types.Response, error)

+ func (d *Discover) Subscribe(signature string, opts types.Options) (<-chan *types.Response, error)

+ type FunctionAdapter interface

+ Call func(service *types.Service, request types.Request, opts types.Options) (*types.Response, error)

+ type Locator interface

+ Discover func(signature *types.Signature) (*types.Service, error)

+ type LogAdapter interface

+ Log func(service *types.Service, message string)

+ type Option func(*Options)

+ func SetAutomate(automateAdapter AutomateAdapter) Option

+ func SetFunction(functionAdapter FunctionAdapter) Option

+ func SetLocator(locator Locator) Option

+ func SetLogger(logger LogAdapter) Option

+ func SetPubsub(pubsubAdapter PubsubAdapter) Option

+ func SetQueue(queueAdapter QueueAdapter) Option

+ func SetTracer(tracer TraceAdapter) Option

+ type Options struct

+ type PubsubAdapter interface

+ Publish func(service *types.Service, request types.Request, opts types.Options) error

+ Subscribe func(service *types.Service, opts types.Options) (<-chan *types.Response, error)

+ type QueueAdapter interface

+ Listen func(service *types.Service, opts types.Options) (<-chan *types.Response, error)

+ Queue func(service *types.Service, request types.Request, opts types.Options) (string, error)

+ type TraceAdapter interface

+ Trace func(service *types.Service)