func BidirectionalTunnels(ctxcontext.Context, t *testing.T, coordinatortailnet.CoordinatorV2)

func GracefulDisconnectTest(ctxcontext.Context, t *testing.T, coordinatortailnet.CoordinatorV2)

func LostTest(ctxcontext.Context, t *testing.T, coordinatortailnet.CoordinatorV2)

func ReadyForHandshakeNoPermissionTest(ctxcontext.Context, t *testing.T, coordinatortailnet.CoordinatorV2)

func ReadyForHandshakeTest(ctxcontext.Context, t *testing.T, coordinatortailnet.CoordinatorV2)

type FakeCoordinateeAuth struct {Chan chan struct{}}

func (FakeCoordinateeAuth)Authorize¶added inv2.18.0

func (fFakeCoordinateeAuth) Authorize(ctxcontext.Context, _ *proto.CoordinateRequest)error

type FakeSubjectKey struct{}

type Peer struct {IDuuid.UUID// contains filtered or unexported fields}

funcNewAgent¶added inv2.16.0

func NewAgent(ctxcontext.Context, ttesting.TB, coordtailnet.CoordinatorV2, namestring) *Peer

NewAgent is a wrapper around NewPeer, creating a peer with Agent auth tied to its ID

funcNewClient¶added inv2.16.0

func NewClient(ctxcontext.Context, ttesting.TB, coordtailnet.CoordinatorV2, namestring, agentIDuuid.UUID) *Peer

NewClient is a wrapper around NewPeer, creating a peer with Client auth tied to the provided agentID

funcNewPeer¶

func NewPeer(ctxcontext.Context, ttesting.TB, coordtailnet.CoordinatorV2, namestring, opts ...PeerOption) *Peer

func (*Peer)AddTunnel¶

func (p *Peer) AddTunnel(otheruuid.UUID)

func (*Peer)AssertEventuallyDisconnected¶

func (p *Peer) AssertEventuallyDisconnected(otheruuid.UUID)

func (*Peer)AssertEventuallyGetsError¶added inv2.11.0

func (p *Peer) AssertEventuallyGetsError(matchstring)

func (*Peer)AssertEventuallyHasDERP¶

func (p *Peer) AssertEventuallyHasDERP(otheruuid.UUID, derpint32)

func (*Peer)AssertEventuallyLost¶

func (p *Peer) AssertEventuallyLost(otheruuid.UUID)

func (*Peer)AssertEventuallyReadyForHandshake¶added inv2.11.0

func (p *Peer) AssertEventuallyReadyForHandshake(otheruuid.UUID)

func (*Peer)AssertEventuallyResponsesClosed¶

func (p *Peer) AssertEventuallyResponsesClosed(expectedErrorstring)

func (*Peer)AssertNeverHasDERPs¶added inv2.16.0

func (p *Peer) AssertNeverHasDERPs(ctxcontext.Context, otheruuid.UUID, expected ...int32)

func (*Peer)AssertNeverUpdateKind¶added inv2.15.0

func (p *Peer) AssertNeverUpdateKind(peeruuid.UUID, kindproto.CoordinateResponse_PeerUpdate_Kind)

AssertNeverUpdateKind asserts that we have not receivedany updates on the provided peer for the provided kind.

func (*Peer)AssertNotClosed¶added inv2.16.0

func (p *Peer) AssertNotClosed(dtime.Duration)

func (*Peer)Close¶

func (p *Peer) Close(ctxcontext.Context)

func (*Peer)ConnectToCoordinator¶added inv2.15.0

func (p *Peer) ConnectToCoordinator(ctxcontext.Context, ctailnet.CoordinatorV2)

func (*Peer)Disconnect¶

func (p *Peer) Disconnect()

func (*Peer)ReadyForHandshake¶added inv2.11.0

func (p *Peer) ReadyForHandshake(peeruuid.UUID)

func (*Peer)RemoveTunnel¶added inv2.18.0

func (p *Peer) RemoveTunnel(otheruuid.UUID)

func (*Peer)UngracefulDisconnect¶added inv2.16.0

func (p *Peer) UngracefulDisconnect(ctxcontext.Context)

func (*Peer)UpdateDERP¶

func (p *Peer) UpdateDERP(derpint32)

func (*Peer)UpdateNode¶added inv2.16.0

func (p *Peer) UpdateNode(node *proto.Node)

type PeerOption func(*Peer)

funcWithAuth¶added inv2.16.0

func WithAuth(authtailnet.CoordinateeAuth)PeerOption

funcWithID¶added inv2.16.0

func WithID(iduuid.UUID)PeerOption

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