2015-06-12 19:52:27 +01:00
|
|
|
package client
|
|
|
|
|
|
|
|
import (
|
2018-03-03 11:53:52 +00:00
|
|
|
"context"
|
2016-01-03 21:14:33 +00:00
|
|
|
"time"
|
|
|
|
|
2020-08-19 17:47:17 +03:00
|
|
|
"github.com/unistack-org/micro/v3/broker"
|
|
|
|
"github.com/unistack-org/micro/v3/codec"
|
|
|
|
"github.com/unistack-org/micro/v3/registry"
|
|
|
|
"github.com/unistack-org/micro/v3/router"
|
|
|
|
"github.com/unistack-org/micro/v3/selector"
|
|
|
|
"github.com/unistack-org/micro/v3/selector/random"
|
|
|
|
"github.com/unistack-org/micro/v3/transport"
|
2015-06-12 19:52:27 +01:00
|
|
|
)
|
|
|
|
|
2015-12-31 18:11:46 +00:00
|
|
|
type Options struct {
|
2016-04-05 18:07:07 +01:00
|
|
|
// Used to select codec
|
|
|
|
ContentType string
|
2020-07-30 15:22:36 +01:00
|
|
|
// Proxy address to send requests via
|
|
|
|
Proxy string
|
2016-04-05 18:07:07 +01:00
|
|
|
|
|
|
|
// Plugged interfaces
|
|
|
|
Broker broker.Broker
|
|
|
|
Codecs map[string]codec.NewCodec
|
2020-07-01 17:06:59 +01:00
|
|
|
Router router.Router
|
2016-04-05 18:07:07 +01:00
|
|
|
Selector selector.Selector
|
|
|
|
Transport transport.Transport
|
|
|
|
|
2020-08-17 22:44:45 +01:00
|
|
|
// Lookup used for looking up routes
|
|
|
|
Lookup LookupFunc
|
|
|
|
|
2016-06-07 00:46:14 +01:00
|
|
|
// Connection Pool
|
|
|
|
PoolSize int
|
|
|
|
PoolTTL time.Duration
|
|
|
|
|
2020-05-22 16:52:24 +01:00
|
|
|
// Response cache
|
|
|
|
Cache *Cache
|
|
|
|
|
2016-04-05 18:07:07 +01:00
|
|
|
// Middleware for client
|
|
|
|
Wrappers []Wrapper
|
|
|
|
|
|
|
|
// Default Call Options
|
|
|
|
CallOptions CallOptions
|
2015-12-31 18:11:46 +00:00
|
|
|
|
2016-01-06 16:25:12 +00:00
|
|
|
// Other options for implementations of the interface
|
|
|
|
// can be stored in a context
|
|
|
|
Context context.Context
|
2015-06-12 19:52:27 +01:00
|
|
|
}
|
|
|
|
|
2015-12-31 18:11:46 +00:00
|
|
|
type CallOptions struct {
|
2019-06-26 20:51:13 +01:00
|
|
|
// Address of remote hosts
|
|
|
|
Address []string
|
2016-04-05 20:04:37 +01:00
|
|
|
// Backoff func
|
|
|
|
Backoff BackoffFunc
|
2020-07-01 17:06:59 +01:00
|
|
|
// Duration to cache the response for
|
|
|
|
CacheExpiry time.Duration
|
2016-04-05 18:07:07 +01:00
|
|
|
// Transport Dial Timeout
|
|
|
|
DialTimeout time.Duration
|
|
|
|
// Number of Call attempts
|
|
|
|
Retries int
|
2020-07-01 17:06:59 +01:00
|
|
|
// Check if retriable func
|
|
|
|
Retry RetryFunc
|
2016-04-05 18:07:07 +01:00
|
|
|
// Request/Response timeout
|
|
|
|
RequestTimeout time.Duration
|
2020-07-01 17:06:59 +01:00
|
|
|
// Router to use for this call
|
|
|
|
Router router.Router
|
|
|
|
// Selector to use for the call
|
|
|
|
Selector selector.Selector
|
2020-07-02 17:03:08 +01:00
|
|
|
// SelectOptions to use when selecting a route
|
|
|
|
SelectOptions []selector.SelectOption
|
2020-03-31 23:22:11 +01:00
|
|
|
// Stream timeout for the stream
|
|
|
|
StreamTimeout time.Duration
|
2020-07-31 11:36:33 +01:00
|
|
|
// Use the auth token as the authorization header
|
|
|
|
AuthToken bool
|
2020-06-30 10:07:52 +01:00
|
|
|
// Network to lookup the route within
|
|
|
|
Network string
|
2016-04-05 18:07:07 +01:00
|
|
|
|
2016-11-07 17:49:35 +00:00
|
|
|
// Middleware for low level call func
|
2016-11-07 17:58:34 +00:00
|
|
|
CallWrappers []CallWrapper
|
2016-11-07 17:49:35 +00:00
|
|
|
|
2016-01-06 16:25:12 +00:00
|
|
|
// Other options for implementations of the interface
|
|
|
|
// can be stored in a context
|
|
|
|
Context context.Context
|
2015-12-31 18:11:46 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
type PublishOptions struct {
|
2019-02-23 10:50:53 +00:00
|
|
|
// Exchange is the routing exchange for the message
|
|
|
|
Exchange string
|
2016-01-06 16:25:12 +00:00
|
|
|
// Other options for implementations of the interface
|
|
|
|
// can be stored in a context
|
|
|
|
Context context.Context
|
2015-12-09 00:02:45 +00:00
|
|
|
}
|
2015-12-08 19:25:42 +00:00
|
|
|
|
2018-05-10 17:33:54 +01:00
|
|
|
type MessageOptions struct {
|
|
|
|
ContentType string
|
|
|
|
}
|
|
|
|
|
2015-12-31 18:11:46 +00:00
|
|
|
type RequestOptions struct {
|
2018-04-14 18:06:52 +01:00
|
|
|
ContentType string
|
|
|
|
Stream bool
|
2015-12-08 19:25:42 +00:00
|
|
|
|
2016-01-06 16:25:12 +00:00
|
|
|
// Other options for implementations of the interface
|
|
|
|
// can be stored in a context
|
|
|
|
Context context.Context
|
2015-12-17 20:37:35 +00:00
|
|
|
}
|
|
|
|
|
2019-12-29 21:07:55 +00:00
|
|
|
func NewOptions(options ...Option) Options {
|
2016-01-02 23:16:15 +00:00
|
|
|
opts := Options{
|
2020-05-22 16:52:24 +01:00
|
|
|
Cache: NewCache(),
|
2019-12-29 21:07:55 +00:00
|
|
|
Context: context.Background(),
|
2020-07-27 13:22:00 +01:00
|
|
|
ContentType: "application/protobuf",
|
2019-12-29 21:07:55 +00:00
|
|
|
Codecs: make(map[string]codec.NewCodec),
|
2016-04-05 18:07:07 +01:00
|
|
|
CallOptions: CallOptions{
|
2016-11-07 17:46:12 +01:00
|
|
|
Backoff: DefaultBackoff,
|
|
|
|
Retry: DefaultRetry,
|
|
|
|
Retries: DefaultRetries,
|
|
|
|
RequestTimeout: DefaultRequestTimeout,
|
|
|
|
DialTimeout: transport.DefaultDialTimeout,
|
2016-04-05 18:07:07 +01:00
|
|
|
},
|
2020-08-25 13:44:41 +03:00
|
|
|
Lookup: LookupRoute,
|
|
|
|
PoolSize: DefaultPoolSize,
|
|
|
|
PoolTTL: DefaultPoolTTL,
|
|
|
|
Selector: random.NewSelector(),
|
2016-01-02 23:16:15 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
for _, o := range options {
|
|
|
|
o(&opts)
|
|
|
|
}
|
|
|
|
|
|
|
|
return opts
|
|
|
|
}
|
|
|
|
|
2015-11-26 12:51:53 +00:00
|
|
|
// Broker to be used for pub/sub
|
2015-06-12 19:52:27 +01:00
|
|
|
func Broker(b broker.Broker) Option {
|
2015-12-31 18:11:46 +00:00
|
|
|
return func(o *Options) {
|
|
|
|
o.Broker = b
|
2015-06-12 19:52:27 +01:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2015-11-26 12:51:53 +00:00
|
|
|
// Codec to be used to encode/decode requests for a given content type
|
2015-11-28 11:22:29 +00:00
|
|
|
func Codec(contentType string, c codec.NewCodec) Option {
|
2015-12-31 18:11:46 +00:00
|
|
|
return func(o *Options) {
|
|
|
|
o.Codecs[contentType] = c
|
2015-11-25 19:50:05 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2015-11-26 12:51:53 +00:00
|
|
|
// Default content type of the client
|
2015-11-25 19:50:05 +00:00
|
|
|
func ContentType(ct string) Option {
|
2015-12-31 18:11:46 +00:00
|
|
|
return func(o *Options) {
|
|
|
|
o.ContentType = ct
|
2015-11-25 19:50:05 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-07-30 15:22:36 +01:00
|
|
|
// Proxy sets the proxy address
|
|
|
|
func Proxy(addr string) Option {
|
|
|
|
return func(o *Options) {
|
|
|
|
o.Proxy = addr
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2016-06-07 00:46:14 +01:00
|
|
|
// PoolSize sets the connection pool size
|
|
|
|
func PoolSize(d int) Option {
|
|
|
|
return func(o *Options) {
|
|
|
|
o.PoolSize = d
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2019-12-15 15:05:19 +08:00
|
|
|
// PoolTTL sets the connection pool ttl
|
2016-06-07 00:46:14 +01:00
|
|
|
func PoolTTL(d time.Duration) Option {
|
|
|
|
return func(o *Options) {
|
|
|
|
o.PoolTTL = d
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-07-01 17:06:59 +01:00
|
|
|
// Transport to use for communication e.g http, rabbitmq, etc
|
|
|
|
func Transport(t transport.Transport) Option {
|
2015-12-31 18:11:46 +00:00
|
|
|
return func(o *Options) {
|
2020-07-01 17:06:59 +01:00
|
|
|
o.Transport = t
|
2015-06-12 19:52:27 +01:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-08-17 22:53:20 +01:00
|
|
|
// Registry sets the routers registry
|
|
|
|
func Registry(r registry.Registry) Option {
|
|
|
|
return func(o *Options) {
|
|
|
|
o.Router.Init(router.Registry(r))
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-07-01 17:06:59 +01:00
|
|
|
// Router is used to lookup routes for a service
|
|
|
|
func Router(r router.Router) Option {
|
2015-12-31 18:11:46 +00:00
|
|
|
return func(o *Options) {
|
2020-07-01 17:06:59 +01:00
|
|
|
o.Router = r
|
2015-06-12 19:52:27 +01:00
|
|
|
}
|
|
|
|
}
|
2015-11-26 20:36:42 +00:00
|
|
|
|
2020-07-01 17:06:59 +01:00
|
|
|
// Selector is used to select a route
|
2015-12-09 19:23:16 +00:00
|
|
|
func Selector(s selector.Selector) Option {
|
2015-12-31 18:11:46 +00:00
|
|
|
return func(o *Options) {
|
|
|
|
o.Selector = s
|
2015-12-07 21:09:10 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2015-11-26 20:36:42 +00:00
|
|
|
// Adds a Wrapper to a list of options passed into the client
|
|
|
|
func Wrap(w Wrapper) Option {
|
2015-12-31 18:11:46 +00:00
|
|
|
return func(o *Options) {
|
|
|
|
o.Wrappers = append(o.Wrappers, w)
|
2015-11-26 20:36:42 +00:00
|
|
|
}
|
|
|
|
}
|
2015-12-09 00:02:45 +00:00
|
|
|
|
2016-11-07 17:49:35 +00:00
|
|
|
// Adds a Wrapper to the list of CallFunc wrappers
|
2016-11-07 18:06:15 +00:00
|
|
|
func WrapCall(cw ...CallWrapper) Option {
|
2016-11-07 17:49:35 +00:00
|
|
|
return func(o *Options) {
|
2016-11-07 17:58:34 +00:00
|
|
|
o.CallOptions.CallWrappers = append(o.CallOptions.CallWrappers, cw...)
|
2016-11-07 17:49:35 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2016-04-05 20:04:37 +01:00
|
|
|
// Backoff is used to set the backoff function used
|
|
|
|
// when retrying Calls
|
|
|
|
func Backoff(fn BackoffFunc) Option {
|
|
|
|
return func(o *Options) {
|
|
|
|
o.CallOptions.Backoff = fn
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-08-17 22:44:45 +01:00
|
|
|
// Lookup sets the lookup function to use for resolving service names
|
|
|
|
func Lookup(l LookupFunc) Option {
|
|
|
|
return func(o *Options) {
|
|
|
|
o.Lookup = l
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2016-01-03 21:14:33 +00:00
|
|
|
// Number of retries when making the request.
|
|
|
|
// Should this be a Call Option?
|
2016-01-02 23:16:15 +00:00
|
|
|
func Retries(i int) Option {
|
|
|
|
return func(o *Options) {
|
2016-04-05 18:07:07 +01:00
|
|
|
o.CallOptions.Retries = i
|
2016-01-02 23:16:15 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2017-04-12 16:47:40 -04:00
|
|
|
// Retry sets the retry function to be used when re-trying.
|
|
|
|
func Retry(fn RetryFunc) Option {
|
|
|
|
return func(o *Options) {
|
|
|
|
o.CallOptions.Retry = fn
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2016-01-03 21:14:33 +00:00
|
|
|
// The request timeout.
|
|
|
|
// Should this be a Call Option?
|
|
|
|
func RequestTimeout(d time.Duration) Option {
|
|
|
|
return func(o *Options) {
|
2016-04-05 18:07:07 +01:00
|
|
|
o.CallOptions.RequestTimeout = d
|
2016-01-03 21:14:33 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-03-31 23:22:11 +01:00
|
|
|
// StreamTimeout sets the stream timeout
|
|
|
|
func StreamTimeout(d time.Duration) Option {
|
|
|
|
return func(o *Options) {
|
|
|
|
o.CallOptions.StreamTimeout = d
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2016-01-03 21:25:03 +00:00
|
|
|
// Transport dial timeout
|
|
|
|
func DialTimeout(d time.Duration) Option {
|
|
|
|
return func(o *Options) {
|
2016-04-05 18:07:07 +01:00
|
|
|
o.CallOptions.DialTimeout = d
|
2016-01-03 21:25:03 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2015-12-09 00:02:45 +00:00
|
|
|
// Call Options
|
|
|
|
|
2019-02-23 10:50:53 +00:00
|
|
|
// WithExchange sets the exchange to route a message through
|
|
|
|
func WithExchange(e string) PublishOption {
|
|
|
|
return func(o *PublishOptions) {
|
|
|
|
o.Exchange = e
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-04-28 19:03:37 +03:00
|
|
|
// PublishContext sets the context in publish options
|
|
|
|
func PublishContext(ctx context.Context) PublishOption {
|
|
|
|
return func(o *PublishOptions) {
|
|
|
|
o.Context = ctx
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2019-06-26 20:51:13 +01:00
|
|
|
// WithAddress sets the remote addresses to use rather than using service discovery
|
|
|
|
func WithAddress(a ...string) CallOption {
|
2018-04-14 16:16:58 +01:00
|
|
|
return func(o *CallOptions) {
|
|
|
|
o.Address = a
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2016-11-07 17:58:34 +00:00
|
|
|
// WithCallWrapper is a CallOption which adds to the existing CallFunc wrappers
|
|
|
|
func WithCallWrapper(cw ...CallWrapper) CallOption {
|
2016-11-07 17:49:35 +00:00
|
|
|
return func(o *CallOptions) {
|
2016-11-07 17:58:34 +00:00
|
|
|
o.CallWrappers = append(o.CallWrappers, cw...)
|
2016-11-07 17:49:35 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2016-04-05 20:04:37 +01:00
|
|
|
// WithBackoff is a CallOption which overrides that which
|
|
|
|
// set in Options.CallOptions
|
|
|
|
func WithBackoff(fn BackoffFunc) CallOption {
|
|
|
|
return func(o *CallOptions) {
|
|
|
|
o.Backoff = fn
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2016-11-07 09:40:11 +01:00
|
|
|
// WithRetry is a CallOption which overrides that which
|
2016-11-03 10:45:31 +01:00
|
|
|
// set in Options.CallOptions
|
2016-11-07 09:40:11 +01:00
|
|
|
func WithRetry(fn RetryFunc) CallOption {
|
2016-11-03 10:45:31 +01:00
|
|
|
return func(o *CallOptions) {
|
2016-11-07 09:40:11 +01:00
|
|
|
o.Retry = fn
|
2016-11-03 10:45:31 +01:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2016-04-05 18:07:07 +01:00
|
|
|
// WithRetries is a CallOption which overrides that which
|
|
|
|
// set in Options.CallOptions
|
|
|
|
func WithRetries(i int) CallOption {
|
|
|
|
return func(o *CallOptions) {
|
|
|
|
o.Retries = i
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// WithRequestTimeout is a CallOption which overrides that which
|
|
|
|
// set in Options.CallOptions
|
|
|
|
func WithRequestTimeout(d time.Duration) CallOption {
|
|
|
|
return func(o *CallOptions) {
|
|
|
|
o.RequestTimeout = d
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-03-31 23:22:11 +01:00
|
|
|
// WithStreamTimeout sets the stream timeout
|
|
|
|
func WithStreamTimeout(d time.Duration) CallOption {
|
|
|
|
return func(o *CallOptions) {
|
|
|
|
o.StreamTimeout = d
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2016-04-05 18:07:07 +01:00
|
|
|
// WithDialTimeout is a CallOption which overrides that which
|
|
|
|
// set in Options.CallOptions
|
|
|
|
func WithDialTimeout(d time.Duration) CallOption {
|
|
|
|
return func(o *CallOptions) {
|
|
|
|
o.DialTimeout = d
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-07-31 11:36:33 +01:00
|
|
|
// WithAuthToken is a CallOption which overrides the
|
2020-03-31 12:44:34 +01:00
|
|
|
// authorization header with the services own auth token
|
2020-07-31 11:36:33 +01:00
|
|
|
func WithAuthToken() CallOption {
|
2020-03-31 12:44:34 +01:00
|
|
|
return func(o *CallOptions) {
|
2020-07-31 11:36:33 +01:00
|
|
|
o.AuthToken = true
|
2020-03-31 12:44:34 +01:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-05-22 16:52:24 +01:00
|
|
|
// WithCache is a CallOption which sets the duration the response
|
|
|
|
// shoull be cached for
|
|
|
|
func WithCache(c time.Duration) CallOption {
|
|
|
|
return func(o *CallOptions) {
|
|
|
|
o.CacheExpiry = c
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-06-30 10:07:52 +01:00
|
|
|
// WithNetwork is a CallOption which sets the network attribute
|
|
|
|
func WithNetwork(n string) CallOption {
|
|
|
|
return func(o *CallOptions) {
|
|
|
|
o.Network = n
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-07-01 17:06:59 +01:00
|
|
|
// WithRouter sets the router to use for this call
|
|
|
|
func WithRouter(r router.Router) CallOption {
|
|
|
|
return func(o *CallOptions) {
|
|
|
|
o.Router = r
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// WithSelector sets the selector to use for this call
|
|
|
|
func WithSelector(s selector.Selector) CallOption {
|
|
|
|
return func(o *CallOptions) {
|
|
|
|
o.Selector = s
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-07-02 17:03:08 +01:00
|
|
|
// WithSelectOptions sets the options to pass to the selector for this call
|
|
|
|
func WithSelectOptions(sops ...selector.SelectOption) CallOption {
|
|
|
|
return func(o *CallOptions) {
|
|
|
|
o.SelectOptions = sops
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2020-02-18 14:18:59 +03:00
|
|
|
func WithMessageContentType(ct string) MessageOption {
|
|
|
|
return func(o *MessageOptions) {
|
|
|
|
o.ContentType = ct
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2015-12-17 20:37:35 +00:00
|
|
|
// Request Options
|
|
|
|
|
2018-04-14 18:06:52 +01:00
|
|
|
func WithContentType(ct string) RequestOption {
|
|
|
|
return func(o *RequestOptions) {
|
|
|
|
o.ContentType = ct
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2015-12-17 20:37:35 +00:00
|
|
|
func StreamingRequest() RequestOption {
|
2015-12-31 18:11:46 +00:00
|
|
|
return func(o *RequestOptions) {
|
|
|
|
o.Stream = true
|
2015-12-17 20:37:35 +00:00
|
|
|
}
|
|
|
|
}
|