client

package

Go to main page

Versions in this module

v0

v0.10.0

Jul 26, 2018

Changes in this version

+ 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)

v0.9.0

May 30, 2018

Changes in this version

+ type MessageOption func(*MessageOptions)

+ type MessageOptions struct

+ ContentType string

v0.8.0

Apr 17, 2018

Changes in this version

type CallOption

+ func WithAddress(a string) CallOption

type CallOptions

+ Address string

type Client

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

+ type Message interface

+ ContentType func() string

+ Payload func() interface{}

+ Topic func() string

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

type RequestOption

+ func WithContentType(ct string) RequestOption

type RequestOptions

+ ContentType string

type Stream

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

+ Close func() error

+ Context func() context.Context

+ Error func() error

+ Recv func(interface{}) error

+ Request func() Request

+ Send func(interface{}) error

v0.7.0

Apr 8, 2018

v0.6.0

Mar 22, 2018

v0.5.0

Mar 4, 2018

v0.4.0

Feb 19, 2018

v0.3.0

Jan 2, 2018

v0.2.0

Oct 29, 2017

v0.1.4

Aug 25, 2017

v0.1.3

Aug 15, 2017

v0.1.2

Jul 18, 2017

v0.1.1

Jun 12, 2017

v0.1.0

Jun 11, 2017

Changes in this version

+ var DefaultBackoff = exponentialBackoff

+ var DefaultClient Client = newRpcClient()

+ var DefaultPoolSize = 0

+ var DefaultPoolTTL = time.Minute

+ var DefaultRequestTimeout = time.Second * 5

+ var DefaultRetries = 1

+ var DefaultRetry = alwaysRetry

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

+ func CallRemote(ctx context.Context, address string, request Request, response interface{}, ...) error

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

+ func Publish(ctx context.Context, p Publication) error

+ func String() string

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

+ type CallFunc func(ctx context.Context, address string, req Request, rsp interface{}, ...) error

+ type CallOption func(*CallOptions)

+ func WithBackoff(fn BackoffFunc) CallOption

+ func WithCallWrapper(cw ...CallWrapper) CallOption

+ func WithDialTimeout(d time.Duration) CallOption

+ func WithRequestTimeout(d time.Duration) CallOption

+ func WithRetries(i int) CallOption

+ func WithRetry(fn RetryFunc) CallOption

+ func WithSelectOption(so ...selector.SelectOption) CallOption

+ type CallOptions struct

+ Backoff BackoffFunc

+ CallWrappers []CallWrapper

+ Context context.Context

+ DialTimeout time.Duration

+ RequestTimeout time.Duration

+ Retries int

+ Retry RetryFunc

+ SelectOptions []selector.SelectOption

+ type CallWrapper func(CallFunc) CallFunc

+ type Client interface

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

+ CallRemote func(ctx context.Context, addr string, req Request, rsp interface{}, ...) error

+ Init func(...Option) error

+ NewJsonRequest func(service, method string, req interface{}, reqOpts ...RequestOption) Request

+ NewProtoRequest func(service, method string, req interface{}, reqOpts ...RequestOption) Request

+ NewPublication func(topic string, msg interface{}) Publication

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

+ Options func() Options

+ Publish func(ctx context.Context, p Publication, opts ...PublishOption) error

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

+ StreamRemote func(ctx context.Context, addr string, req Request, opts ...CallOption) (Streamer, error)

+ String func() string

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

+ func NewClient(opt ...Option) Client

+ 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 Selector(s selector.Selector) Option

+ func Transport(t transport.Transport) Option

+ func Wrap(w Wrapper) Option

+ func WrapCall(cw ...CallWrapper) Option

+ type Options struct

+ Broker broker.Broker

+ CallOptions CallOptions

+ Codecs map[string]codec.NewCodec

+ ContentType string

+ Context context.Context

+ PoolSize int

+ PoolTTL time.Duration

+ Registry registry.Registry

+ Selector selector.Selector

+ Transport transport.Transport

+ Wrappers []Wrapper

+ type Publication interface

+ ContentType func() string

+ Message func() interface{}

+ Topic func() string

+ func NewPublication(topic string, message interface{}) Publication

+ type PublishOption func(*PublishOptions)

+ type PublishOptions struct

+ Context context.Context

+ type Request interface

+ ContentType func() string

+ Method func() string

+ Request func() interface{}

+ Service func() string

+ Stream func() bool

+ func NewJsonRequest(service, method string, request interface{}, reqOpts ...RequestOption) Request

+ func NewProtoRequest(service, method string, request interface{}, reqOpts ...RequestOption) Request

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

+ type RequestOption func(*RequestOptions)

+ func StreamingRequest() RequestOption

+ type RequestOptions struct

+ Context context.Context

+ Stream bool

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

+ type StreamWrapper func(Streamer) Streamer

+ type Streamer interface

+ Close func() error

+ Context func() context.Context

+ Error func() error

+ Recv func(interface{}) error

+ Request func() Request

+ Send func(interface{}) error

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

+ func StreamRemote(ctx context.Context, address string, request Request, opts ...CallOption) (Streamer, error)

+ type Wrapper func(Client) Client

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL