testcontrol

func (*AuthPath) CompleteSuccessfully ¶

func (ap *AuthPath) CompleteSuccessfully()

CompleteSuccessfully completes the login path successfully, as if the user did the whole auth dance.

func (*Server) AddDNSRecords ¶

func (s *Server) AddDNSRecords(records ...tailcfg.DNSRecord)

AddDNSRecords adds records to the server's DNS config.

func (*Server) AddFakeNode ¶

func (s *Server) AddFakeNode()

AddFakeNode injects a fake node into the server.

func (*Server) AddPingRequest ¶

func (s *Server) AddPingRequest(nodeKeyDst key.NodePublic, pr *tailcfg.PingRequest) bool

AddPingRequest sends the ping pr to nodeKeyDst.

It reports whether the message was enqueued. That is, it reports whether nodeKeyDst was connected.

func (*Server) AddRawMapResponse ¶

func (s *Server) AddRawMapResponse(nodeKeyDst key.NodePublic, mr *tailcfg.MapResponse) bool

AddRawMapResponse delivers the raw MapResponse mr to nodeKeyDst. It's meant for testing incremental map updates.

Once AddRawMapResponse has been sent to a node, all future automatic MapResponses to that node will be suppressed and only explicit MapResponses injected via AddRawMapResponse will be sent.

It reports whether the message was enqueued. That is, it reports whether nodeKeyDst was connected.

func (*Server) AllNodes ¶

func (s *Server) AllNodes() (nodes []*tailcfg.Node)

func (*Server) AwaitNodeInMapRequest ¶

func (s *Server) AwaitNodeInMapRequest(ctx context.Context, k key.NodePublic) error

AwaitNodeInMapRequest waits for node k to be stuck in a map poll. It returns an error if and only if the context is done first.

func (*Server) BaseURL ¶

func (s *Server) BaseURL() string

BaseURL returns the server's base URL, without trailing slash.

func (*Server) CompleteAuth ¶

func (s *Server) CompleteAuth(authPathOrURL string) bool

CompleteAuth marks the provided path or URL (containing "/auth/...") as successfully authenticated, unblocking any requests blocked on that in serveRegister.

func (*Server) CompleteDeviceApproval ¶

func (s *Server) CompleteDeviceApproval(controlUrl string, urlStr string, nodeKey *key.NodePublic) bool

Complete the device approval for this node.

This function returns false if the node does not exist, or you try to approve a device against a different control server.

func (*Server) ForceNetmapUpdate ¶

func (s *Server) ForceNetmapUpdate(ctx context.Context, nodeKey key.NodePublic) error

ForceNetmapUpdate waits for the node to get stuck in a map poll and then sends the current netmap (which may result in a redundant netmap). The intended use case is ensuring state changes propagate before running tests.

This should only be called for nodes connected as streaming clients. Calling this with a non-streaming node will result in non-deterministic behavior.

This function cannot guarantee that the node has processed the issued update, so tests should confirm processing by querying the node. By example:

if err := s.ForceNetmapUpdate(node.Key()); err != nil {
// handle error
}
for !updatesPresent(node.NetMap()) {
time.Sleep(10 * time.Millisecond)
}

func (*Server) InServeMap ¶

func (s *Server) InServeMap() int

InServeMap returns the number of clients currently in a MapRequest HTTP handler.

func (*Server) MapResponse ¶

func (s *Server) MapResponse(req *tailcfg.MapRequest) (res *tailcfg.MapResponse, err error)

MapResponse generates a MapResponse for a MapRequest.

No updates to s are done here.

func (*Server) Node ¶

func (s *Server) Node(nodeKey key.NodePublic) *tailcfg.Node

Node returns the node for nodeKey. It's always nil or cloned memory.

func (*Server) NodeRoundTripper ¶

func (s *Server) NodeRoundTripper(n key.NodePublic) http.RoundTripper

func (*Server) NumNodes ¶

func (s *Server) NumNodes() int

NumNodes returns the number of nodes in the testcontrol server.

This is useful when connecting a bunch of virtual machines to a testcontrol server to see how many of them connected successfully.

func (*Server) SendC2N ¶

func (s *Server) SendC2N(node key.NodePublic, req *http.Request, onRes func(*http.Response)) error

SendC2N sends req to node. When the response is received, onRes is called.

func (*Server) ServeHTTP ¶

func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*Server) SetExpireAllNodes ¶

func (s *Server) SetExpireAllNodes(expired bool)

Mark the Node key of every node as expired

func (*Server) SetGlobalAppCaps ¶

func (s *Server) SetGlobalAppCaps(appCaps tailcfg.PeerCapMap)

SetGlobalAppCaps configures global app capabilities. This is equivalent to

"grants": [
   {
     "src": ["*"],
     "dst": ["*"],
     "app": <contents of the input map>
   }
]

func (*Server) SetJailed ¶

func (s *Server) SetJailed(a, b key.NodePublic, jailed bool)

SetJailed sets b to be jailed when it is a peer of a.

func (*Server) SetMasqueradeAddresses ¶

func (s *Server) SetMasqueradeAddresses(pairs []MasqueradePair)

SetMasqueradeAddresses sets the masquerade addresses for the server. See MasqueradePair for more details.

func (*Server) SetNodeCapMap ¶

func (s *Server) SetNodeCapMap(nodeKey key.NodePublic, capMap tailcfg.NodeCapMap)

SetNodeCapMap overrides the capability map the specified client receives.

func (*Server) SetSubnetRoutes ¶

func (s *Server) SetSubnetRoutes(nodeKey key.NodePublic, routes []netip.Prefix)

SetSubnetRoutes sets the list of subnet routes which a node is routing.

func (*Server) UpdateNode ¶

func (s *Server) UpdateNode(n *tailcfg.Node) (peersToUpdate []tailcfg.NodeID)