config

Jul 11, 2017

Changes in this version

+ type Backoff struct

+ Exponential ExponentialBackoff

+ func (c Backoff) Strategy() (backoffapi.Strategy, error)

+ type ExponentialBackoff struct

+ First time.Duration

+ Max time.Duration

+ func (c ExponentialBackoff) Strategy() (backoffapi.Strategy, error)

Jun 8, 2017

Changes in this version

type Configurator

+ func (c *Configurator) MustRegisterPeerList(s PeerListSpec)

+ func (c *Configurator) MustRegisterPeerListUpdater(s PeerListUpdaterSpec)

+ func (c *Configurator) RegisterPeerList(s PeerListSpec) error

+ func (c *Configurator) RegisterPeerListUpdater(s PeerListUpdaterSpec) error

+ type PeerChooser struct

+ func (pc PeerChooser) BuildPeerChooser(transport peer.Transport, identify func(string) peer.Identifier, kit *Kit) (peer.Chooser, error)

+ func (pc PeerChooser) Empty() bool

+ type PeerChooserPreset struct

+ BuildPeerChooser interface{}

+ Name string

+ type PeerListSpec struct

+ BuildPeerList interface{}

+ Name string

+ type PeerListUpdaterSpec struct

+ BuildPeerListUpdater interface{}

+ Name string

type TransportSpec

+ PeerChooserPresets []PeerChooserPreset

May 1, 2017

Changes in this version

+ type BinderSpec struct

+ BuildBinder interface{}

+ Name string

+ type ChooserSpec struct

+ BuildChooser interface{}

+ Name string

type Configurator

+ func (c *Configurator) MustRegisterBinder(s BinderSpec)

+ func (c *Configurator) MustRegisterChooser(s ChooserSpec)

+ func (c *Configurator) RegisterBinder(s BinderSpec) error

+ func (c *Configurator) RegisterChooser(s ChooserSpec) error

+ type Kit struct

+ func (k *Kit) ServiceName() string

+ type Option func(*Configurator)

+ func InterpolationResolver(f func(k string) (v string, ok bool)) Option

Mar 20, 2017

Changes in this version

+ type Configurator struct

+ func New() *Configurator

+ func (c *Configurator) LoadConfig(data interface{}) (yarpc.Config, error)

+ func (c *Configurator) LoadConfigFromYAML(r io.Reader) (yarpc.Config, error)

+ func (c *Configurator) MustRegisterTransport(t TransportSpec)

+ func (c *Configurator) NewDispatcher(data interface{}) (*yarpc.Dispatcher, error)

+ func (c *Configurator) NewDispatcherFromYAML(r io.Reader) (*yarpc.Dispatcher, error)

+ func (c *Configurator) RegisterTransport(t TransportSpec) error

+ type TransportSpec struct

+ BuildInbound interface{}

+ BuildOnewayOutbound interface{}

+ BuildTransport interface{}

+ BuildUnaryOutbound interface{}

+ Name string