rpctest

Documentation

Index

• func MultiConnPair(peerIdServ, peerIdClient string) (serv, client transport.MultiConn)
• type TestPool
  • func NewTestPool() *TestPool
  • func (t *TestPool) AddPeer(ctx context.Context, p peer.Peer) (err error)
  • func (t *TestPool) Close(ctx context.Context) (err error)
  • func (t *TestPool) Get(ctx context.Context, id string) (peer.Peer, error)
  • func (t *TestPool) GetOneOf(ctx context.Context, peerIds []string) (peer.Peer, error)
  • func (t *TestPool) Init(a *app.App) (err error)
  • func (t *TestPool) Name() (name string)
  • func (t *TestPool) Run(ctx context.Context) (err error)
  • func (t *TestPool) WithServer(ts *TestServer) *TestPool
• type TestServer
  • func NewTestServer() *TestServer
  • func (s *TestServer) Close(ctx context.Context) (err error)
  • func (s *TestServer) Dial(peerId string) (clientPeer peer.Peer, err error)
  • func (s *TestServer) DrpcConfig() rpc.Config
  • func (s *TestServer) Init(a *app.App) (err error)
  • func (s *TestServer) Name() (name string)
  • func (s *TestServer) Run(ctx context.Context) (err error)
  • func (s *TestServer) ServeConn(ctx context.Context, conn net.Conn) (err error)

Functions

func MultiConnPair

func MultiConnPair(peerIdServ, peerIdClient string) (serv, client transport.MultiConn)

Types

type TestPool

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

func NewTestPool

func NewTestPool() *TestPool

func (*TestPool) AddPeer

func (t *TestPool) AddPeer(ctx context.Context, p peer.Peer) (err error)

func (*TestPool) Close

func (t *TestPool) Close(ctx context.Context) (err error)

func (*TestPool) Get

func (t *TestPool) Get(ctx context.Context, id string) (peer.Peer, error)

func (*TestPool) GetOneOf

func (t *TestPool) GetOneOf(ctx context.Context, peerIds []string) (peer.Peer, error)

func (*TestPool) Init

func (t *TestPool) Init(a *app.App) (err error)

func (*TestPool) Name

func (t *TestPool) Name() (name string)

func (*TestPool) Run

func (t *TestPool) Run(ctx context.Context) (err error)

func (*TestPool) WithServer

func (t *TestPool) WithServer(ts *TestServer) *TestPool

type TestServer

type TestServer struct {
	*drpcmux.Mux
	*drpcserver.Server
}

func NewTestServer

func NewTestServer() *TestServer

func (*TestServer) Close

func (s *TestServer) Close(ctx context.Context) (err error)

func (*TestServer) Dial

func (s *TestServer) Dial(peerId string) (clientPeer peer.Peer, err error)

func (*TestServer) DrpcConfig

func (s *TestServer) DrpcConfig() rpc.Config

func (*TestServer) Init

func (s *TestServer) Init(a *app.App) (err error)

func (*TestServer) Name

func (s *TestServer) Name() (name string)

func (*TestServer) Run

func (s *TestServer) Run(ctx context.Context) (err error)

func (*TestServer) ServeConn

func (s *TestServer) ServeConn(ctx context.Context, conn net.Conn) (err error)