Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

client

package

Go to main page

Versions in this module

v2

v2.9.5

Oct 21, 2020

v2.9.4

Oct 21, 2020

v2.9.3

Oct 21, 2020

v2.9.2

Oct 21, 2020

Changes in this version

+ var DefaultBackoff = exponentialBackoff

+ var DefaultClient Client = newRpcClient()

+ var DefaultCodecs = map[string]codec.NewCodec

+ var DefaultContentType = "application/protobuf"

+ var DefaultPoolSize = 100

+ var DefaultPoolTTL = time.Minute

+ var DefaultRequestTimeout = time.Second * 5

+ var DefaultRetries = 1

+ var DefaultRetry = RetryOnError

+ var NewClient func(...Option) Client = newRpcClient

+ func Call(ctx context.Context, request Request, response interface{}, opts ...CallOption) error

+ func LookupRoute(req Request, opts CallOptions) (*router.Route, error)

+ func NewContext(ctx context.Context, c Client) context.Context

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

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

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

+ func String() string

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

+ type Cache struct

+ func NewCache() *Cache

+ func (c *Cache) Get(ctx context.Context, req *Request) (interface{}, bool)

+ func (c *Cache) List() map[string]string

+ func (c *Cache) Set(ctx context.Context, req *Request, rsp interface{}, expiry time.Duration)

+ type CallFunc func(ctx context.Context, node *registry.Node, req Request, rsp interface{}, ...) error

+ type CallOption func(*CallOptions)

+ func WithAddress(a ...string) CallOption

+ func WithBackoff(fn BackoffFunc) CallOption

+ func WithCache(c time.Duration) CallOption

+ func WithCallWrapper(cw ...CallWrapper) CallOption

+ func WithDialTimeout(d time.Duration) CallOption

+ func WithNetwork(n string) CallOption

+ func WithRequestTimeout(d time.Duration) CallOption

+ func WithRetries(i int) CallOption

+ func WithRetry(fn RetryFunc) CallOption

+ func WithRouter(r router.Router) CallOption

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

+ func WithSelector(s selector.Selector) CallOption

+ func WithServiceToken() CallOption

+ func WithStreamTimeout(d time.Duration) CallOption

+ type CallOptions struct

+ Address []string

+ Backoff BackoffFunc

+ CacheExpiry time.Duration

+ CallWrappers []CallWrapper

+ Context context.Context

+ DialTimeout time.Duration

+ Network string

+ RequestTimeout time.Duration

+ Retries int

+ Retry RetryFunc

+ Router router.Router

+ SelectOptions []selector.SelectOption

+ Selector selector.Selector

+ ServiceToken bool

+ StreamTimeout time.Duration

+ type CallWrapper func(CallFunc) CallFunc

+ type Client interface

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

+ Init func(...Option) error

+ NewMessage func(topic string, msg interface{}, opts ...MessageOption) Message

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

+ Options func() Options

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

+ Stream func(ctx context.Context, req Request, opts ...CallOption) (Stream, error)

+ String func() string

+ func FromContext(ctx context.Context) (Client, bool)

+ type Message interface

+ ContentType func() string

+ Payload func() interface{}

+ Topic func() string

+ func NewMessage(topic string, payload interface{}, opts ...MessageOption) Message

+ type MessageOption func(*MessageOptions)

+ func WithMessageContentType(ct string) MessageOption

+ type MessageOptions struct

+ ContentType string

+ type Option func(*Options)

+ func Backoff(fn BackoffFunc) Option

+ func Broker(b broker.Broker) Option

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

+ func ContentType(ct string) Option

+ func DialTimeout(d time.Duration) Option

+ func PoolSize(d int) Option

+ func PoolTTL(d time.Duration) Option

+ func Registry(r registry.Registry) Option

+ func RequestTimeout(d time.Duration) Option

+ func Retries(i int) Option

+ func Retry(fn RetryFunc) Option

+ func Router(r router.Router) Option

+ func Selector(s selector.Selector) Option

+ func StreamTimeout(d time.Duration) Option

+ func Transport(t transport.Transport) Option

+ func Wrap(w Wrapper) Option

+ func WrapCall(cw ...CallWrapper) Option

+ type Options struct

+ Broker broker.Broker

+ Cache *Cache

+ CallOptions CallOptions

+ Codecs map[string]codec.NewCodec

+ ContentType string

+ Context context.Context

+ PoolSize int

+ PoolTTL time.Duration

+ Router router.Router

+ Selector selector.Selector

+ Transport transport.Transport

+ Wrappers []Wrapper

+ func NewOptions(options ...Option) Options

+ type PublishOption func(*PublishOptions)

+ func PublishContext(ctx context.Context) PublishOption

+ func WithExchange(e string) PublishOption

+ type PublishOptions struct

+ Context context.Context

+ Exchange string

+ type Request interface

+ Body func() interface{}

+ Codec func() codec.Writer

+ ContentType func() string

+ Endpoint func() string

+ Method func() string

+ Service func() string

+ Stream func() bool

+ func NewRequest(service, endpoint string, request interface{}, reqOpts ...RequestOption) Request

+ type RequestOption func(*RequestOptions)

+ func StreamingRequest() RequestOption

+ func WithContentType(ct string) RequestOption

+ type RequestOptions struct

+ ContentType string

+ Context context.Context

+ Stream bool

+ type Response interface

+ Codec func() codec.Reader

+ Header func() map[string]string

+ Read func() ([]byte, error)

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

+ type Stream interface

+ Close func() error

+ Context func() context.Context

+ Error func() error

+ Recv func(interface{}) error

+ Request func() Request

+ Response func() Response

+ Send func(interface{}) error

+ func NewStream(ctx context.Context, request Request, opts ...CallOption) (Stream, error)

+ type StreamWrapper func(Stream) Stream

+ type Wrapper func(Client) Client