yarpctest

Documentation

Overview

Package yarpctest provides utilities to test YARPC services and clients.

Index

• type FakePeer
  • func (p *FakePeer) EndRequest()
  • func (p *FakePeer) Identifier() string
  • func (p *FakePeer) StartRequest()
  • func (p *FakePeer) Status() peer.Status
• type FakeTransport
  • func NewFakeTransport() *FakeTransport
  • func (t *FakeTransport) ReleasePeer(id peer.Identifier, ps peer.Subscriber) error
  • func (t *FakeTransport) RetainPeer(id peer.Identifier, ps peer.Subscriber) (peer.Peer, error)

Types

type FakePeer

type FakePeer struct {
	// contains filtered or unexported fields
}

FakePeer is a fake peer with an identifier.

func (*FakePeer) EndRequest

func (p *FakePeer) EndRequest()

EndRequest does nothing.

func (*FakePeer) Identifier

func (p *FakePeer) Identifier() string

Identifier returns the fake peer identifier.

func (*FakePeer) StartRequest

func (p *FakePeer) StartRequest()

StartRequest does nothing.

func (*FakePeer) Status

func (p *FakePeer) Status() peer.Status

Status returns the fake peer status.

type FakeTransport

type FakeTransport struct {
	transport.Lifecycle
}

FakeTransport is a fake transport.

func NewFakeTransport

func NewFakeTransport() *FakeTransport

NewFakeTransport returns a fake transport.

func (*FakeTransport) ReleasePeer

func (t *FakeTransport) ReleasePeer(id peer.Identifier, ps peer.Subscriber) error

ReleasePeer does nothing.

func (*FakeTransport) RetainPeer

func (t *FakeTransport) RetainPeer(id peer.Identifier, ps peer.Subscriber) (peer.Peer, error)

RetainPeer returns a fake peer.