testPool: implement pool.Service
This commit is contained in:
parent
f6e2cc3890
commit
c51e3e2e05
@ -66,6 +66,10 @@ func (t *TestPool) DialOneOf(ctx context.Context, peerIds []string) (peer.Peer,
|
|||||||
return &testPeer{id: peerIds[rand.Intn(len(peerIds))], Conn: t.ts.Dial(ctx)}, nil
|
return &testPeer{id: peerIds[rand.Intn(len(peerIds))], Conn: t.ts.Dial(ctx)}, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (t *TestPool) NewPool(name string) pool.Pool {
|
||||||
|
return t
|
||||||
|
}
|
||||||
|
|
||||||
func (t *TestPool) Init(a *app.App) (err error) {
|
func (t *TestPool) Init(a *app.App) (err error) {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user