client

package
v3.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 13, 2022 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

Package client is an interface for an RPC client

Index

Constants

This section is empty.

Variables

View Source 
var (
	// DefaultBackoff is the default backoff function for retries
	DefaultBackoff = exponentialBackoff
	// DefaultRetry is the default check-for-retry function for retries
	DefaultRetry = RetryOnConnectFailure
	// DefaultRetries is the default number of times a request is tried
	DefaultRetries = 1
	// DefaultRequestTimeout is the default request timeout
	DefaultRequestTimeout = time.Second * 15
	// DefaultPoolSize sets the connection pool size
	DefaultPoolSize = 100
	// DefaultPoolTTL sets the connection pool ttl
	DefaultPoolTTL = time.Minute
)

Functions

func Call 

func Call(ctx context.Context, req Request, rsp interface{}, opts ...CallOption) error

Call performs a request

func LookupRoute 

func LookupRoute(ctx context.Context, req Request, opts CallOptions) ([]string, error)

LookupRoute for a request using the router and then choose one using the selector

func Publish 

func Publish(ctx context.Context, msg Message) error

Publish a message

func RetryAlways 

func RetryAlways(ctx context.Context, req Request, retryCount int, err error) (bool, error)

RetryAlways always retry on error

func RetryNever 

func RetryNever(ctx context.Context, req Request, retryCount int, err error) (bool, error)

RetryNever never retries a request

func RetryOnConnectFailure 

func RetryOnConnectFailure(ctx context.Context, req Request, retryCount int, err error) (bool, error)

RetryOnConnectFailure will return true if "connection refused" is returned

func RetryOnError 

func RetryOnError(ctx context.Context, req Request, retryCount int, err error) (bool, error)

RetryOnError retries a request on a 500 or timeout error

Types

type BackoffFunc 

type BackoffFunc func(ctx context.Context, req Request, attempts int) (time.Duration, error)

type CallFunc 

type CallFunc func(ctx context.Context, addr string, req Request, rsp interface{}, opts CallOptions) error

CallFunc represents the individual call func

type CallOption 

type CallOption func(*CallOptions)

CallOption used by Call or Stream

func WithAddress 

func WithAddress(a ...string) CallOption

WithAddress sets the remote addresses to use rather than using service discovery

func WithAuthToken 

func WithAuthToken() CallOption

WithAuthToken is a CallOption which overrides the authorization header with the services own auth token

func WithBackoff 

func WithBackoff(fn BackoffFunc) CallOption

WithBackoff is a CallOption which overrides that which set in Options.CallOptions

func WithCallWrapper 

func WithCallWrapper(cw ...CallWrapper) CallOption

WithCallWrapper is a CallOption which adds to the existing CallFunc wrappers

func WithDialTimeout 

func WithDialTimeout(d time.Duration) CallOption

WithDialTimeout is a CallOption which overrides that which set in Options.CallOptions

func WithNetwork 

func WithNetwork(n string) CallOption

WithNetwork is a CallOption which sets the network attribute

func WithRequestTimeout 

func WithRequestTimeout(d time.Duration) CallOption

WithRequestTimeout is a CallOption which overrides that which set in Options.CallOptions

func WithRetries 

func WithRetries(i int) CallOption

WithRetries is a CallOption which overrides that which set in Options.CallOptions

func WithRetry 

func WithRetry(fn RetryFunc) CallOption

WithRetry is a CallOption which overrides that which set in Options.CallOptions

func WithRouter 

func WithRouter(r router.Router) CallOption

WithRouter sets the router to use for this call

func WithSelectOptions 

func WithSelectOptions(sops ...selector.SelectOption) CallOption

WithSelectOptions sets the options to pass to the selector for this call

func WithSelector 

func WithSelector(s selector.Selector) CallOption

WithSelector sets the selector to use for this call

func WithStreamTimeout 

func WithStreamTimeout(d time.Duration) CallOption

WithStreamTimeout sets the stream timeout

type CallOptions 

type CallOptions struct {
	// Address of remote hosts
	Address []string
	// Backoff func
	Backoff BackoffFunc
	// Transport Dial Timeout
	DialTimeout time.Duration
	// Number of Call attempts
	Retries int
	// Check if retriable func
	Retry RetryFunc
	// Request/Response timeout
	RequestTimeout time.Duration
	// Router to use for this call
	Router router.Router
	// Selector to use for the call
	Selector selector.Selector
	// SelectOptions to use when selecting a route
	SelectOptions []selector.SelectOption
	// Stream timeout for the stream
	StreamTimeout time.Duration
	// Use the auth token as the authorization header
	AuthToken bool
	// Network to lookup the route within
	Network string

	// Middleware for low level call func
	CallWrappers []CallWrapper

	// Other options for implementations of the interface
	// can be stored in a context
	Context context.Context
}

type CallWrapper 

type CallWrapper func(CallFunc) CallFunc

CallWrapper is a low level wrapper for the CallFunc

type Client 

type Client interface {
	Init(...Option) error
	Options() Options
	NewMessage(topic string, msg interface{}, opts ...MessageOption) Message
	NewRequest(service, endpoint string, req interface{}, reqOpts ...RequestOption) Request
	Call(ctx context.Context, req Request, rsp interface{}, opts ...CallOption) error
	Stream(ctx context.Context, req Request, opts ...CallOption) (Stream, error)
	Publish(ctx context.Context, msg Message, opts ...PublishOption) error
	String() string
}

Client is the interface used to make requests to services. It supports Request/Response via Transport and Publishing via the Broker. It also supports bidirectional streaming of requests. 

var (
	// DefaultClient implementation
	DefaultClient Client
)

type LookupFunc 

type LookupFunc func(context.Context, Request, CallOptions) ([]string, error)

LookupFunc is used to lookup routes for a service

type Message 

type Message interface {
	Topic() string
	Payload() interface{}
	ContentType() string
}

Message is the interface for publishing asynchronously

func NewMessage 

func NewMessage(topic string, msg interface{}) Message

NewMessage returns a message which can be published

type MessageOption 

type MessageOption func(*MessageOptions)

MessageOption used by NewMessage

func WithMessageContentType 

func WithMessageContentType(ct string) MessageOption

type MessageOptions 

type MessageOptions struct {
	ContentType string
}

type Option 

type Option func(*Options)

Option used by the Client

func Backoff 

func Backoff(fn BackoffFunc) Option

Backoff is used to set the backoff function used when retrying Calls

func Broker 

func Broker(b broker.Broker) Option

Broker to be used for pub/sub

func Codec 

func Codec(contentType string, c codec.NewCodec) Option

Codec to be used to encode/decode requests for a given content type

func ContentType 

func ContentType(ct string) Option

Default content type of the client

func DialTimeout 

func DialTimeout(d time.Duration) Option

Transport dial timeout

func Lookup 

func Lookup(l LookupFunc) Option

Lookup sets the lookup function to use for resolving service names

func PoolSize 

func PoolSize(d int) Option

PoolSize sets the connection pool size

func PoolTTL 

func PoolTTL(d time.Duration) Option

PoolTTL sets the connection pool ttl

func Proxy 

func Proxy(addr string) Option

Proxy sets the proxy address

func Registry 

func Registry(r registry.Registry) Option

Registry sets the routers registry

func RequestTimeout 

func RequestTimeout(d time.Duration) Option

The request timeout. Should this be a Call Option?

func Retries 

func Retries(i int) Option

Number of retries when making the request. Should this be a Call Option?

func Retry 

func Retry(fn RetryFunc) Option

Retry sets the retry function to be used when re-trying.

func Router 

func Router(r router.Router) Option

Router is used to lookup routes for a service

func Selector 

func Selector(s selector.Selector) Option

Selector is used to select a route

func StreamTimeout 

func StreamTimeout(d time.Duration) Option

StreamTimeout sets the stream timeout

func Transport 

func Transport(t transport.Transport) Option

Transport to use for communication e.g http, rabbitmq, etc

func Wrap 

func Wrap(w Wrapper) Option

Adds a Wrapper to a list of options passed into the client

func WrapCall 

func WrapCall(cw ...CallWrapper) Option

Adds a Wrapper to the list of CallFunc wrappers

type Options 

type Options struct {
	// Used to select codec
	ContentType string
	// Proxy address to send requests via
	Proxy string

	// Plugged interfaces
	Broker    broker.Broker
	Codecs    map[string]codec.NewCodec
	Router    router.Router
	Selector  selector.Selector
	Transport transport.Transport

	// Lookup used for looking up routes
	Lookup LookupFunc

	// Connection Pool
	PoolSize int
	PoolTTL  time.Duration

	// Middleware for client
	Wrappers []Wrapper

	// Default Call Options
	CallOptions CallOptions

	// Other options for implementations of the interface
	// can be stored in a context
	Context context.Context
}

func NewOptions 

func NewOptions(options ...Option) Options

type PublishOption 

type PublishOption func(*PublishOptions)

PublishOption used by Publish

func PublishContext 

func PublishContext(ctx context.Context) PublishOption

PublishContext sets the context in publish options

func WithExchange 

func WithExchange(e string) PublishOption

WithExchange sets the exchange to route a message through

type PublishOptions 

type PublishOptions struct {
	// Exchange is the routing exchange for the message
	Exchange string
	// Other options for implementations of the interface
	// can be stored in a context
	Context context.Context
}

type Request 

type Request interface {
	// The service to call
	Service() string
	// The action to take
	Method() string
	// The endpoint to invoke
	Endpoint() string
	// The content type
	ContentType() string
	// The unencoded request body
	Body() interface{}
	// Write to the encoded request writer. This is nil before a call is made
	Codec() codec.Writer
	// indicates whether the request will be a streaming one rather than unary
	Stream() bool
}

Request is the interface for a synchronous request used by Call or Stream

func NewRequest 

func NewRequest(service, endpoint string, req interface{}, opts ...RequestOption) Request

NewRequest returns a request can which be executed using Call or Stream

type RequestOption 

type RequestOption func(*RequestOptions)

RequestOption used by NewRequest

func StreamingRequest 

func StreamingRequest() RequestOption

func WithContentType 

func WithContentType(ct string) RequestOption

type RequestOptions 

type RequestOptions struct {
	ContentType string
	Stream      bool

	// Other options for implementations of the interface
	// can be stored in a context
	Context context.Context
}

type Response 

type Response interface {
	// Read the response
	Codec() codec.Reader
	// read the header
	Header() map[string]string
	// Read the undecoded response
	Read() ([]byte, error)
}

Response is the response received from a service

type RetryFunc 

type RetryFunc func(ctx context.Context, req Request, retryCount int, err error) (bool, error)

note that returning either false or a non-nil error will result in the call not being retried

type Stream 

type Stream interface {
	// Context for the stream
	Context() context.Context
	// The request made
	Request() Request
	// The response read
	Response() Response
	// Send will encode and send a request
	Send(interface{}) error
	// Recv will decode and read a response
	Recv(interface{}) error
	// Error returns the stream error
	Error() error
	// Close closes the stream
	Close() error
}

Stream is the interface for a bidirectional synchronous stream

type StreamWrapper 

type StreamWrapper func(Stream) Stream

StreamWrapper wraps a Stream and returns the equivalent

type Wrapper 

type Wrapper func(Client) Client

Wrapper wraps a client and returns a client

Source Files

View all Source files

Directories

Path Synopsis
Package grpc provides a gRPC client
 Package grpc provides a gRPC client
proto
Package mucp provides a transport agnostic RPC client
 Package mucp provides a transport agnostic RPC client

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.