func ackXdsResponse()

in dp_check/dp_check.go [692:704]

• 13 lines of code
• 2 McCabe index (conditional complexity)

func ackXdsResponse(stream adsStream, node *v3corepb.Node, typeURL, resourceName string, versionInfoMap, nonceMap map[string]string) error {
	ackReq := &v3discoverypb.DiscoveryRequest{
		VersionInfo:   versionInfoMap[typeURL],
		Node:          node,
		ResourceNames: []string{resourceName},
		TypeUrl:       typeURL,
		ResponseNonce: nonceMap[typeURL],
	}
	if err := stream.Send(ackReq); err != nil {
		return fmt.Errorf("failed to ack xDS response: %v", err)
	}
	return nil
}