integrationtest

Aug 6, 2018

Changes in this version

+ func Timeout(ctx context.Context, rawClient raw.Client) error

Jul 11, 2017

Changes in this version

+ func Blast(ctx context.Context, t *testing.T, rawClient raw.Client)

+ func Call(ctx context.Context, rawClient raw.Client) error

+ func CallUntilSuccess(t *testing.T, rawClient raw.Client, interval time.Duration)

+ func Register(dispatcher *yarpc.Dispatcher)

+ type TransportSpec struct

+ Addr func(xport peer.Transport, inbound transport.Inbound) string

+ Identify func(addr string) peer.Identifier

+ NewClientTransport func(t *testing.T) peer.Transport

+ NewInbound func(xport peer.Transport, addr string) transport.Inbound

+ NewServerTransport func(t *testing.T, addr string) peer.Transport

+ NewUnaryOutbound func(xport peer.Transport, pc peer.Chooser) transport.UnaryOutbound

+ func (s TransportSpec) NewClient(t *testing.T, addrs []string) (*yarpc.Dispatcher, raw.Client)

+ func (s TransportSpec) NewServer(t *testing.T, addr string) (*yarpc.Dispatcher, string)

+ func (s TransportSpec) Test(t *testing.T)

+ func (s TransportSpec) TestBackoffConnRoundRobin(t *testing.T)

+ func (s TransportSpec) TestConcurrentClientsRoundRobin(t *testing.T)

+ func (s TransportSpec) TestConnectAndStopRoundRobin(t *testing.T)