2016-12-14 17:41:48 +02:00
|
|
|
// Package client is an interface for an RPC client
|
2015-01-14 01:31:27 +02:00
|
|
|
package client
|
|
|
|
|
2015-05-21 20:24:57 +02:00
|
|
|
import (
|
2018-03-03 13:53:52 +02:00
|
|
|
"context"
|
2016-01-03 23:14:33 +02:00
|
|
|
"time"
|
2015-05-21 20:24:57 +02:00
|
|
|
)
|
|
|
|
|
2016-01-30 23:15:08 +02:00
|
|
|
// Client is the interface used to make requests to services.
|
|
|
|
// It supports Request/Response via Transport and Publishing via the Broker.
|
|
|
|
// It also supports bidiectional streaming of requests.
|
2015-01-14 01:31:27 +02:00
|
|
|
type Client interface {
|
2016-01-02 21:12:17 +02:00
|
|
|
Init(...Option) error
|
|
|
|
Options() Options
|
2018-05-10 18:33:54 +02:00
|
|
|
NewMessage(topic string, msg interface{}, opts ...MessageOption) Message
|
2015-12-17 22:37:35 +02:00
|
|
|
NewRequest(service, method string, req interface{}, reqOpts ...RequestOption) Request
|
2015-12-08 21:25:42 +02:00
|
|
|
Call(ctx context.Context, req Request, rsp interface{}, opts ...CallOption) error
|
2018-04-14 19:15:09 +02:00
|
|
|
Stream(ctx context.Context, req Request, opts ...CallOption) (Stream, error)
|
2018-04-14 19:06:52 +02:00
|
|
|
Publish(ctx context.Context, msg Message, opts ...PublishOption) error
|
2015-12-19 23:56:14 +02:00
|
|
|
String() string
|
2015-06-12 20:52:27 +02:00
|
|
|
}
|
|
|
|
|
2018-04-14 19:06:52 +02:00
|
|
|
// Message is the interface for publishing asynchronously
|
|
|
|
type Message interface {
|
2015-06-12 20:52:27 +02:00
|
|
|
Topic() string
|
2018-04-14 19:06:52 +02:00
|
|
|
Payload() interface{}
|
2015-06-12 20:52:27 +02:00
|
|
|
ContentType() string
|
|
|
|
}
|
|
|
|
|
2016-04-06 18:53:16 +02:00
|
|
|
// Request is the interface for a synchronous request used by Call or Stream
|
2015-06-12 20:52:27 +02:00
|
|
|
type Request interface {
|
|
|
|
Service() string
|
|
|
|
Method() string
|
|
|
|
ContentType() string
|
|
|
|
Request() interface{}
|
2015-12-17 22:37:35 +02:00
|
|
|
// indicates whether the request will be a streaming one rather than unary
|
|
|
|
Stream() bool
|
2015-06-01 19:55:27 +02:00
|
|
|
}
|
|
|
|
|
2018-04-14 19:15:09 +02:00
|
|
|
// Stream is the inteface for a bidirectional synchronous stream
|
|
|
|
type Stream interface {
|
2015-12-17 22:37:35 +02:00
|
|
|
Context() context.Context
|
2015-06-01 19:55:27 +02:00
|
|
|
Request() Request
|
2015-12-17 22:37:35 +02:00
|
|
|
Send(interface{}) error
|
|
|
|
Recv(interface{}) error
|
2015-06-01 19:55:27 +02:00
|
|
|
Error() error
|
|
|
|
Close() error
|
2015-01-14 01:31:27 +02:00
|
|
|
}
|
|
|
|
|
2016-04-06 18:53:16 +02:00
|
|
|
// Option used by the Client
|
2015-12-31 20:11:46 +02:00
|
|
|
type Option func(*Options)
|
2016-04-06 18:53:16 +02:00
|
|
|
|
|
|
|
// CallOption used by Call or Stream
|
2015-12-31 20:11:46 +02:00
|
|
|
type CallOption func(*CallOptions)
|
2016-04-06 18:53:16 +02:00
|
|
|
|
|
|
|
// PublishOption used by Publish
|
2015-12-31 20:11:46 +02:00
|
|
|
type PublishOption func(*PublishOptions)
|
2016-04-06 18:53:16 +02:00
|
|
|
|
2018-05-10 18:33:54 +02:00
|
|
|
// MessageOption used by NewMessage
|
|
|
|
type MessageOption func(*MessageOptions)
|
|
|
|
|
2016-04-06 18:53:16 +02:00
|
|
|
// RequestOption used by NewRequest
|
2015-12-31 20:11:46 +02:00
|
|
|
type RequestOption func(*RequestOptions)
|
2015-05-21 20:24:57 +02:00
|
|
|
|
2015-01-14 01:31:27 +02:00
|
|
|
var (
|
2016-04-06 18:53:16 +02:00
|
|
|
// DefaultClient is a default client to use out of the box
|
2015-05-23 18:40:53 +02:00
|
|
|
DefaultClient Client = newRpcClient()
|
2016-04-06 18:53:16 +02:00
|
|
|
// DefaultBackoff is the default backoff function for retries
|
|
|
|
DefaultBackoff = exponentialBackoff
|
2016-11-07 10:40:11 +02:00
|
|
|
// DefaultRetry is the default check-for-retry function for retries
|
2018-07-22 18:41:58 +02:00
|
|
|
DefaultRetry = RetryOnError
|
2016-04-06 18:53:16 +02:00
|
|
|
// DefaultRetries is the default number of times a request is tried
|
|
|
|
DefaultRetries = 1
|
|
|
|
// DefaultRequestTimeout is the default request timeout
|
2016-01-03 23:14:33 +02:00
|
|
|
DefaultRequestTimeout = time.Second * 5
|
2016-06-07 01:46:14 +02:00
|
|
|
// DefaultPoolSize sets the connection pool size
|
2018-05-26 10:10:29 +02:00
|
|
|
DefaultPoolSize = 1
|
2016-06-07 01:46:14 +02:00
|
|
|
// DefaultPoolTTL sets the connection pool ttl
|
|
|
|
DefaultPoolTTL = time.Minute
|
2015-01-14 01:31:27 +02:00
|
|
|
)
|
|
|
|
|
2018-04-17 12:00:22 +02:00
|
|
|
// Makes a synchronous call to a service using the default client
|
|
|
|
func Call(ctx context.Context, request Request, response interface{}, opts ...CallOption) error {
|
|
|
|
return DefaultClient.Call(ctx, request, response, opts...)
|
|
|
|
}
|
|
|
|
|
|
|
|
// Publishes a publication using the default client. Using the underlying broker
|
|
|
|
// set within the options.
|
2018-05-10 18:33:54 +02:00
|
|
|
func Publish(ctx context.Context, msg Message, opts ...PublishOption) error {
|
|
|
|
return DefaultClient.Publish(ctx, msg, opts...)
|
2018-04-17 12:00:22 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
// Creates a new message using the default client
|
2018-05-10 18:33:54 +02:00
|
|
|
func NewMessage(topic string, payload interface{}, opts ...MessageOption) Message {
|
|
|
|
return DefaultClient.NewMessage(topic, payload, opts...)
|
2018-04-17 12:00:22 +02:00
|
|
|
}
|
|
|
|
|
2015-11-26 14:21:00 +02:00
|
|
|
// Creates a new client with the options passed in
|
2015-05-23 21:04:16 +02:00
|
|
|
func NewClient(opt ...Option) Client {
|
2015-05-23 18:40:53 +02:00
|
|
|
return newRpcClient(opt...)
|
|
|
|
}
|
2018-04-17 12:00:22 +02:00
|
|
|
|
|
|
|
// Creates a new request using the default client. Content Type will
|
|
|
|
// be set to the default within options and use the appropriate codec
|
|
|
|
func NewRequest(service, method string, request interface{}, reqOpts ...RequestOption) Request {
|
|
|
|
return DefaultClient.NewRequest(service, method, request, reqOpts...)
|
|
|
|
}
|
|
|
|
|
|
|
|
// Creates a streaming connection with a service and returns responses on the
|
|
|
|
// channel passed in. It's up to the user to close the streamer.
|
|
|
|
func NewStream(ctx context.Context, request Request, opts ...CallOption) (Stream, error) {
|
|
|
|
return DefaultClient.Stream(ctx, request, opts...)
|
|
|
|
}
|
|
|
|
|
|
|
|
func String() string {
|
|
|
|
return DefaultClient.String()
|
|
|
|
}
|