client

Feb 23, 2019

retracted

Changes in this version

type PublishOption

+ func WithExchange(e string) PublishOption

type PublishOptions

+ Exchange string

Jan 17, 2019

retracted

Changes in this version

type Stream

+ Response func() Response

Jan 13, 2019

retracted

Changes in this version

+ var DefaultCodecs = map[string]codec.NewCodec

+ var DefaultContentType = "application/protobuf"

type Option

+ func WithRouter(r Router) Option

type Options

+ Router Router

type Request

+ Body func() interface{}

+ Codec func() codec.Writer

+ Endpoint func() string

+ type Response interface

+ Codec func() codec.Reader

+ Header func() map[string]string

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

+ type Router interface

+ SendRequest func(context.Context, Request) (Response, error)

Jul 26, 2018

retracted

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)

May 30, 2018

retracted

Changes in this version

+ type MessageOption func(*MessageOptions)

+ type MessageOptions struct

+ ContentType string

Apr 17, 2018

retracted

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

Jun 11, 2017

retracted

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